com.continuent.tungsten.replicator.applier.batch
Class InfiniDBBatchApplier

java.lang.Object
  com.continuent.tungsten.replicator.applier.batch.SimpleBatchApplier
      com.continuent.tungsten.replicator.applier.batch.InfiniDBBatchApplier

All Implemented Interfaces:

RawApplier, ReplicatorPlugin

public class InfiniDBBatchApplier
extends SimpleBatchApplier

Version:

1.0

Author:

Stephane Giron

Field Summary

Fields inherited from class com.continuent.tungsten.replicator.applier.batch.SimpleBatchApplier

charset, cleanUpFiles, commitSeqnoTable, conn, consistencySelect, consistencyTable, dateFormatter, DELETE, driver, heartbeatTable, ignoreSessionPattern, INSERT, metadataSchema, onLoadMismatch, password, showCommands, stageColumnPrefix, stageDirectory, stageMergeScript, stagePkeyColumn, stageSchemaPrefix, stageTablePrefix, startupScript, statement, timezone, url, user

Constructor Summary

InfiniDBBatchApplier()

Method Summary

protected void

clearStageTable(CsvInfo info) Needs to be done in a transaction, otherwise cpimport will be unable to get the lock on the stage table !

Methods inherited from class com.continuent.tungsten.replicator.applier.batch.SimpleBatchApplier

apply, assertNotNull, commit, configure, getCsvString, getLastEvent, initializeGenerator, prepare, release, rollback, setCharset, setCleanUpFiles, setDriver, setOnLoadMismatch, setPassword, setShowCommands, setStageColumnPrefix, setStageDirectory, setStageMergeScript, setStagePkeyColumn, setStageSchemaPrefix, setStageTablePrefix, setStartupScript, setTaskId, setTimezone, setUrl, setUser

Methods inherited from class java.lang.Object

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

Constructor Detail

InfiniDBBatchApplier

public InfiniDBBatchApplier()

Method Detail

clearStageTable

protected void clearStageTable(CsvInfo info)
                        throws ReplicatorException

Needs to be done in a transaction, otherwise cpimport will be unable to get the lock on the stage table !

Overrides:

clearStageTable in class SimpleBatchApplier

Parameters:

info -

Throws:

ReplicatorException