Package org.jumpmind.symmetric.db

Class AbstractSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

Direct Known Subclasses:

AbstractEmbeddedSymmetricDialect, AseSymmetricDialect, Db2SymmetricDialect, DerbySymmetricDialect, FirebirdSymmetricDialect, GenericSymmetricDialect, HanaSymmetricDialect, HsqlDb2SymmetricDialect, InformixSymmetricDialect, IngresSymmetricDialect, InterbaseSymmetricDialect, MsSqlSymmetricDialect, MySqlSymmetricDialect, NuoDbSymmetricDialect, OracleSymmetricDialect, PostgreSqlSymmetricDialect, RaimaSymmetricDialect, RedshiftSymmetricDialect, SqlAnywhereSymmetricDialect, SqliteSymmetricDialect, VoltDbSymmetricDialect

public abstract class AbstractSymmetricDialect
extends Object
implements ISymmetricDialect

Field Summary

Fields

Modifier and Type	Field	Description
protected int	databaseMajorVersion
protected int	databaseMinorVersion
protected String	databaseName
protected String	databaseProductVersion
protected String	driverName
protected String	driverVersion
protected IExtensionService	extensionService
protected boolean	isSpatialTypesEnabled
protected final org.slf4j.Logger	log
static final int	MAX_SYMMETRIC_SUPPORTED_TRIGGER_SIZE
protected IParameterService	parameterService
protected IDatabasePlatform	platform
protected Set<String>	sqlKeywords
protected Map<String,String>	sqlReplacementTokens
protected boolean	supportsDdlTriggers
protected Boolean	supportsGetGeneratedKeys
protected boolean	supportsSubselectsInDelete
protected boolean	supportsSubselectsInUpdate
protected boolean	supportsTransactionViews
protected String	tablePrefixLowerCase
protected ISymmetricDialect	targetDialect
protected AbstractTriggerTemplate	triggerTemplate

Constructor Summary

Constructors

Constructor	Description
AbstractSymmetricDialect(IParameterService parameterService, IDatabasePlatform platform)

Method Summary

