Package org.jumpmind.symmetric.io

Class JdbcBatchBulkDatabaseWriter

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

org.jumpmind.symmetric.io.JdbcBatchBulkDatabaseWriter

All Implemented Interfaces:

IDataResource, IDataWriter

public class JdbcBatchBulkDatabaseWriter
extends AbstractBulkDatabaseWriter

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, targetColumnSourceReferencesMap, targetTable, targetTables, TRANSACTION_ABORTED, uncommittedCount, writerSettings

Constructor Summary

Constructors

Constructor	Description
JdbcBatchBulkDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String tablePrefix, DatabaseWriterSettings writerSettings)

Method Summary

Modifier and Type	Method	Description
protected void	bulkWrite(CsvData data)
protected void	checkForConflict(boolean isDml)
protected AbstractDatabaseWriter.LoadStatus	delete(CsvData data, boolean useConflictDetection)
void	end(Batch batch, boolean inError)
protected int	execute(CsvData data, String[] values)
protected AbstractDatabaseWriter.LoadStatus	insert(CsvData data)
protected void	prepare()
protected boolean	requireNewStatement(DmlStatement.DmlType currentType, CsvData data, boolean applyChangesOnly, boolean useConflictDetection, Conflict.DetectConflict detectType)
void	start(Batch batch)
protected AbstractDatabaseWriter.LoadStatus	update(CsvData data, boolean applyChangesOnly, boolean useConflictDetection)

Methods inherited from class org.jumpmind.symmetric.io.AbstractBulkDatabaseWriter

isFallBackToDefault, write, writeDefault

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, checkTargetTableHasColumns, commit, containsNullLookupKeyDataSinceLastStatement, create, create, dmlValuesToString, doesColumnNeedUpdated, end, getCurData, getCurrentDmlStatement, getSqlStatements, getTableKey, getWriterSettings, isCteExpression, isDml, logDataTruncation, logFailureDetails, logFailureDetails, lookupTableAtTarget, lookupTableFromCache, prepare, prepareAndExecute, preprocessSqlStatement, putTableInCache, quoteString, removeGeneratedColumns, replaceCteExpression, replaceCteExpression, sql, start, targetTableWasChangedByFilter, updateChangedDataIndicator

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

JdbcBatchBulkDatabaseWriter

public JdbcBatchBulkDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String tablePrefix,
 DatabaseWriterSettings writerSettings)

Method Details

start

public void start(Batch batch)

Specified by:

start in interface IDataWriter

Overrides:

start in class AbstractBulkDatabaseWriter

bulkWrite

protected void bulkWrite(CsvData data)

Specified by:

bulkWrite in class AbstractBulkDatabaseWriter

delete

protected AbstractDatabaseWriter.LoadStatus delete(CsvData data,
 boolean useConflictDetection)

Overrides:

delete in class DefaultDatabaseWriter

insert

protected AbstractDatabaseWriter.LoadStatus insert(CsvData data)

Overrides:

insert in class DefaultDatabaseWriter

update

protected AbstractDatabaseWriter.LoadStatus update(CsvData data,
 boolean applyChangesOnly,
 boolean useConflictDetection)

Overrides:

update in class DefaultDatabaseWriter

checkForConflict

protected void checkForConflict(boolean isDml)

prepare

protected void prepare()

Overrides:

prepare in class DefaultDatabaseWriter

execute

protected int execute(CsvData data,
 String[] values)

Overrides:

execute in class DefaultDatabaseWriter

end

public void end(Batch batch,
 boolean inError)

Specified by:

end in interface IDataWriter

Overrides:

end in class AbstractBulkDatabaseWriter

requireNewStatement

protected boolean requireNewStatement(DmlStatement.DmlType currentType,
 CsvData data,
 boolean applyChangesOnly,
 boolean useConflictDetection,
 Conflict.DetectConflict detectType)

Overrides:

requireNewStatement in class DefaultDatabaseWriter