Package org.jumpmind.symmetric.db

Class AbstractEmbeddedSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

org.jumpmind.symmetric.db.AbstractEmbeddedSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

Direct Known Subclasses:

H2SymmetricDialect, HsqlDbSymmetricDialect

public abstract class AbstractEmbeddedSymmetricDialect
extends AbstractSymmetricDialect
implements ISymmetricDialect

Field Summary

Fields inherited from class org.jumpmind.symmetric.db.AbstractSymmetricDialect

databaseMajorVersion, databaseMinorVersion, databaseName, databaseProductVersion, driverName, driverVersion, extensionService, isSpatialTypesEnabled, log, MAX_SYMMETRIC_SUPPORTED_TRIGGER_SIZE, parameterService, platform, sqlKeywords, sqlReplacementTokens, supportsDdlTriggers, supportsGetGeneratedKeys, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionViews, tablePrefixLowerCase, targetDialect, triggerTemplate

Constructor Summary

Constructors

Constructor	Description
AbstractEmbeddedSymmetricDialect(IParameterService parameterService, IDatabasePlatform platform)

Method Summary

Modifier and Type	Method	Description
void	cleanDatabase()
String	createCsvDataSql(Trigger trigger, TriggerHistory triggerHistory, Channel channel, String whereClause)
String	createCsvPrimaryKeySql(Trigger trigger, TriggerHistory triggerHistory, Channel channel, String whereClause)
String	createInitialLoadSqlFor(Node node, TriggerRouter trigger, Table table, TriggerHistory triggerHistory, Channel channel, String overrideSelectSql)	All the templates have ' escaped because the SQL is inserted into a view.
boolean	escapesTemplatesForDatabaseInserts()
String	getDefaultCatalog()
String	getInitialLoadTableAlias()
String	preProcessTriggerSqlClause(String sqlClause)

Methods inherited from class org.jumpmind.symmetric.db.AbstractSymmetricDialect

areDatabaseTransactionsPendingSince, buildSqlReplacementTokens, canGapsOccurInCapturedDataIds, cleanupTriggers, close, createDdlTrigger, createOrAlterTablesIfNecessary, createPostDdlTriggerDDL, createPostTriggerDDL, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlForMultipleTables, createRequiredDatabaseObjects, createRequiredDatabaseObjectsImpl, createTrigger, createTrigger, disableSyncTriggers, doesDdlTriggerExist, doesTriggerExist, doesTriggerExistOnPlatform, dropRequiredDatabaseObjects, dropTablesAndDatabaseObjects, getBinaryEncoding, getColumnPositionUsingTemplate, getCreateRequiredDatabaseObjectsDDL, getCreateSymmetricDDL, getCurrentSequenceValue, getDatabaseTime, getDatabaseTimeSQL, getDataHasChangedCondition, getDbSpecificDataHasChangedCondition, getDriverName, getDriverVersion, getDropTriggerSql, getEarliestTransactionStartTime, getEngineName, getInitialLoadTwoPassLobLengthSql, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSequenceName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSqlTypeForIds, getSymmetricDdlChanges, getSymTablePermissions, getSyncTriggersOnIncomingExpression, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTemplateNumberPrecisionSpec, getTransactionId, getTransactionTriggerExpression, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, install, installed, isBlobSyncSupported, isClobSyncSupported, isInitialLoadTwoPassLob, isTransactionIdOverrideSupported, logSql, massageDataExtractionSql, massageForLob, merge, needsToSelectLobData, orderColumns, postCreateDdlTrigger, postCreateTrigger, prefixConfigDatabase, readDatabaseFromXml, readSymmetricSchemaFromDatabase, readSymmetricSchemaFromXml, removeDdlTrigger, removeTrigger, removeTrigger, replaceTokens, requiresAutoCommitFalseToSetFetchSize, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionId, supportsTransactionViews, switchCatalogForTriggerInstall, truncateTable, uninstall, uninstall, 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

areDatabaseTransactionsPendingSince, canGapsOccurInCapturedDataIds, cleanupTriggers, createDdlTrigger, createOrAlterTablesIfNecessary, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlForMultipleTables, createRequiredDatabaseObjects, createTrigger, createTrigger, disableSyncTriggers, disableSyncTriggers, doesDdlTriggerExist, doesTriggerExist, dropRequiredDatabaseObjects, dropTablesAndDatabaseObjects, enableSyncTriggers, getBinaryEncoding, getColumnPositionUsingTemplate, getCreateRequiredDatabaseObjectsDDL, getCreateSymmetricDDL, getCurrentSequenceValue, getDatabaseTime, getDatabaseTimeSQL, getDataHasChangedCondition, getDriverName, getDriverVersion, getEarliestTransactionStartTime, getEngineName, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSequenceName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSqlTypeForIds, getSymmetricDdlChanges, getSymTablePermissions, getSyncTriggersExpression, getSyncTriggersOnIncomingExpression, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTemplateNumberPrecisionSpec, getTransactionId, getTransactionTriggerExpression, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, isBlobSyncSupported, isClobSyncSupported, isInitialLoadTwoPassLob, isTransactionIdOverrideSupported, massageDataExtractionSql, massageForLob, needsToSelectLobData, orderColumns, readSymmetricSchemaFromXml, removeDdlTrigger, removeTrigger, removeTrigger, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionId, supportsTransactionViews, truncateTable, verifyDatabaseIsCompatible

Constructor Details

AbstractEmbeddedSymmetricDialect

public AbstractEmbeddedSymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

createInitialLoadSqlFor

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

All the templates have ' escaped because the SQL is inserted into a view. When returning the raw SQL for use as SQL it needs to be un-escaped.

Specified by:

createInitialLoadSqlFor in interface ISymmetricDialect

Overrides:

createInitialLoadSqlFor in class AbstractSymmetricDialect

createCsvDataSql

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

Specified by:

createCsvDataSql in interface ISymmetricDialect

Overrides:

createCsvDataSql in class AbstractSymmetricDialect

createCsvPrimaryKeySql

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

Specified by:

createCsvPrimaryKeySql in interface ISymmetricDialect

Overrides:

createCsvPrimaryKeySql in class AbstractSymmetricDialect

cleanDatabase

public void cleanDatabase()

Specified by:

cleanDatabase in interface ISymmetricDialect

getDefaultCatalog

public String getDefaultCatalog()

getInitialLoadTableAlias

public String getInitialLoadTableAlias()

Specified by:

getInitialLoadTableAlias in interface ISymmetricDialect

Overrides:

getInitialLoadTableAlias in class AbstractSymmetricDialect

preProcessTriggerSqlClause

public String preProcessTriggerSqlClause(String sqlClause)

Specified by:

preProcessTriggerSqlClause in interface ISymmetricDialect

Overrides:

preProcessTriggerSqlClause in class AbstractSymmetricDialect

escapesTemplatesForDatabaseInserts

public boolean escapesTemplatesForDatabaseInserts()

Specified by:

escapesTemplatesForDatabaseInserts in interface ISymmetricDialect

Overrides:

escapesTemplatesForDatabaseInserts in class AbstractSymmetricDialect