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

Class DefaultDatabaseWriter

java.lang.Object

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

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

All Implemented Interfaces:

IDataResource, IDataWriter

Direct Known Subclasses:

DynamicDefaultDatabaseWriter

public class DefaultDatabaseWriter
extends AbstractDatabaseWriter

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
static final String	CUR_DATA
protected DmlStatement	currentDmlStatement
protected Object[]	currentDmlValues
protected boolean	hasUncommittedDdl
protected Boolean	isCteExpression
protected LogSqlBuilder	logSqlBuilder
protected IDatabasePlatform	platform
protected ISqlTransaction	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
DefaultDatabaseWriter(IDatabasePlatform platform)
DefaultDatabaseWriter(IDatabasePlatform platform, DatabaseWriterSettings settings)
DefaultDatabaseWriter(IDatabasePlatform platform, IDatabaseWriterConflictResolver conflictResolver, DatabaseWriterSettings settings)

Method Summary

Modifier and Type	Method	Description
protected void	allowInsertIntoAutoIncrementColumns(boolean value, Table table)
protected void	bindVariables(Map<String,Object> variables)
protected void	checkTargetTableHasColumns()
void	close()
protected void	commit(boolean earlyCommit)
protected void	commit(boolean earlyCommit, ISqlTransaction newTransaction)
protected boolean	containsNullLookupKeyDataSinceLastStatement(DmlStatement.DmlType currentType, CsvData data, Conflict.DetectConflict detectType)
protected boolean	create(CsvData data)
protected boolean	create(CsvData data, boolean withoutDefaults)
protected AbstractDatabaseWriter.LoadStatus	delete(CsvData data, boolean useConflictDetection)
protected String	dmlValuesToString(Object[] dmlValues, int[] types)
protected boolean	doesColumnNeedUpdated(int targetColumnIndex, Column column, CsvData data, String[] rowData, String[] oldData, boolean applyChangesOnly)
void	end(Table table)
void	end(Batch batch, boolean inError)
protected int	execute(CsvData data, String[] values)
protected String	getCurData(ISqlTransaction transaction)
DmlStatement	getCurrentDmlStatement()
IDatabasePlatform	getPlatform()
IDatabasePlatform	getPlatform(String table)
IDatabasePlatform	getPlatform(Table table)
protected List<String>	getSqlStatements(String script)
protected String	getTableKey(Table table)
IDatabasePlatform	getTargetPlatform()
ISqlTransaction	getTargetTransaction()
ISqlTransaction	getTransaction()
ISqlTransaction	getTransaction(String table)
ISqlTransaction	getTransaction(Table table)
DatabaseWriterSettings	getWriterSettings()
protected AbstractDatabaseWriter.LoadStatus	insert(CsvData data)
protected boolean	isCteExpression()
protected boolean	isDml(String sql)
protected void	logDataTruncation(CsvData data, StringBuilder failureMessage)
protected void	logFailureDetails(Throwable e, CsvData data, boolean logLastDmlDetails)
protected void	logFailureDetails(Throwable e, CsvData data, boolean logLastDmlDetails, Object[] values)
protected Table	lookupTableAtTarget(Table sourceTable)
protected Table	lookupTableFromCache(Table sourceTable, String tableKey)
void	open(DataContext context)
protected void	prepare()
protected void	prepare(String sql, CsvData data)
int	prepareAndExecute(String sql, CsvData data)
protected String	preprocessSqlStatement(String sql)
protected void	putTableInCache(String tableKey, Table table)
protected String	quoteString(String string)
protected void	removeGeneratedColumns(Table table)
protected void	replaceCteExpression()
protected String	replaceCteExpression(String sql)
protected boolean	requireNewStatement(DmlStatement.DmlType currentType, CsvData data, boolean applyChangesOnly, boolean useConflictDetection, Conflict.DetectConflict detectType)
protected void	rollback()
protected boolean	sql(CsvData data)
boolean	start(Table table)
protected void	targetTableWasChangedByFilter(Table oldTargetTable)
protected AbstractDatabaseWriter.LoadStatus	update(CsvData data, boolean applyChangesOnly, boolean useConflictDetection)
protected void	updateChangedDataIndicator(CsvData data, Column column, boolean needsUpdated)

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, start, write

Methods inherited from class java.lang.Object

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

Field Details

CUR_DATA

public static final String CUR_DATA

See Also:

• Constant Field Values

platform

protected IDatabasePlatform platform

transaction

protected ISqlTransaction transaction

currentDmlStatement

protected DmlStatement currentDmlStatement

currentDmlValues

protected Object[] currentDmlValues

logSqlBuilder

protected LogSqlBuilder logSqlBuilder

isCteExpression

protected Boolean isCteExpression

hasUncommittedDdl

protected boolean hasUncommittedDdl

Constructor Details

DefaultDatabaseWriter

public DefaultDatabaseWriter(IDatabasePlatform platform)

DefaultDatabaseWriter

public DefaultDatabaseWriter(IDatabasePlatform platform,
 DatabaseWriterSettings settings)

DefaultDatabaseWriter

public DefaultDatabaseWriter(IDatabasePlatform platform,
 IDatabaseWriterConflictResolver conflictResolver,
 DatabaseWriterSettings settings)