Modifier and Type	Method	Description
boolean	areDatabaseTransactionsPendingSince(long time)
protected void	buildSqlReplacementTokens()
boolean	canGapsOccurInCapturedDataIds()
void	cleanupTriggers()
protected void	close(ISqlTransaction transaction)
String	createCsvDataSql(Trigger trigger, TriggerHistory triggerHistory, Channel channel, String whereClause)
String	createCsvPrimaryKeySql(Trigger trigger, TriggerHistory triggerHistory, Channel channel, String whereClause)
void	createDdlTrigger(String tablePrefix, StringBuilder sqlBuffer, String triggerName, String runtimeCatalog, String runtimeSchema)
String	createInitialLoadSqlFor(Node node, TriggerRouter trigger, Table table, TriggerHistory triggerHistory, Channel channel, String overrideSelectSql)
boolean	createOrAlterTablesIfNecessary(String... tableNames)
protected String	createPostDdlTriggerDDL(String tablePrefix, String triggerName)
protected String	createPostTriggerDDL(DataEventType dml, Trigger trigger, TriggerHistory hist, Channel channel, String tablePrefix, Table table)
String	createPurgeSqlFor(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory)
String	createPurgeSqlFor(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory, List<TransformService.TransformTableNodeGroupLink> transforms)
String	createPurgeSqlFor(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory, List<TransformService.TransformTableNodeGroupLink> transforms, String deleteSql)
List<String>	createPurgeSqlForMultipleTables(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory, List<TransformService.TransformTableNodeGroupLink> transforms, String deleteSql)
void	createRequiredDatabaseObjects()
protected void	createRequiredDatabaseObjectsImpl(StringBuilder ddl)
void	createTrigger(StringBuilder sqlBuffer, DataEventType dml, Trigger trigger, TriggerHistory hist, Channel channel, String tablePrefix, Table table)
void	createTrigger(StringBuilder sqlBuffer, DataEventType dml, Trigger trigger, TriggerHistory hist, Channel channel, String tablePrefix, Table table, ISqlTransaction transaction)
void	disableSyncTriggers(ISqlTransaction transaction)	Deprecated.
boolean	doesDdlTriggerExist(String catalogName, String schema, String triggerName)
final boolean	doesTriggerExist(StringBuilder sqlBuffer, String catalogName, String schema, String tableName, String triggerName)
protected abstract boolean	doesTriggerExistOnPlatform(StringBuilder seqlBuffer, String catalogName, String schema, String tableName, String triggerName)
abstract void	dropRequiredDatabaseObjects()
void	dropTablesAndDatabaseObjects()
boolean	escapesTemplatesForDatabaseInserts()
abstract BinaryEncoding	getBinaryEncoding()
boolean[]	getColumnPositionUsingTemplate(Table originalTable, TriggerHistory triggerHistory)
String	getCreateRequiredDatabaseObjectsDDL()
String	getCreateSymmetricDDL()
long	getCurrentSequenceValue(SequenceIdentifier identifier)
long	getDatabaseTime()
String	getDatabaseTimeSQL()
final String	getDataHasChangedCondition(Trigger trigger)
protected String	getDbSpecificDataHasChangedCondition(Trigger trigger)
String	getDriverName()
String	getDriverVersion()
protected String	getDropTriggerSql(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName)
Date	getEarliestTransactionStartTime()
String	getEngineName()
String	getInitialLoadTableAlias()
String	getInitialLoadTwoPassLobLengthSql(Column column, boolean isFirstPass)
String	getInitialLoadTwoPassLobSql(String sql, Table table, boolean isFirstPass)
int	getMajorVersion()
String	getMasterCollation()
int	getMaxTriggerNameLength()
int	getMinorVersion()
String	getName()
IParameterService	getParameterService()
IDatabasePlatform	getPlatform()
String	getProductVersion()
String	getSequenceKeyName(SequenceIdentifier identifier)
String	getSequenceName(SequenceIdentifier identifier)
String	getSourceNodeExpression()
Set<String>	getSqlKeywords()
Map<String,String>	getSqlReplacementTokens()
int	getSqlTypeForIds()
String	getSymmetricDdlChanges()
PermissionType[]	getSymTablePermissions()
String	getSyncTriggersOnIncomingExpression()
String	getTablePrefix()
ISymmetricDialect	getTargetDialect()
ISymmetricDialect	getTargetDialect(String tableName)
IDatabasePlatform	getTargetPlatform()
IDatabasePlatform	getTargetPlatform(String tableName)
String	getTemplateNumberPrecisionSpec()
String	getTransactionId(ISqlTransaction transaction)
String	getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, Trigger trigger)
AbstractTriggerTemplate	getTriggerTemplate()
String	getVersion()
void	initTablesAndDatabaseObjects()
long	insertWithGeneratedKey(String sql, SequenceIdentifier sequenceId)
long	insertWithGeneratedKey(String sql, SequenceIdentifier identifier, Object... args)
protected void	install(String sql, String objectName, StringBuilder ddl)
protected boolean	installed(String sql, String objectName)
boolean	isBlobSyncSupported()
boolean	isClobSyncSupported()
boolean	isInitialLoadTwoPassLob(Table table)
boolean	isTransactionIdOverrideSupported()
protected final void	logSql(String sql, StringBuilder sqlBuffer)
String	massageDataExtractionSql(String sql, boolean isContainsBigLob)
String	massageForLob(String sql, boolean isContainsBigLob)
protected Database	merge(Database... databases)
boolean	needsToSelectLobData()
Column[]	orderColumns(String[] columnNames, Table table)	Deprecated.
protected void	postCreateDdlTrigger(ISqlTransaction transaction, String tablePrefix, StringBuilder sqlBuffer, String triggerName)
protected void	postCreateTrigger(ISqlTransaction transaction, StringBuilder sqlBuffer, DataEventType dml, Trigger trigger, TriggerHistory hist, Channel channel, String tablePrefix, Table table)
protected void	prefixConfigDatabase(Database targetTables)
String	preProcessTriggerSqlClause(String sqlClause)
protected Database	readDatabaseFromXml(String resourceName)
Database	readSymmetricSchemaFromDatabase()
Database	readSymmetricSchemaFromXml()
void	removeDdlTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName)
void	removeTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName)
void	removeTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName, ISqlTransaction transaction)
protected String	replaceTokens(String sql, String objectName)
boolean	requiresAutoCommitFalseToSetFetchSize()
void	setExtensionService(IExtensionService extensionService)
void	setTargetDialect(ISymmetricDialect targetDialect)
boolean	supportsBatchUpdates()
boolean	supportsDdlTriggers()
boolean	supportsOpenCursorsAcrossCommit()
boolean	supportsSubselectsInDelete()
boolean	supportsSubselectsInUpdate()
boolean	supportsTransactionId()
boolean	supportsTransactionViews()
protected String	switchCatalogForTriggerInstall(String catalog, ISqlTransaction transaction)
void	truncateTable(String tableName)
protected void	uninstall(String sql, String objectName)
protected void	uninstall(String sql, String objectName, StringBuilder ddl)
void	verifyDatabaseIsCompatible()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.db.ISymmetricDialect

