org.jumpmind.symmetric.db

Interface ISymmetricDialect

All Known Implementing Classes:

AbstractSymmetricDialect, SqliteSymmetricDialect

public interface ISymmetricDialect

Method Summary

Modifier and Type	Method and Description
boolean	areDatabaseTransactionsPendingSince(long time)
boolean	canGapsOccurInCapturedDataIds()
void	cleanDatabase()
void	cleanupTriggers()
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... tables)
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)
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.
void	disableSyncTriggers(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String nodeId)
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)
void	dropRequiredDatabaseObjects()
void	dropTablesAndDatabaseObjects()
void	enableSyncTriggers(org.jumpmind.db.sql.ISqlTransaction transaction)
boolean	escapesTemplatesForDatabaseInserts()
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)
java.lang.String	getDriverName()
java.lang.String	getDriverVersion()
java.util.Date	getEarliestTransactionStartTime()
java.lang.String	getEngineName()
java.lang.String	getInitialLoadTableAlias()
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()
java.lang.String	getSyncTriggersExpression()
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)
boolean	isBlobSyncSupported()
boolean	isClobSyncSupported()
boolean	isInitialLoadTwoPassLob(org.jumpmind.db.model.Table table)
boolean	isTransactionIdOverrideSupported()
java.lang.String	massageDataExtractionSql(java.lang.String sql, boolean isContainsBigLob)
java.lang.String	massageForLob(java.lang.String sql, boolean isContainsBigLob)
boolean	needsToSelectLobData()
org.jumpmind.db.model.Column[]	orderColumns(java.lang.String[] columnNames, org.jumpmind.db.model.Table table) Deprecated.
java.lang.String	preProcessTriggerSqlClause(java.lang.String sqlClause)
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)
void	setExtensionService(IExtensionService extensionService)
void	setTargetDialect(ISymmetricDialect targetDialect)
boolean	supportsBatchUpdates()
boolean	supportsOpenCursorsAcrossCommit()
boolean	supportsSubselectsInDelete()
boolean	supportsSubselectsInUpdate()
boolean	supportsTransactionId()
boolean	supportsTransactionViews()
void	truncateTable(java.lang.String tableName)
void	verifyDatabaseIsCompatible()

Method Detail

createTrigger

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)

createTrigger

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)

createDdlTrigger

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

getEngineName

java.lang.String getEngineName()

removeTrigger

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)

removeTrigger

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

removeDdlTrigger

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

doesTriggerExist

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

doesDdlTriggerExist

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

verifyDatabaseIsCompatible

void verifyDatabaseIsCompatible()

initTablesAndDatabaseObjects

void initTablesAndDatabaseObjects()

dropTablesAndDatabaseObjects

void dropTablesAndDatabaseObjects()

createOrAlterTablesIfNecessary

boolean createOrAlterTablesIfNecessary(java.lang.String... tables)

dropRequiredDatabaseObjects

void dropRequiredDatabaseObjects()

createRequiredDatabaseObjects

void createRequiredDatabaseObjects()

getPlatform

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

getTargetPlatform

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

getName

java.lang.String getName()

getVersion

java.lang.String getVersion()

getMajorVersion

int getMajorVersion()

getMinorVersion

int getMinorVersion()

getProductVersion

java.lang.String getProductVersion()

getBinaryEncoding

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

getTransactionTriggerExpression

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

createInitialLoadSqlFor

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

getColumnPositionUsingTemplate

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

createPurgeSqlFor

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

createPurgeSqlFor

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

createPurgeSqlFor

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

createPurgeSqlForMultipleTables

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

createCsvDataSql

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

createCsvPrimaryKeySql

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

getMaxTriggerNameLength

int getMaxTriggerNameLength()

supportsTransactionId

boolean supportsTransactionId()

supportsTransactionViews

boolean supportsTransactionViews()

supportsSubselectsInDelete

boolean supportsSubselectsInDelete()

supportsSubselectsInUpdate

boolean supportsSubselectsInUpdate()

cleanDatabase

void cleanDatabase()

disableSyncTriggers

@Deprecated
void disableSyncTriggers(org.jumpmind.db.sql.ISqlTransaction transaction)

Deprecated.

disableSyncTriggers

void disableSyncTriggers(org.jumpmind.db.sql.ISqlTransaction transaction,
                         java.lang.String nodeId)

enableSyncTriggers

void enableSyncTriggers(org.jumpmind.db.sql.ISqlTransaction transaction)

getSyncTriggersExpression

java.lang.String getSyncTriggersExpression()

getSourceNodeExpression

java.lang.String getSourceNodeExpression()

getCreateSymmetricDDL

java.lang.String getCreateSymmetricDDL()

isBlobSyncSupported

boolean isBlobSyncSupported()

isClobSyncSupported

boolean isClobSyncSupported()

isTransactionIdOverrideSupported

boolean isTransactionIdOverrideSupported()

getTable

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

insertWithGeneratedKey

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

insertWithGeneratedKey

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

orderColumns

@Deprecated
org.jumpmind.db.model.Column[] orderColumns(java.lang.String[] columnNames,
                                                        org.jumpmind.db.model.Table table)

Deprecated.

supportsOpenCursorsAcrossCommit

boolean supportsOpenCursorsAcrossCommit()

getSqlKeywords

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

getInitialLoadTableAlias

java.lang.String getInitialLoadTableAlias()

preProcessTriggerSqlClause

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

truncateTable

void truncateTable(java.lang.String tableName)

getDatabaseTime

long getDatabaseTime()

areDatabaseTransactionsPendingSince

boolean areDatabaseTransactionsPendingSince(long time)

getEarliestTransactionStartTime

java.util.Date getEarliestTransactionStartTime()

needsToSelectLobData

boolean needsToSelectLobData()

getDataHasChangedCondition

java.lang.String getDataHasChangedCondition(Trigger trigger)

canGapsOccurInCapturedDataIds

boolean canGapsOccurInCapturedDataIds()

massageDataExtractionSql

java.lang.String massageDataExtractionSql(java.lang.String sql,
                                          boolean isContainsBigLob)

massageForLob

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

isInitialLoadTwoPassLob

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

getInitialLoadTwoPassLobSql

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

escapesTemplatesForDatabaseInserts

boolean escapesTemplatesForDatabaseInserts()

getMasterCollation

java.lang.String getMasterCollation()

supportsBatchUpdates

boolean supportsBatchUpdates()

cleanupTriggers

void cleanupTriggers()

getDriverName

java.lang.String getDriverName()

getDriverVersion

java.lang.String getDriverVersion()

getSequenceName

java.lang.String getSequenceName(SequenceIdentifier identifier)

getSequenceKeyName

java.lang.String getSequenceKeyName(SequenceIdentifier identifier)

getCurrentSequenceValue

long getCurrentSequenceValue(SequenceIdentifier identifier)

getTablePrefix

java.lang.String getTablePrefix()

readSymmetricSchemaFromXml

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

getTemplateNumberPrecisionSpec

java.lang.String getTemplateNumberPrecisionSpec()

getSqlReplacementTokens

java.util.Map<java.lang.String,java.lang.String> getSqlReplacementTokens()

getSqlTypeForIds

int getSqlTypeForIds()

getTriggerTemplate

AbstractTriggerTemplate getTriggerTemplate()

getParameterService

IParameterService getParameterService()

setExtensionService

void setExtensionService(IExtensionService extensionService)

getSymTablePermissions

org.jumpmind.db.platform.PermissionType[] getSymTablePermissions()

getTargetDialect

ISymmetricDialect getTargetDialect()

setTargetDialect

void setTargetDialect(ISymmetricDialect targetDialect)