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

Class DefaultDatabaseWriterConflictResolver

java.lang.Object

org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriterConflictResolver

org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriterConflictResolver

All Implemented Interfaces:

IExtensionPoint, IDatabaseWriterConflictResolver

Direct Known Subclasses:

DefaultTransformWriterConflictResolver

public class DefaultDatabaseWriterConflictResolver
extends AbstractDatabaseWriterConflictResolver

Constructor Summary

Constructors

Constructor	Description
DefaultDatabaseWriterConflictResolver()

Method Summary

Modifier and Type	Method	Description
protected Object[]	addKeyArgs(Object[] currentArgs, Object[] additionalArgs)
protected void	captureMissingDelete(Conflict conflict, AbstractDatabaseWriter writer, CsvData data)
protected boolean	checkForForeignKeyChildExistsViolation(AbstractDatabaseWriter writer, CsvData data, Conflict conflict, Throwable e)
protected boolean	checkForUniqueKeyViolation(AbstractDatabaseWriter writer, CsvData data, Conflict conflict, Throwable e, boolean isFallback)
protected boolean	checkIfMismatchedPrimaryKey(AbstractDatabaseWriter writer)
protected boolean	deleteForeignKeyChildren(IDatabasePlatform platform, ISqlTemplate sqlTemplate, DefaultDatabaseWriter databaseWriter, Table targetTable, CsvData data, Row row)
protected int	deleteRow(IDatabasePlatform platform, ISqlTemplate sqlTemplate, DefaultDatabaseWriter databaseWriter, Table targetTable, List<Column> whereColumns, List<String> whereValues, boolean isUniqueKey)
protected int	deleteUniqueConstraintRow(IDatabasePlatform platform, ISqlTemplate sqlTemplate, DefaultDatabaseWriter databaseWriter, Table targetTable, IIndex uniqueIndex, CsvData data)
protected String	getConflictRowKey(Table table, Map<String,String> values)
protected Map<String,String>	getLookupDataMap(CsvData data, Table table)
protected boolean	isCaptureTimeNewer(Conflict conflict, AbstractDatabaseWriter writer, CsvData data, String tableName)
protected boolean	isCaptureTimeNewerForUk(AbstractDatabaseWriter writer, CsvData data)
protected boolean	isConflictingLosingParentRow(AbstractDatabaseWriter writer, CsvData data)
protected boolean	isTimestampNewer(Conflict conflict, AbstractDatabaseWriter writer, CsvData data)
protected boolean	isVersionNewer(Conflict conflict, AbstractDatabaseWriter writer, CsvData data)
protected void	modifyTimestampsForPrecision(IDatabasePlatform platform, Table table, String[] pkData)
protected int	prepareAndExecute(IDatabasePlatform platform, DefaultDatabaseWriter databaseWriter, String sql, Object... values)
protected boolean	primaryKeyUpdateAllowed(DynamicDefaultDatabaseWriter databaseWriter, Table targetTable)
protected int	queryForInt(IDatabasePlatform platform, DefaultDatabaseWriter databaseWriter, String sql, Object[] values, int[] types)
protected Row	queryForRow(IDatabasePlatform platform, DefaultDatabaseWriter databaseWriter, String sql, Object... values)
protected boolean	uniqueKeyUpdateAllowed(DynamicDefaultDatabaseWriter databaseWriter, Table targetTable, Column[] uniqueColumns)
protected String	updateCteExpression(String sql, String nodeId)

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

afterResolutionAttempt, attemptToResolve, beforeResolutionAttempt, checkIfTransactionAborted, ignore, ignoreRow, isIgnoreRow, logConflictHappened, logConflictResolution, needsResolved, performChainedFallbackForDelete, performChainedFallbackForInsert, performChainedFallbackForUpdate, performChainedFallbackForUpdateNoException, performChainedFallbackForUpdateWithException, performFallbackToInsert, performFallbackToUpdate

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDatabaseWriterConflictResolver

public DefaultDatabaseWriterConflictResolver()

Method Details

isTimestampNewer

protected boolean isTimestampNewer(Conflict conflict,
 AbstractDatabaseWriter writer,
 CsvData data)

Specified by:

isTimestampNewer in class AbstractDatabaseWriterConflictResolver