Method Details

getPlatform

public IDatabasePlatform getPlatform()

getPlatform

public IDatabasePlatform getPlatform(Table table)

getPlatform

public IDatabasePlatform getPlatform(String table)

getTargetPlatform

public IDatabasePlatform getTargetPlatform()

getTransaction

public ISqlTransaction getTransaction()

getTransaction

public ISqlTransaction getTransaction(Table table)

getTransaction

public ISqlTransaction getTransaction(String table)

getTargetTransaction

public ISqlTransaction getTargetTransaction()

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

Overrides:

open in class AbstractDatabaseWriter

start

public boolean start(Table table)

Specified by:

start in interface IDataWriter

Overrides:

start in class AbstractDatabaseWriter

end

public void end(Table table)

Specified by:

end in interface IDataWriter

Overrides:

end in class AbstractDatabaseWriter

end

public void end(Batch batch,
 boolean inError)

Specified by:

end in interface IDataWriter

Overrides:

end in class AbstractDatabaseWriter

close

public void close()

Specified by:

close in interface IDataResource

Overrides:

close in class AbstractDatabaseWriter

commit

protected void commit(boolean earlyCommit)

Overrides:

commit in class AbstractDatabaseWriter

commit

protected void commit(boolean earlyCommit,
 ISqlTransaction newTransaction)

rollback

protected void rollback()

Overrides:

rollback in class AbstractDatabaseWriter

isCteExpression

protected boolean isCteExpression()

replaceCteExpression

protected void replaceCteExpression()

replaceCteExpression

protected String replaceCteExpression(String sql)

isDml

protected boolean isDml(String sql)

insert

protected AbstractDatabaseWriter.LoadStatus insert(CsvData data)

Specified by:

insert in class AbstractDatabaseWriter

delete

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

Specified by:

delete in class AbstractDatabaseWriter

update

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

Specified by:

update in class AbstractDatabaseWriter

checkTargetTableHasColumns

protected void checkTargetTableHasColumns()

create

protected boolean create(CsvData data)

Specified by:

create in class AbstractDatabaseWriter

create

protected boolean create(CsvData data,
 boolean withoutDefaults)

sql

protected boolean sql(CsvData data)

Specified by:

sql in class AbstractDatabaseWriter

requireNewStatement

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

containsNullLookupKeyDataSinceLastStatement

protected boolean containsNullLookupKeyDataSinceLastStatement(DmlStatement.DmlType currentType,
 CsvData data,
 Conflict.DetectConflict detectType)

targetTableWasChangedByFilter

protected void targetTableWasChangedByFilter(Table oldTargetTable)

Overrides:

targetTableWasChangedByFilter in class AbstractDatabaseWriter

logFailureDetails

protected void logFailureDetails(Throwable e,
 CsvData data,
 boolean logLastDmlDetails)

Specified by:

logFailureDetails in class AbstractDatabaseWriter

logFailureDetails

protected void logFailureDetails(Throwable e,
 CsvData data,
 boolean logLastDmlDetails,
 Object[] values)

Specified by:

logFailureDetails in class AbstractDatabaseWriter

logDataTruncation

protected void logDataTruncation(CsvData data,
 StringBuilder failureMessage)

dmlValuesToString

protected String dmlValuesToString(Object[] dmlValues,
 int[] types)

bindVariables

protected void bindVariables(Map<String,Object> variables)

Overrides:

bindVariables in class AbstractDatabaseWriter

getSqlStatements

protected List<String> getSqlStatements(String script)

preprocessSqlStatement

protected String preprocessSqlStatement(String sql)

quoteString

protected String quoteString(String string)

doesColumnNeedUpdated

protected boolean doesColumnNeedUpdated(int targetColumnIndex,
 Column column,
 CsvData data,
 String[] rowData,
 String[] oldData,
 boolean applyChangesOnly)

updateChangedDataIndicator

protected void updateChangedDataIndicator(CsvData data,
 Column column,
 boolean needsUpdated)

prepare

protected void prepare()

prepare

protected void prepare(String sql,
 CsvData data)

execute

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

lookupTableAtTarget

protected Table lookupTableAtTarget(Table sourceTable)

Overrides:

lookupTableAtTarget in class AbstractDatabaseWriter

removeGeneratedColumns

protected void removeGeneratedColumns(Table table)

getTableKey

protected String getTableKey(Table table)

lookupTableFromCache

protected Table lookupTableFromCache(Table sourceTable,
 String tableKey)

putTableInCache

protected void putTableInCache(String tableKey,
 Table table)

getCurrentDmlStatement

public DmlStatement getCurrentDmlStatement()

getWriterSettings

public DatabaseWriterSettings getWriterSettings()

Overrides:

getWriterSettings in class AbstractDatabaseWriter

prepareAndExecute

public int prepareAndExecute(String sql,
 CsvData data)

getCurData

protected String getCurData(ISqlTransaction transaction)

allowInsertIntoAutoIncrementColumns

protected void allowInsertIntoAutoIncrementColumns(boolean value,
 Table table)

Overrides:

allowInsertIntoAutoIncrementColumns in class AbstractDatabaseWriter