cleanDatabase, disableSyncTriggers, enableSyncTriggers, getSyncTriggersExpression

Field Details

log

protected final org.slf4j.Logger log

MAX_SYMMETRIC_SUPPORTED_TRIGGER_SIZE

public static final int MAX_SYMMETRIC_SUPPORTED_TRIGGER_SIZE

See Also:

• Constant Field Values

platform

protected IDatabasePlatform platform

targetDialect

protected ISymmetricDialect targetDialect

triggerTemplate

protected AbstractTriggerTemplate triggerTemplate

parameterService

protected IParameterService parameterService

extensionService

protected IExtensionService extensionService

supportsGetGeneratedKeys

protected Boolean supportsGetGeneratedKeys

databaseName

protected String databaseName

driverVersion

protected String driverVersion

driverName

protected String driverName

databaseMajorVersion

protected int databaseMajorVersion

databaseMinorVersion

protected int databaseMinorVersion

databaseProductVersion

protected String databaseProductVersion

sqlKeywords

protected Set<String> sqlKeywords

supportsTransactionViews

protected boolean supportsTransactionViews

supportsSubselectsInDelete

protected boolean supportsSubselectsInDelete

supportsSubselectsInUpdate

protected boolean supportsSubselectsInUpdate

supportsDdlTriggers

protected boolean supportsDdlTriggers

sqlReplacementTokens

protected Map<String,String> sqlReplacementTokens

tablePrefixLowerCase

protected String tablePrefixLowerCase

isSpatialTypesEnabled

protected boolean isSpatialTypesEnabled

Constructor Details

AbstractSymmetricDialect

public AbstractSymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

getSymmetricDdlChanges

public String getSymmetricDdlChanges()

Specified by:

getSymmetricDdlChanges in interface ISymmetricDialect

requiresAutoCommitFalseToSetFetchSize

public boolean requiresAutoCommitFalseToSetFetchSize()

buildSqlReplacementTokens

protected void buildSqlReplacementTokens()

getSqlReplacementTokens

public Map<String,String> getSqlReplacementTokens()

Specified by:

getSqlReplacementTokens in interface ISymmetricDialect

getMaxTriggerNameLength

public int getMaxTriggerNameLength()

Specified by:

getMaxTriggerNameLength in interface ISymmetricDialect

verifyDatabaseIsCompatible

public void verifyDatabaseIsCompatible()

Specified by:

verifyDatabaseIsCompatible in interface ISymmetricDialect

initTablesAndDatabaseObjects

public void initTablesAndDatabaseObjects()

Specified by:

initTablesAndDatabaseObjects in interface ISymmetricDialect

replaceTokens

protected String replaceTokens(String sql,
 String objectName)

installed

protected boolean installed(String sql,
 String objectName)

install

protected void install(String sql,
 String objectName,
 StringBuilder ddl)

uninstall

