org.jumpmind.symmetric.db

Class AbstractSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

Direct Known Subclasses:

SqliteSymmetricDialect

public abstract class AbstractSymmetricDialect
extends java.lang.Object
implements ISymmetricDialect

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractSymmetricDialect()
AbstractSymmetricDialect(IParameterService parameterService, org.jumpmind.db.platform.IDatabasePlatform platform)

Method Summary

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

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 org.jumpmind.db.platform.IDatabasePlatform platform

targetDialect

protected ISymmetricDialect targetDialect

triggerTemplate

protected AbstractTriggerTemplate triggerTemplate

parameterService

protected IParameterService parameterService

extensionService

protected IExtensionService extensionService

supportsGetGeneratedKeys

protected java.lang.Boolean supportsGetGeneratedKeys

databaseName

protected java.lang.String databaseName

driverVersion

protected java.lang.String driverVersion

driverName

protected java.lang.String driverName

databaseMajorVersion

protected int databaseMajorVersion

databaseMinorVersion

protected int databaseMinorVersion

databaseProductVersion

protected java.lang.String databaseProductVersion

sqlKeywords

protected java.util.Set<java.lang.String> sqlKeywords

supportsTransactionViews

protected boolean supportsTransactionViews

supportsSubselectsInDelete

protected boolean supportsSubselectsInDelete

supportsSubselectsInUpdate

protected boolean supportsSubselectsInUpdate

sqlReplacementTokens

protected java.util.Map<java.lang.String,java.lang.String> sqlReplacementTokens

Constructor Detail

AbstractSymmetricDialect

public AbstractSymmetricDialect()

AbstractSymmetricDialect

public AbstractSymmetricDialect(IParameterService parameterService,
                                org.jumpmind.db.platform.IDatabasePlatform platform)

Method Detail

requiresAutoCommitFalseToSetFetchSize

public boolean requiresAutoCommitFalseToSetFetchSize()

buildSqlReplacementTokens

protected void buildSqlReplacementTokens()

getSqlReplacementTokens

public java.util.Map<java.lang.String,java.lang.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 java.lang.String replaceTokens(java.lang.String sql,
                                         java.lang.String objectName)

installed

protected boolean installed(java.lang.String sql,
                            java.lang.String objectName)

install

protected void install(java.lang.String sql,
                       java.lang.String objectName)

uninstall

protected void uninstall(java.lang.String sql,
                         java.lang.String objectName)

dropTablesAndDatabaseObjects

public void dropTablesAndDatabaseObjects()

Specified by:

dropTablesAndDatabaseObjects in interface ISymmetricDialect

doesTriggerExist

public final boolean doesTriggerExist(java.lang.String catalogName,
                                      java.lang.String schema,
                                      java.lang.String tableName,
                                      java.lang.String triggerName)

Specified by:

doesTriggerExist in interface ISymmetricDialect

doesDdlTriggerExist

public boolean doesDdlTriggerExist(java.lang.String catalogName,
                                   java.lang.String schema,
                                   java.lang.String triggerName)

Specified by:

doesDdlTriggerExist in interface ISymmetricDialect

dropRequiredDatabaseObjects

public abstract void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

createRequiredDatabaseObjects

public abstract void createRequiredDatabaseObjects()

Specified by:

createRequiredDatabaseObjects in interface ISymmetricDialect

getBinaryEncoding

public abstract org.jumpmind.db.util.BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

doesTriggerExistOnPlatform

protected abstract boolean doesTriggerExistOnPlatform(java.lang.String catalogName,
                                                      java.lang.String schema,
                                                      java.lang.String tableName,
                                                      java.lang.String triggerName)

getTransactionTriggerExpression

public java.lang.String getTransactionTriggerExpression(java.lang.String defaultCatalog,
                                                        java.lang.String defaultSchema,
                                                        Trigger trigger)

Specified by:

getTransactionTriggerExpression in interface ISymmetricDialect

createInitialLoadSqlFor

public java.lang.String createInitialLoadSqlFor(Node node,
                                                TriggerRouter trigger,
                                                org.jumpmind.db.model.Table table,
                                                TriggerHistory triggerHistory,
                                                Channel channel,
                                                java.lang.String overrideSelectSql)

Specified by:

createInitialLoadSqlFor in interface ISymmetricDialect

getColumnPositionUsingTemplate

public boolean[] getColumnPositionUsingTemplate(org.jumpmind.db.model.Table originalTable,
                                                TriggerHistory triggerHistory)

Specified by:

getColumnPositionUsingTemplate in interface ISymmetricDialect

createPurgeSqlFor

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

Specified by:

createPurgeSqlFor in interface ISymmetricDialect

createPurgeSqlFor

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

Specified by:

createPurgeSqlFor in interface ISymmetricDialect

createPurgeSqlFor

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

Specified by:

createPurgeSqlFor in interface ISymmetricDialect