isCaptureTimeNewer

protected boolean isCaptureTimeNewer(Conflict conflict,
 AbstractDatabaseWriter writer,
 CsvData data,
 String tableName)

Specified by:

isCaptureTimeNewer in class AbstractDatabaseWriterConflictResolver

modifyTimestampsForPrecision

protected void modifyTimestampsForPrecision(IDatabasePlatform platform,
 Table table,
 String[] pkData)

primaryKeyUpdateAllowed

protected boolean primaryKeyUpdateAllowed(DynamicDefaultDatabaseWriter databaseWriter,
 Table targetTable)

uniqueKeyUpdateAllowed

protected boolean uniqueKeyUpdateAllowed(DynamicDefaultDatabaseWriter databaseWriter,
 Table targetTable,
 Column[] uniqueColumns)

getLookupDataMap

protected Map<String,String> getLookupDataMap(CsvData data,
 Table table)

isCaptureTimeNewerForUk

protected boolean isCaptureTimeNewerForUk(AbstractDatabaseWriter writer,
 CsvData data)

addKeyArgs

protected Object[] addKeyArgs(Object[] currentArgs,
 Object[] additionalArgs)

isVersionNewer

protected boolean isVersionNewer(Conflict conflict,
 AbstractDatabaseWriter writer,
 CsvData data)

Specified by:

isVersionNewer in class AbstractDatabaseWriterConflictResolver

checkForUniqueKeyViolation

protected boolean checkForUniqueKeyViolation(AbstractDatabaseWriter writer,
 CsvData data,
 Conflict conflict,
 Throwable e,
 boolean isFallback)

Specified by:

checkForUniqueKeyViolation in class AbstractDatabaseWriterConflictResolver

isConflictingLosingParentRow

protected boolean isConflictingLosingParentRow(AbstractDatabaseWriter writer,
 CsvData data)

Specified by:

isConflictingLosingParentRow in class AbstractDatabaseWriterConflictResolver

checkIfMismatchedPrimaryKey

protected boolean checkIfMismatchedPrimaryKey(AbstractDatabaseWriter writer)

Specified by:

checkIfMismatchedPrimaryKey in class AbstractDatabaseWriterConflictResolver

getConflictRowKey

protected String getConflictRowKey(Table table,
 Map<String,String> values)

deleteUniqueConstraintRow

protected int deleteUniqueConstraintRow(IDatabasePlatform platform,
 ISqlTemplate sqlTemplate,
 DefaultDatabaseWriter databaseWriter,
 Table targetTable,
 IIndex uniqueIndex,
 CsvData data)

deleteRow

protected int deleteRow(IDatabasePlatform platform,
 ISqlTemplate sqlTemplate,
 DefaultDatabaseWriter databaseWriter,
 Table targetTable,
 List<Column> whereColumns,
 List<String> whereValues,
 boolean isUniqueKey)

checkForForeignKeyChildExistsViolation

protected boolean checkForForeignKeyChildExistsViolation(AbstractDatabaseWriter writer,
 CsvData data,
 Conflict conflict,
 Throwable e)

Specified by:

checkForForeignKeyChildExistsViolation in class AbstractDatabaseWriterConflictResolver

deleteForeignKeyChildren

protected boolean deleteForeignKeyChildren(IDatabasePlatform platform,
 ISqlTemplate sqlTemplate,
 DefaultDatabaseWriter databaseWriter,
 Table targetTable,
 CsvData data,
 Row row)

captureMissingDelete

protected void captureMissingDelete(Conflict conflict,
 AbstractDatabaseWriter writer,
 CsvData data)

Specified by:

captureMissingDelete in class AbstractDatabaseWriterConflictResolver

updateCteExpression

protected String updateCteExpression(String sql,
 String nodeId)

prepareAndExecute

protected int prepareAndExecute(IDatabasePlatform platform,
 DefaultDatabaseWriter databaseWriter,
 String sql,
 Object... values)

queryForRow

protected Row queryForRow(IDatabasePlatform platform,
 DefaultDatabaseWriter databaseWriter,
 String sql,
 Object... values)

queryForInt

protected int queryForInt(IDatabasePlatform platform,
 DefaultDatabaseWriter databaseWriter,
 String sql,
 Object[] values,
 int[] types)