com.continuent.tungsten.replicator.applier
Class MySQLDrizzleApplier

java.lang.Object
  com.continuent.tungsten.replicator.applier.JdbcApplier
      com.continuent.tungsten.replicator.applier.MySQLApplier
          com.continuent.tungsten.replicator.applier.MySQLDrizzleApplier

All Implemented Interfaces:

RawApplier, ReplicatorPlugin

public class MySQLDrizzleApplier
extends MySQLApplier

Version:

1.0

Author:

Stephane Giron

Field Summary

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

BIGINT_MAX_VALUE, host, port, urlOptions

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

MySQLDrizzleApplier()

Method Summary

protected void	applyLoadDataLocal(LoadDataFileQuery data, java.io.File temporaryFile) applyLoadDataLocal executes the LoadDataFileQuery.
protected void	applyStatementData(StatementData data)
void	configure(PluginContext context) Generate URL suitable for MySQL and then delegate remaining configuration to superclass.
protected void	setInteger(java.sql.PreparedStatement prepStatement, int bindLoc, java.lang.Object valToInsert)
protected void	setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)

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

addColumn, applyRowIdData, hexdump, setHost, setPort, setUrlOptions

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

apply, applyOneRowChangePrepared, applyRowChangeData, applySessionVariables, applySetTimestamp, 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

Constructor Detail

MySQLDrizzleApplier

public MySQLDrizzleApplier()

Method Detail

configure

public void configure(PluginContext context)
               throws ReplicatorException

Description copied from class: MySQLApplier

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

Specified by:

configure in interface ReplicatorPlugin

Overrides:

configure in class MySQLApplier

Throws:

ReplicatorException - Thrown if configuration is incomplete or fails

See Also:

ReplicatorPlugin.configure(PluginContext context)

applyStatementData

protected void applyStatementData(StatementData data)
                           throws ReplicatorException

Overrides:

applyStatementData in class JdbcApplier

Throws:

ReplicatorException

applyLoadDataLocal

protected void applyLoadDataLocal(LoadDataFileQuery data,
                                  java.io.File temporaryFile)
                           throws ReplicatorException

Description copied from class: MySQLApplier

applyLoadDataLocal executes the LoadDataFileQuery. This method is most likely to be database specific. See for example :

Overrides:

applyLoadDataLocal in class MySQLApplier

Parameters:

data - The LoadDataFileQuery containing the query that has to be executed

temporaryFile - The file containing data to be loaded

Throws:

ReplicatorException - if an error occurs

See Also:

JdbcApplier.applyStatementData(com.continuent.tungsten.replicator.dbms.StatementData)

setInteger

protected void setInteger(java.sql.PreparedStatement prepStatement,
                          int bindLoc,
                          java.lang.Object valToInsert)
                   throws java.sql.SQLException

Overrides:

setInteger in class MySQLApplier

Throws:

java.sql.SQLException

setObject

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

Description copied from class: MySQLApplier

Overrides:

setObject in class MySQLApplier

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)