createPurgeSqlForMultipleTables

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

Specified by:

createPurgeSqlForMultipleTables in interface ISymmetricDialect

createCsvDataSql

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

Specified by:

createCsvDataSql in interface ISymmetricDialect

createCsvPrimaryKeySql

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

Specified by:

createCsvPrimaryKeySql in interface ISymmetricDialect

getSqlKeywords

public java.util.Set<java.lang.String> getSqlKeywords()

Specified by:

getSqlKeywords in interface ISymmetricDialect

getDropTriggerSql

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

removeTrigger

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

Specified by:

removeTrigger in interface ISymmetricDialect

removeTrigger

public void removeTrigger(java.lang.StringBuilder sqlBuffer,
                          java.lang.String catalogName,
                          java.lang.String schemaName,
                          java.lang.String triggerName,
                          java.lang.String tableName,
                          org.jumpmind.db.sql.ISqlTransaction transaction)

Specified by:

removeTrigger in interface ISymmetricDialect

removeDdlTrigger

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

Specified by:

removeDdlTrigger in interface ISymmetricDialect

logSql

protected final void logSql(java.lang.String sql,
                            java.lang.StringBuilder sqlBuffer)

createTrigger

public void createTrigger(java.lang.StringBuilder sqlBuffer,
                          org.jumpmind.symmetric.io.data.DataEventType dml,
                          Trigger trigger,
                          TriggerHistory hist,
                          Channel channel,
                          java.lang.String tablePrefix,
                          org.jumpmind.db.model.Table table)

Specified by:

createTrigger in interface ISymmetricDialect

createTrigger

public void createTrigger(java.lang.StringBuilder sqlBuffer,
                          org.jumpmind.symmetric.io.data.DataEventType dml,
                          Trigger trigger,
                          TriggerHistory hist,
                          Channel channel,
                          java.lang.String tablePrefix,
                          org.jumpmind.db.model.Table table,
                          org.jumpmind.db.sql.ISqlTransaction transaction)

Specified by:

createTrigger in interface ISymmetricDialect

postCreateTrigger

protected void postCreateTrigger(org.jumpmind.db.sql.ISqlTransaction transaction,
                                 java.lang.StringBuilder sqlBuffer,
                                 org.jumpmind.symmetric.io.data.DataEventType dml,
                                 Trigger trigger,
                                 TriggerHistory hist,
                                 Channel channel,
                                 java.lang.String tablePrefix,
                                 org.jumpmind.db.model.Table table)

switchCatalogForTriggerInstall

protected java.lang.String switchCatalogForTriggerInstall(java.lang.String catalog,
                                                          org.jumpmind.db.sql.ISqlTransaction transaction)

createPostTriggerDDL

protected java.lang.String createPostTriggerDDL(org.jumpmind.symmetric.io.data.DataEventType dml,
                                                Trigger trigger,
                                                TriggerHistory hist,
                                                Channel channel,
                                                java.lang.String tablePrefix,
                                                org.jumpmind.db.model.Table table)

createDdlTrigger

public void createDdlTrigger(java.lang.String tablePrefix,
                             java.lang.StringBuilder sqlBuffer,
                             java.lang.String triggerName)

Specified by:

createDdlTrigger in interface ISymmetricDialect

getCreateSymmetricDDL

public java.lang.String getCreateSymmetricDDL()

Specified by:

getCreateSymmetricDDL in interface ISymmetricDialect

prefixConfigDatabase

protected void prefixConfigDatabase(org.jumpmind.db.model.Database targetTables)

getTable

public org.jumpmind.db.model.Table getTable(TriggerHistory triggerHistory,
                                            boolean useCache)

Specified by:

getTable in interface ISymmetricDialect

createOrAlterTablesIfNecessary

public boolean createOrAlterTablesIfNecessary(java.lang.String... tableNames)

Specified by:

createOrAlterTablesIfNecessary in interface ISymmetricDialect

readSymmetricSchemaFromXml

public org.jumpmind.db.model.Database readSymmetricSchemaFromXml()

Specified by:

readSymmetricSchemaFromXml in interface ISymmetricDialect

readSymmetricSchemaFromDatabase

public org.jumpmind.db.model.Database readSymmetricSchemaFromDatabase()

readDatabaseFromXml

protected org.jumpmind.db.model.Database readDatabaseFromXml(java.lang.String resourceName)
                                                      throws java.io.IOException

Throws:

java.io.IOException

merge

protected org.jumpmind.db.model.Database merge(org.jumpmind.db.model.Database... databases)

getPlatform

public org.jumpmind.db.platform.IDatabasePlatform getPlatform()

Specified by:

getPlatform in interface ISymmetricDialect

getTargetPlatform

public org.jumpmind.db.platform.IDatabasePlatform getTargetPlatform()

Specified by:

getTargetPlatform in interface ISymmetricDialect

getName