protected void uninstall(String sql,
 String objectName)

uninstall

protected void uninstall(String sql,
 String objectName,
 StringBuilder ddl)

dropTablesAndDatabaseObjects

public void dropTablesAndDatabaseObjects()

Specified by:

dropTablesAndDatabaseObjects in interface ISymmetricDialect

doesTriggerExist

public final boolean doesTriggerExist(StringBuilder sqlBuffer,
 String catalogName,
 String schema,
 String tableName,
 String triggerName)

Specified by:

doesTriggerExist in interface ISymmetricDialect

doesDdlTriggerExist

public boolean doesDdlTriggerExist(String catalogName,
 String schema,
 String triggerName)

Specified by:

doesDdlTriggerExist in interface ISymmetricDialect

dropRequiredDatabaseObjects

public abstract void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

createRequiredDatabaseObjects

public void createRequiredDatabaseObjects()

Specified by:

createRequiredDatabaseObjects in interface ISymmetricDialect

getCreateRequiredDatabaseObjectsDDL

public String getCreateRequiredDatabaseObjectsDDL()

Specified by:

getCreateRequiredDatabaseObjectsDDL in interface ISymmetricDialect

createRequiredDatabaseObjectsImpl

protected void createRequiredDatabaseObjectsImpl(StringBuilder ddl)

getBinaryEncoding

public abstract BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

doesTriggerExistOnPlatform

protected abstract boolean doesTriggerExistOnPlatform(StringBuilder seqlBuffer,
 String catalogName,
 String schema,
 String tableName,
 String triggerName)

getTransactionTriggerExpression

public String getTransactionTriggerExpression(String defaultCatalog,
 String defaultSchema,
 Trigger trigger)

Specified by:

getTransactionTriggerExpression in interface ISymmetricDialect

getTransactionId

public String getTransactionId(ISqlTransaction transaction)

Specified by:

getTransactionId in interface ISymmetricDialect

createInitialLoadSqlFor

public String createInitialLoadSqlFor(Node node,
 TriggerRouter trigger,
 Table table,
 TriggerHistory triggerHistory,
 Channel channel,
 String overrideSelectSql)

Specified by:

createInitialLoadSqlFor in interface ISymmetricDialect

getColumnPositionUsingTemplate

public boolean[] getColumnPositionUsingTemplate(Table originalTable,
 TriggerHistory triggerHistory)

Specified by:

getColumnPositionUsingTemplate in interface ISymmetricDialect

createPurgeSqlFor

public String createPurgeSqlFor(Node node,
 TriggerRouter triggerRouter,
 TriggerHistory triggerHistory)

Specified by:

createPurgeSqlFor in interface ISymmetricDialect

createPurgeSqlFor

public String createPurgeSqlFor(Node node,
 TriggerRouter triggerRouter,
 TriggerHistory triggerHistory,
 List<TransformService.TransformTableNodeGroupLink> transforms)

Specified by:

createPurgeSqlFor in interface ISymmetricDialect

createPurgeSqlFor

public String createPurgeSqlFor(Node node,
 TriggerRouter triggerRouter,
 TriggerHistory triggerHistory,
 List<TransformService.TransformTableNodeGroupLink> transforms,
 String deleteSql)

Specified by:

createPurgeSqlFor in interface ISymmetricDialect

createPurgeSqlForMultipleTables

public List<String> createPurgeSqlForMultipleTables(Node node,
 TriggerRouter triggerRouter,
 TriggerHistory triggerHistory,
 List<TransformService.TransformTableNodeGroupLink> transforms,
 String deleteSql)

Specified by:

createPurgeSqlForMultipleTables in interface ISymmetricDialect

createCsvDataSql

public String createCsvDataSql(Trigger trigger,
 TriggerHistory triggerHistory,
 Channel channel,
 String whereClause)

Specified by:

createCsvDataSql in interface ISymmetricDialect

createCsvPrimaryKeySql

public String createCsvPrimaryKeySql(Trigger trigger,
 TriggerHistory triggerHistory,
 Channel channel,
 String whereClause)

Specified by:

createCsvPrimaryKeySql in interface ISymmetricDialect

getSqlKeywords

public Set<String> getSqlKeywords()

Specified by:

getSqlKeywords in interface ISymmetricDialect

getDropTriggerSql

protected String getDropTriggerSql(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName,
 String tableName)

removeTrigger

public void removeTrigger(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName,
 String tableName)

Specified by:

removeTrigger in interface ISymmetricDialect

removeTrigger

public void removeTrigger(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName,
 String tableName,
 ISqlTransaction transaction)

Specified by:

removeTrigger in interface ISymmetricDialect

removeDdlTrigger

public void removeDdlTrigger(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName)

Specified by:

removeDdlTrigger in interface ISymmetricDialect

logSql

protected final void logSql(String sql,
 StringBuilder sqlBuffer)

createTrigger

public void createTrigger(StringBuilder sqlBuffer,
 DataEventType dml,
 Trigger trigger,
 TriggerHistory hist,
 Channel channel,
 String tablePrefix,
 Table table)

Specified by:

createTrigger in interface ISymmetricDialect

createTrigger

public void createTrigger(StringBuilder sqlBuffer,
 DataEventType dml,
 Trigger trigger,
 TriggerHistory hist,
 Channel channel,
 String tablePrefix,
 Table table,
 ISqlTransaction transaction)

Specified by:

createTrigger in interface ISymmetricDialect

postCreateTrigger

protected void postCreateTrigger(ISqlTransaction transaction,
 StringBuilder sqlBuffer,
 DataEventType dml,
 Trigger trigger,
 TriggerHistory hist,
 Channel channel,
 String tablePrefix,
 Table table)

switchCatalogForTriggerInstall

protected String switchCatalogForTriggerInstall(String catalog,
 ISqlTransaction transaction)

createPostTriggerDDL

protected String createPostTriggerDDL(DataEventType dml,
 Trigger trigger,
 TriggerHistory hist,
 Channel channel,
 String tablePrefix,
 Table table)

createDdlTrigger

public void createDdlTrigger(String tablePrefix,
 StringBuilder sqlBuffer,
 String triggerName,
 String runtimeCatalog,
 String runtimeSchema)

Specified by:

createDdlTrigger in interface ISymmetricDialect

postCreateDdlTrigger

protected void postCreateDdlTrigger(ISqlTransaction transaction,
 String tablePrefix,
 StringBuilder sqlBuffer,
 String triggerName)

createPostDdlTriggerDDL

protected String createPostDdlTriggerDDL(String tablePrefix,
 String triggerName)

getCreateSymmetricDDL

public String getCreateSymmetricDDL()

Specified by:

getCreateSymmetricDDL in interface ISymmetricDialect

prefixConfigDatabase

protected void prefixConfigDatabase(Database targetTables)

createOrAlterTablesIfNecessary

public boolean createOrAlterTablesIfNecessary(String... tableNames)

Specified by:

createOrAlterTablesIfNecessary in interface ISymmetricDialect

readSymmetricSchemaFromXml

public Database readSymmetricSchemaFromXml()

Specified by:

readSymmetricSchemaFromXml in interface ISymmetricDialect

readSymmetricSchemaFromDatabase

public Database readSymmetricSchemaFromDatabase()

readDatabaseFromXml

protected Database readDatabaseFromXml(String resourceName)
                                throws IOException

Throws:

IOException

merge

protected Database merge(Database... databases)

getPlatform

public IDatabasePlatform getPlatform()

Specified by:

getPlatform in interface ISymmetricDialect

getTargetPlatform

public IDatabasePlatform getTargetPlatform()

Specified by:

getTargetPlatform in interface ISymmetricDialect

getTargetPlatform

public IDatabasePlatform getTargetPlatform(String tableName)

Specified by:

getTargetPlatform in interface ISymmetricDialect

getName

public String getName()

Specified by:

getName in interface ISymmetricDialect

getVersion

public String getVersion()

Specified by:

getVersion in interface ISymmetricDialect

getMajorVersion

public int getMajorVersion()

Specified by:

getMajorVersion in interface ISymmetricDialect

getMinorVersion

public int getMinorVersion()

Specified by:

getMinorVersion in interface ISymmetricDialect

getProductVersion

public String getProductVersion()

Specified by:

getProductVersion in interface ISymmetricDialect

supportsTransactionViews

public boolean supportsTransactionViews()

Specified by:

supportsTransactionViews in interface ISymmetricDialect

supportsSubselectsInDelete

public boolean supportsSubselectsInDelete()

Specified by:

supportsSubselectsInDelete in interface ISymmetricDialect

supportsSubselectsInUpdate

public boolean supportsSubselectsInUpdate()

Specified by:

supportsSubselectsInUpdate in interface ISymmetricDialect

supportsDdlTriggers

public boolean supportsDdlTriggers()

Specified by:

supportsDdlTriggers in interface ISymmetricDialect

insertWithGeneratedKey

public long insertWithGeneratedKey(String sql,
 SequenceIdentifier sequenceId)

Specified by:

insertWithGeneratedKey in interface ISymmetricDialect

insertWithGeneratedKey

public long insertWithGeneratedKey(String sql,
 SequenceIdentifier identifier,
 Object... args)

Specified by:

insertWithGeneratedKey in interface ISymmetricDialect

getSequenceName

public String getSequenceName(SequenceIdentifier identifier)

Specified by:

getSequenceName in interface ISymmetricDialect

getSequenceKeyName

public String getSequenceKeyName(SequenceIdentifier identifier)

Specified by:

getSequenceKeyName in interface ISymmetricDialect

getCurrentSequenceValue

public long getCurrentSequenceValue(SequenceIdentifier identifier)

Specified by:

getCurrentSequenceValue in interface ISymmetricDialect

orderColumns

@Deprecated
public Column[] orderColumns(String[] columnNames,
 Table table)

Deprecated.

Specified by:

orderColumns in interface ISymmetricDialect

disableSyncTriggers

@Deprecated
public void disableSyncTriggers(ISqlTransaction transaction)

Deprecated.

Specified by:

disableSyncTriggers in interface ISymmetricDialect

supportsTransactionId

public boolean supportsTransactionId()

Specified by:

supportsTransactionId in interface ISymmetricDialect

isBlobSyncSupported

public boolean isBlobSyncSupported()

Specified by:

isBlobSyncSupported in interface ISymmetricDialect

isClobSyncSupported

public boolean isClobSyncSupported()

Specified by:

isClobSyncSupported in interface ISymmetricDialect

isTransactionIdOverrideSupported

public boolean isTransactionIdOverrideSupported()

Specified by:

isTransactionIdOverrideSupported in interface ISymmetricDialect

getEngineName

public String getEngineName()

Specified by:

getEngineName in interface ISymmetricDialect

supportsOpenCursorsAcrossCommit

public boolean supportsOpenCursorsAcrossCommit()

Specified by:

supportsOpenCursorsAcrossCommit in interface ISymmetricDialect

getInitialLoadTableAlias

public String getInitialLoadTableAlias()

Specified by:

getInitialLoadTableAlias in interface ISymmetricDialect

preProcessTriggerSqlClause

public String preProcessTriggerSqlClause(String sqlClause)

Specified by:

preProcessTriggerSqlClause in interface ISymmetricDialect

truncateTable

public void truncateTable(String tableName)

Specified by:

truncateTable in interface ISymmetricDialect

areDatabaseTransactionsPendingSince

public boolean areDatabaseTransactionsPendingSince(long time)

Specified by:

areDatabaseTransactionsPendingSince in interface ISymmetricDialect

getEarliestTransactionStartTime

public Date getEarliestTransactionStartTime()

Specified by:

getEarliestTransactionStartTime in interface ISymmetricDialect

getDatabaseTimeSQL

public String getDatabaseTimeSQL()

Specified by:

getDatabaseTimeSQL in interface ISymmetricDialect

getDatabaseTime

public long getDatabaseTime()

Specified by:

getDatabaseTime in interface ISymmetricDialect

