Package org.jumpmind.symmetric.io.data.writer

Class DynamicDefaultDatabaseWriter

java.lang.Object

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

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

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

All Implemented Interfaces:

IDataResource, IDataWriter

Direct Known Subclasses:

AbstractBulkDatabaseWriter, CassandraDatabaseWriter, KafkaWriter

public class DynamicDefaultDatabaseWriter
extends DefaultDatabaseWriter

Nested Class Summary

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

AbstractDatabaseWriter.LoadStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected String	tablePrefix
protected IDatabasePlatform	targetPlatform
protected ISqlTransaction	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
DynamicDefaultDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String prefix)
DynamicDefaultDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String prefix, DatabaseWriterSettings settings)
DynamicDefaultDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String prefix, IDatabaseWriterConflictResolver conflictResolver, DatabaseWriterSettings settings)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	commit(boolean earlyCommit)
IDatabasePlatform	getPlatform()
IDatabasePlatform	getPlatform(String table)
IDatabasePlatform	getPlatform(Table table)
String	getTablePrefix()
IDatabasePlatform	getTargetPlatform()
ISqlTransaction	getTargetTransaction()
ISqlTransaction	getTransaction()
ISqlTransaction	getTransaction(String table)
ISqlTransaction	getTransaction(Table table)
boolean	isLoadOnly()
protected boolean	isSymmetricTable(String tableName)
protected boolean	isSymmetricTable(Table table)
void	open(DataContext context)
protected void	rollback()

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

allowInsertIntoAutoIncrementColumns, bindVariables, commit, containsNullLookupKeyDataSinceLastStatement, create, create, delete, dmlValuesToString, doesColumnNeedUpdated, end, 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, start, write

Methods inherited from class java.lang.Object

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

Field Details

targetPlatform

protected IDatabasePlatform targetPlatform

targetTransaction

protected ISqlTransaction targetTransaction

tablePrefix

protected String tablePrefix

Constructor Details

DynamicDefaultDatabaseWriter

public DynamicDefaultDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String prefix)

DynamicDefaultDatabaseWriter

public DynamicDefaultDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String prefix,
 DatabaseWriterSettings settings)

DynamicDefaultDatabaseWriter

public DynamicDefaultDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String prefix,
 IDatabaseWriterConflictResolver conflictResolver,
 DatabaseWriterSettings settings)

Method Details

isSymmetricTable

protected boolean isSymmetricTable(Table table)

isSymmetricTable

protected boolean isSymmetricTable(String tableName)

isLoadOnly

public boolean isLoadOnly()

getPlatform

public IDatabasePlatform getPlatform(Table table)

Overrides:

getPlatform in class DefaultDatabaseWriter

getPlatform

public IDatabasePlatform getPlatform(String table)

Overrides:

getPlatform in class DefaultDatabaseWriter

getPlatform

public IDatabasePlatform getPlatform()

Overrides:

getPlatform in class DefaultDatabaseWriter

getTargetPlatform

public IDatabasePlatform getTargetPlatform()

Overrides:

getTargetPlatform in class DefaultDatabaseWriter

getTransaction

public ISqlTransaction getTransaction()

Overrides:

getTransaction in class DefaultDatabaseWriter

getTransaction

public ISqlTransaction getTransaction(Table table)

Overrides:

getTransaction in class DefaultDatabaseWriter

getTransaction

public ISqlTransaction getTransaction(String table)

Overrides:

getTransaction in class DefaultDatabaseWriter

getTargetTransaction

public ISqlTransaction getTargetTransaction()

Overrides:

getTargetTransaction in class DefaultDatabaseWriter

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

Overrides:

open in class DefaultDatabaseWriter

close

public void close()

Specified by:

close in interface IDataResource

Overrides:

close in class DefaultDatabaseWriter

commit

protected void commit(boolean earlyCommit)

Overrides:

commit in class DefaultDatabaseWriter

rollback

protected void rollback()

Overrides:

rollback in class DefaultDatabaseWriter

getTablePrefix

public String getTablePrefix()