Package org.jumpmind.symmetric.db.ase

Class AseSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

org.jumpmind.symmetric.db.ase.AseSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

public class AseSymmetricDialect
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
AseSymmetricDialect(IParameterService parameterService, IDatabasePlatform platform)

Method Summary

Modifier and Type	Method	Description
boolean	alterTableIdentityGapIfNecessary()
boolean	alterTableLockingSchemeIfNecessary()	Applies the "datarows" table locking scheme to overcome overly restrictive defaults ("allpages" or "datapages") causing database waits and deadlocks
void	cleanDatabase()
boolean	createOrAlterTablesIfNecessary(String... tableNames)
void	disableSyncTriggers(ISqlTransaction transaction, String nodeId)
protected boolean	doesTriggerExistOnPlatform(StringBuilder sqlBuffer, String catalogName, String schema, String tableName, String triggerName)
void	dropRequiredDatabaseObjects()
void	enableSyncTriggers(ISqlTransaction transaction)
BinaryEncoding	getBinaryEncoding()
int	getMaxTriggerNameLength()
int	getPageSize()
String	getSyncTriggersExpression()
List<String>	getTableNamesRequiringDatarowLockingScheme(String prefix)
String	getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, Trigger trigger)
boolean	isTransactionIdOverrideSupported()
boolean	needsToSelectLobData()
Database	readSymmetricSchemaFromXml()
protected void	reconfigureTableColumn(Database database, String prefix, String tableName, String columnName, String size)
void	removeTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName, ISqlTransaction transaction)
boolean	supportsTransactionId()
protected String	switchCatalogForTriggerInstall(String catalog, ISqlTransaction transaction)

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

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

Constructor Details

AseSymmetricDialect

public AseSymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

readSymmetricSchemaFromXml

public Database readSymmetricSchemaFromXml()

Specified by:

readSymmetricSchemaFromXml in interface ISymmetricDialect

Overrides:

readSymmetricSchemaFromXml in class AbstractSymmetricDialect

reconfigureTableColumn

protected void reconfigureTableColumn(Database database,
 String prefix,
 String tableName,
 String columnName,
 String size)

createOrAlterTablesIfNecessary

public boolean createOrAlterTablesIfNecessary(String... tableNames)

Specified by:

createOrAlterTablesIfNecessary in interface ISymmetricDialect

Overrides:

createOrAlterTablesIfNecessary in class AbstractSymmetricDialect

alterTableIdentityGapIfNecessary

public boolean alterTableIdentityGapIfNecessary()

alterTableLockingSchemeIfNecessary

public boolean alterTableLockingSchemeIfNecessary()

Applies the "datarows" table locking scheme to overcome overly restrictive defaults ("allpages" or "datapages") causing database waits and deadlocks

getTableNamesRequiringDatarowLockingScheme

public List<String> getTableNamesRequiringDatarowLockingScheme(String prefix)

dropRequiredDatabaseObjects

public void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

dropRequiredDatabaseObjects in class AbstractSymmetricDialect

removeTrigger

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

Specified by:

removeTrigger in interface ISymmetricDialect

Overrides:

removeTrigger in class AbstractSymmetricDialect

switchCatalogForTriggerInstall

protected String switchCatalogForTriggerInstall(String catalog,
 ISqlTransaction transaction)

Overrides:

switchCatalogForTriggerInstall in class AbstractSymmetricDialect

getBinaryEncoding

public BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

Specified by:

getBinaryEncoding in class AbstractSymmetricDialect

doesTriggerExistOnPlatform

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

Specified by:

doesTriggerExistOnPlatform in class AbstractSymmetricDialect

disableSyncTriggers

public void disableSyncTriggers(ISqlTransaction transaction,
 String nodeId)

Specified by:

disableSyncTriggers in interface ISymmetricDialect

enableSyncTriggers

public void enableSyncTriggers(ISqlTransaction transaction)

Specified by:

enableSyncTriggers in interface ISymmetricDialect

getSyncTriggersExpression

public String getSyncTriggersExpression()

Specified by:

getSyncTriggersExpression in interface ISymmetricDialect

getTransactionTriggerExpression

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

Specified by:

getTransactionTriggerExpression in interface ISymmetricDialect

Overrides:

getTransactionTriggerExpression in class AbstractSymmetricDialect

supportsTransactionId

public boolean supportsTransactionId()

Specified by:

supportsTransactionId in interface ISymmetricDialect

Overrides:

supportsTransactionId in class AbstractSymmetricDialect

isTransactionIdOverrideSupported

public boolean isTransactionIdOverrideSupported()

Specified by:

isTransactionIdOverrideSupported in interface ISymmetricDialect

Overrides:

isTransactionIdOverrideSupported in class AbstractSymmetricDialect

cleanDatabase

public void cleanDatabase()

Specified by:

cleanDatabase in interface ISymmetricDialect

needsToSelectLobData

public boolean needsToSelectLobData()

Specified by:

needsToSelectLobData in interface ISymmetricDialect

Overrides:

needsToSelectLobData in class AbstractSymmetricDialect

getMaxTriggerNameLength

public int getMaxTriggerNameLength()

Specified by:

getMaxTriggerNameLength in interface ISymmetricDialect

Overrides:

getMaxTriggerNameLength in class AbstractSymmetricDialect

getPageSize

public int getPageSize()