public java.lang.String getName()

Specified by:

getName in interface ISymmetricDialect

getVersion

public java.lang.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 java.lang.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

insertWithGeneratedKey

public long insertWithGeneratedKey(java.lang.String sql,
                                   SequenceIdentifier sequenceId)

Specified by:

insertWithGeneratedKey in interface ISymmetricDialect

insertWithGeneratedKey

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

Specified by:

insertWithGeneratedKey in interface ISymmetricDialect

getSequenceName

public java.lang.String getSequenceName(SequenceIdentifier identifier)

Specified by:

getSequenceName in interface ISymmetricDialect

getSequenceKeyName

public java.lang.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 org.jumpmind.db.model.Column[] orderColumns(java.lang.String[] columnNames,
                                                               org.jumpmind.db.model.Table table)

Deprecated.

Specified by:

orderColumns in interface ISymmetricDialect

disableSyncTriggers

@Deprecated
public void disableSyncTriggers(org.jumpmind.db.sql.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 java.lang.String getEngineName()

Specified by:

getEngineName in interface ISymmetricDialect

supportsOpenCursorsAcrossCommit

public boolean supportsOpenCursorsAcrossCommit()

Specified by:

supportsOpenCursorsAcrossCommit in interface ISymmetricDialect

getInitialLoadTableAlias

public java.lang.String getInitialLoadTableAlias()

Specified by:

getInitialLoadTableAlias in interface ISymmetricDialect

preProcessTriggerSqlClause

public java.lang.String preProcessTriggerSqlClause(java.lang.String sqlClause)

Specified by:

preProcessTriggerSqlClause in interface ISymmetricDialect

truncateTable

public void truncateTable(java.lang.String tableName)

Specified by:

truncateTable in interface ISymmetricDialect

areDatabaseTransactionsPendingSince

public boolean areDatabaseTransactionsPendingSince(long time)

Specified by:

areDatabaseTransactionsPendingSince in interface ISymmetricDialect

getEarliestTransactionStartTime

public java.util.Date getEarliestTransactionStartTime()

Specified by:

getEarliestTransactionStartTime in interface ISymmetricDialect

getDatabaseTime

public long getDatabaseTime()

Specified by:

getDatabaseTime in interface ISymmetricDialect

getSourceNodeExpression

public java.lang.String getSourceNodeExpression()

Specified by:

getSourceNodeExpression in interface ISymmetricDialect

getDataHasChangedCondition

public final java.lang.String getDataHasChangedCondition(Trigger trigger)

Specified by:

getDataHasChangedCondition in interface ISymmetricDialect

getDbSpecificDataHasChangedCondition

protected java.lang.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 java.lang.String massageDataExtractionSql(java.lang.String sql,
                                                 boolean isContainsBigLob)

Specified by:

massageDataExtractionSql in interface ISymmetricDialect

getDriverName

public java.lang.String getDriverName()

Specified by:

getDriverName in interface ISymmetricDialect

getDriverVersion

public java.lang.String getDriverVersion()

Specified by:

getDriverVersion in interface ISymmetricDialect

massageForLob

public java.lang.String massageForLob(java.lang.String sql,
                                      boolean isContainsBigLob)

Specified by:

massageForLob in interface ISymmetricDialect

isInitialLoadTwoPassLob

public boolean isInitialLoadTwoPassLob(org.jumpmind.db.model.Table table)

Specified by:

isInitialLoadTwoPassLob in interface ISymmetricDialect

getInitialLoadTwoPassLobSql

public java.lang.String getInitialLoadTwoPassLobSql(java.lang.String sql,
                                                    org.jumpmind.db.model.Table table,
                                                    boolean isFirstPass)

Specified by:

getInitialLoadTwoPassLobSql in interface ISymmetricDialect

getInitialLoadTwoPassLobLengthSql

public java.lang.String getInitialLoadTwoPassLobLengthSql(org.jumpmind.db.model.Column column,
                                                          boolean isFirstPass)

escapesTemplatesForDatabaseInserts

public boolean escapesTemplatesForDatabaseInserts()

Specified by:

escapesTemplatesForDatabaseInserts in interface ISymmetricDialect

getMasterCollation

public java.lang.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(org.jumpmind.db.sql.ISqlTransaction transaction)

getTablePrefix

public java.lang.String getTablePrefix()

Specified by:

getTablePrefix in interface ISymmetricDialect

getTemplateNumberPrecisionSpec

public java.lang.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 org.jumpmind.db.platform.PermissionType[] getSymTablePermissions()

Specified by:

getSymTablePermissions in interface ISymmetricDialect

getTargetDialect

public ISymmetricDialect getTargetDialect()

Specified by:

getTargetDialect in interface ISymmetricDialect

setTargetDialect

public void setTargetDialect(ISymmetricDialect targetDialect)

Specified by:

setTargetDialect in interface ISymmetricDialect