com.continuent.tungsten.replicator.applier
Class DrizzleApplier

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

All Implemented Interfaces:

RawApplier, ReplicatorPlugin

public class DrizzleApplier
extends JdbcApplier

Stub applier class that automatically constructs url from Drizzle-specific properties like host, port, and service.

Version:

1.0

Author:

Robert Hodges, Marcus Eriksson

Field Summary

protected java.lang.String	host
protected int	port
protected java.lang.String	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

DrizzleApplier()

Method Summary

protected void	applyRowIdData(RowIdData data)
void	configure(PluginContext context) Generate URL suitable for Drizzle and then delegate remaining configuration to superclass.
void	setHost(java.lang.String host) Host name or IP address.
void	setPort(java.lang.String portAsString) TCP/IP port number, a positive integer.
void	setUrlOptions(java.lang.String urlOptions) JDBC URL options with a leading ?.

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

addColumn, apply, applyLoadDataLocal, applyOneRowChangePrepared, applyRowChangeData, applySessionVariables, applySetTimestamp, applyStatementData, applyUseSchema, bindColumnValues, commit, fillColumnNames, getDatabase, getLastEvent, logFailedStatementSQL, logFailedStatementSQL, needNewSQLStatement, prepare, printColumnSpec, release, rollback, setDriver, setGetColumnMetadataFromDB, setIgnoreSessionVars, setObject, 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

urlOptions

protected java.lang.String urlOptions

Constructor Detail

DrizzleApplier

public DrizzleApplier()

Method Detail

setHost

public void setHost(java.lang.String host)

Host name or IP address.

setPort

public void setPort(java.lang.String portAsString)

TCP/IP port number, a positive integer.

setUrlOptions

public void setUrlOptions(java.lang.String urlOptions)

JDBC URL options with a leading ?.

configure

public void configure(PluginContext context)
               throws ReplicatorException

Generate URL suitable for Drizzle 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(com.continuent.tungsten.replicator.plugin.PluginContext context)

applyRowIdData

protected void applyRowIdData(RowIdData data)
                       throws ReplicatorException

Overrides:

applyRowIdData in class JdbcApplier

Throws:

ReplicatorException