Package org.jumpmind.symmetric.io

Class AbstractBulkDatabaseWriter

java.lang.Object

org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriter

org.jumpmind.symmetric.io.data.writer.DynamicDefaultDatabaseWriter

org.jumpmind.symmetric.io.AbstractBulkDatabaseWriter

All Implemented Interfaces:

IDataResource, IDataWriter

Direct Known Subclasses:

JdbcBatchBulkDatabaseWriter

public abstract class AbstractBulkDatabaseWriter
extends DynamicDefaultDatabaseWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

AbstractDatabaseWriter.LoadStatus

Field Summary

Fields inherited from class org.jumpmind.symmetric.io.data.writer.DynamicDefaultDatabaseWriter

tablePrefix, targetPlatform, targetTransaction

Fields inherited from class org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriter

CUR_DATA, currentDmlStatement, currentDmlValues, hasUncommittedDdl, isCteExpression, logSqlBuilder, platform, transaction

Fields inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

batch, CONFLICT_ERROR, CONFLICT_IGNORE, conflictResolver, context, isRequiresSavePointsInTransaction, lastApplyChangesOnly, lastData, lastUseConflictDetection, missingTables, sourceTable, statistics, targetTable, targetTables, TRANSACTION_ABORTED, uncommittedCount, writerSettings

Constructor Summary

Constructors

Constructor	Description
AbstractBulkDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String tablePrefix)
AbstractBulkDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String tablePrefix, DatabaseWriterSettings settings)

Method Summary

Modifier and Type	Method	Description
protected abstract void	bulkWrite(CsvData data)
void	end(Batch batch, boolean inError)
boolean	isFallBackToDefault()
void	start(Batch batch)
final void	write(CsvData data)
protected final void	writeDefault(CsvData data)

Methods inherited from class org.jumpmind.symmetric.io.data.writer.DynamicDefaultDatabaseWriter

close, commit, getPlatform, getPlatform, getPlatform, getTablePrefix, getTargetPlatform, getTargetTransaction, getTransaction, getTransaction, getTransaction, isLoadOnly, isSymmetricTable, isSymmetricTable, open, rollback

Methods inherited from class org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriter

allowInsertIntoAutoIncrementColumns, bindVariables, commit, containsNullLookupKeyDataSinceLastStatement, create, create, delete, dmlValuesToString, doesColumnNeedUpdated, end, execute, getCurData, getCurrentDmlStatement, getSqlStatements, getTableKey, getWriterSettings, insert, isCteExpression, logDataTruncation, logFailureDetails, lookupTableAtTarget, lookupTableFromCache, prepare, prepare, prepareAndExecute, preprocessSqlStatement, putTableInCache, quoteString, replaceCteExpression, requireNewStatement, sql, start, targetTableWasChangedByFilter, update, updateChangedDataIndicator

Methods inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

checkForEarlyCommit, filterAfter, filterBefore, filterError, getBatch, getConflictResolver, getContext, getLookupDataMap, getPkDataFor, getRowData, getSourceTable, getStatistics, getTargetTable, hasFilterThatHandlesMissingTable, notifyFiltersBatchCommitted, notifyFiltersBatchComplete, notifyFiltersBatchRolledback, notifyFiltersEarlyCommit, script, setConflictResolver

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractBulkDatabaseWriter

public AbstractBulkDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String tablePrefix)

AbstractBulkDatabaseWriter

public AbstractBulkDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String tablePrefix,
 DatabaseWriterSettings settings)

Method Details

start

public void start(Batch batch)

Specified by:

start in interface IDataWriter

Overrides:

start in class AbstractDatabaseWriter

write

public final void write(CsvData data)

Specified by:

write in interface IDataWriter

Overrides:

write in class AbstractDatabaseWriter

end

public void end(Batch batch,
 boolean inError)

Specified by:

end in interface IDataWriter

Overrides:

end in class DefaultDatabaseWriter

isFallBackToDefault

public boolean isFallBackToDefault()

writeDefault

protected final void writeDefault(CsvData data)

bulkWrite

protected abstract void bulkWrite(CsvData data)