getSourceNodeExpression

public String getSourceNodeExpression()

Specified by:

getSourceNodeExpression in interface ISymmetricDialect

getDataHasChangedCondition

public final String getDataHasChangedCondition(Trigger trigger)

Specified by:

getDataHasChangedCondition in interface ISymmetricDialect

getDbSpecificDataHasChangedCondition

protected String getDbSpecificDataHasChangedCondition(Trigger trigger)

needsToSelectLobData

public boolean needsToSelectLobData()

Specified by:

needsToSelectLobData in interface ISymmetricDialect

canGapsOccurInCapturedDataIds

public boolean canGapsOccurInCapturedDataIds()

Specified by:

canGapsOccurInCapturedDataIds in interface ISymmetricDialect

massageDataExtractionSql

public String massageDataExtractionSql(String sql,
 boolean isContainsBigLob)

Specified by:

massageDataExtractionSql in interface ISymmetricDialect

getDriverName

public String getDriverName()

Specified by:

getDriverName in interface ISymmetricDialect

getDriverVersion

public String getDriverVersion()

Specified by:

getDriverVersion in interface ISymmetricDialect

massageForLob

public String massageForLob(String sql,
 boolean isContainsBigLob)

Specified by:

massageForLob in interface ISymmetricDialect

isInitialLoadTwoPassLob

public boolean isInitialLoadTwoPassLob(Table table)

Specified by:

isInitialLoadTwoPassLob in interface ISymmetricDialect

getInitialLoadTwoPassLobSql

public String getInitialLoadTwoPassLobSql(String sql,
 Table table,
 boolean isFirstPass)

Specified by:

getInitialLoadTwoPassLobSql in interface ISymmetricDialect

getInitialLoadTwoPassLobLengthSql

public String getInitialLoadTwoPassLobLengthSql(Column column,
 boolean isFirstPass)

escapesTemplatesForDatabaseInserts

public boolean escapesTemplatesForDatabaseInserts()

Specified by:

escapesTemplatesForDatabaseInserts in interface ISymmetricDialect

getMasterCollation

public String getMasterCollation()

Specified by:

getMasterCollation in interface ISymmetricDialect

supportsBatchUpdates

public boolean supportsBatchUpdates()

Specified by:

supportsBatchUpdates in interface ISymmetricDialect

cleanupTriggers

public void cleanupTriggers()

Specified by:

cleanupTriggers in interface ISymmetricDialect

getTriggerTemplate

public AbstractTriggerTemplate getTriggerTemplate()

Specified by:

getTriggerTemplate in interface ISymmetricDialect

close

protected void close(ISqlTransaction transaction)

getTablePrefix

public String getTablePrefix()

Specified by:

getTablePrefix in interface ISymmetricDialect

getTemplateNumberPrecisionSpec

public String getTemplateNumberPrecisionSpec()

Specified by:

getTemplateNumberPrecisionSpec in interface ISymmetricDialect

getSqlTypeForIds

public int getSqlTypeForIds()

Specified by:

getSqlTypeForIds in interface ISymmetricDialect

getParameterService

public IParameterService getParameterService()

Specified by:

getParameterService in interface ISymmetricDialect

setExtensionService

public void setExtensionService(IExtensionService extensionService)

Specified by:

setExtensionService in interface ISymmetricDialect

getSymTablePermissions

public PermissionType[] getSymTablePermissions()

Specified by:

getSymTablePermissions in interface ISymmetricDialect

getTargetDialect

public ISymmetricDialect getTargetDialect()

Specified by:

getTargetDialect in interface ISymmetricDialect

getTargetDialect

public ISymmetricDialect getTargetDialect(String tableName)

Specified by:

getTargetDialect in interface ISymmetricDialect

setTargetDialect

public void setTargetDialect(ISymmetricDialect targetDialect)

Specified by:

setTargetDialect in interface ISymmetricDialect

getSyncTriggersOnIncomingExpression

public String getSyncTriggersOnIncomingExpression()

Specified by:

getSyncTriggersOnIncomingExpression in interface ISymmetricDialect