com.continuent.tungsten.replicator.applier
Class OracleApplier

java.lang.Object
  com.continuent.tungsten.replicator.applier.JdbcApplier
      com.continuent.tungsten.replicator.applier.OracleApplier

All Implemented Interfaces:

RawApplier, ReplicatorPlugin

public class OracleApplier
extends JdbcApplier

Field Summary

protected java.lang.String	host
protected int	port
protected java.lang.String	service

Fields inherited from class com.continuent.tungsten.replicator.applier.JdbcApplier

commitCount, commitSeqnoTable, conn, consistencySelect, consistencyTable, currentOptions, currentSchema, currentTimestamp, driver, eventCount, heartbeatTable, ignoreSessionPattern, ignoreSessionVars, lastSessionId, maxSQLLogLength, metadataSchema, password, runtime, statement, taskId, url, user

Constructor Summary

OracleApplier()

Method Summary

protected Column	addColumn(java.sql.ResultSet rs, java.lang.String columnName) Returns a new column definition.
void	configure(PluginContext context) Generate URL suitable for MySQL and then delegate remaining configuration to superclass.
void	setHost(java.lang.String host)
protected void	setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
void	setPort(java.lang.String portAsString)
void	setService(java.lang.String service)

Methods inherited from class com.continuent.tungsten.replicator.applier.JdbcApplier

apply, applyLoadDataLocal, applyOneRowChangePrepared, applyRowChangeData, applyRowIdData, applySessionVariables, applySetTimestamp, applyStatementData, applyUseSchema, bindColumnValues, commit, fillColumnNames, getDatabase, getLastEvent, logFailedStatementSQL, logFailedStatementSQL, needNewSQLStatement, prepare, printColumnSpec, release, rollback, setDriver, setGetColumnMetadataFromDB, setIgnoreSessionVars, setPassword, setTaskId, setUrl, setUser

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

host

protected java.lang.String host

port

protected int port

service

protected java.lang.String service

Constructor Detail

OracleApplier

public OracleApplier()

Method Detail

setHost

public void setHost(java.lang.String host)

setPort

public void setPort(java.lang.String portAsString)

setService

public void setService(java.lang.String service)

configure

public void configure(PluginContext context)
               throws ReplicatorException

Generate URL suitable for MySQL and then delegate remaining configuration to superclass.

Specified by:

configure in interface ReplicatorPlugin

Overrides:

configure in class JdbcApplier

Throws:

ReplicatorException - Thrown if configuration is incomplete or fails

See Also:

ReplicatorPlugin.configure(PluginContext context)

setObject

protected void setObject(java.sql.PreparedStatement prepStatement,
                         int bindLoc,
                         OneRowChange.ColumnVal value,
                         OneRowChange.ColumnSpec columnSpec)
                  throws java.sql.SQLException

Overrides:

setObject in class JdbcApplier

Throws:

java.sql.SQLException

See Also:

JdbcApplier.setObject(java.sql.PreparedStatement, int, com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnVal, com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnSpec)

addColumn

protected Column addColumn(java.sql.ResultSet rs,
                           java.lang.String columnName)
                    throws java.sql.SQLException

Description copied from class: JdbcApplier

Returns a new column definition.

Overrides:

addColumn in class JdbcApplier

Parameters:

rs - Metadata resultset

columnName - Name of the column to be added

Returns:

the column definition

Throws:

java.sql.SQLException - if an error occurs