Package org.jumpmind.symmetric.db.db2

Class Db2SymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

org.jumpmind.symmetric.db.db2.Db2SymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

Direct Known Subclasses:

Db2As400SymmetricDialect, Db2v9SymmetricDialect, Db2zOsSymmetricDialect

public class Db2SymmetricDialect
extends AbstractSymmetricDialect
implements ISymmetricDialect

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FUNCTION_TRANSACTION_ID
static final String	VAR_SOURCE_NODE_ID
static final String	VAR_TRIGGER_DISABLED

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
Db2SymmetricDialect(IParameterService parameterService, IDatabasePlatform platform)

Method Summary

Modifier and Type	Method	Description
void	cleanDatabase()
boolean	createOrAlterTablesIfNecessary(String... tables)
void	createRequiredDatabaseObjects()
void	disableSyncTriggers(ISqlTransaction transaction, String nodeId)
protected boolean	doesTriggerExistOnPlatform(String catalog, String schema, String tableName, String triggerName)
void	dropRequiredDatabaseObjects()
void	enableSyncTriggers(ISqlTransaction transaction)
BinaryEncoding	getBinaryEncoding()
String	getDatabaseTimeSQL()
protected String	getDbSpecificDataHasChangedCondition(Trigger trigger)
String	getSourceNodeExpression()
String	getSyncTriggersExpression()
protected String	getSystemSchemaName()
String	getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, Trigger trigger)
boolean	isBlobSyncSupported()
boolean	isClobSyncSupported()
String	massageDataExtractionSql(String sql, boolean isContainsBigLob)
boolean	supportsTransactionId()
void	truncateTable(String tableName)

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

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

Field Details

VAR_SOURCE_NODE_ID

public static final String VAR_SOURCE_NODE_ID

See Also:

• Constant Field Values

VAR_TRIGGER_DISABLED

public static final String VAR_TRIGGER_DISABLED

See Also:

• Constant Field Values

FUNCTION_TRANSACTION_ID

public static final String FUNCTION_TRANSACTION_ID

See Also:

• Constant Field Values

Constructor Details

Db2SymmetricDialect

public Db2SymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

createOrAlterTablesIfNecessary

public boolean createOrAlterTablesIfNecessary(String... tables)

Specified by:

createOrAlterTablesIfNecessary in interface ISymmetricDialect

Overrides:

createOrAlterTablesIfNecessary in class AbstractSymmetricDialect

doesTriggerExistOnPlatform

protected boolean doesTriggerExistOnPlatform(String catalog,
 String schema,
 String tableName,
 String triggerName)

Specified by:

doesTriggerExistOnPlatform in class AbstractSymmetricDialect

massageDataExtractionSql

public String massageDataExtractionSql(String sql,
 boolean isContainsBigLob)

Specified by:

massageDataExtractionSql in interface ISymmetricDialect

Overrides:

massageDataExtractionSql in class AbstractSymmetricDialect

getSystemSchemaName

protected String getSystemSchemaName()

createRequiredDatabaseObjects

public void createRequiredDatabaseObjects()

Specified by:

createRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

createRequiredDatabaseObjects in class AbstractSymmetricDialect

dropRequiredDatabaseObjects

public void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

dropRequiredDatabaseObjects in class AbstractSymmetricDialect

isBlobSyncSupported

public boolean isBlobSyncSupported()

Specified by:

isBlobSyncSupported in interface ISymmetricDialect

Overrides:

isBlobSyncSupported in class AbstractSymmetricDialect

isClobSyncSupported

public boolean isClobSyncSupported()

Specified by:

isClobSyncSupported in interface ISymmetricDialect

Overrides:

isClobSyncSupported in class AbstractSymmetricDialect

getBinaryEncoding

public BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

Specified by:

getBinaryEncoding in class AbstractSymmetricDialect

enableSyncTriggers

public void enableSyncTriggers(ISqlTransaction transaction)

Specified by:

enableSyncTriggers in interface ISymmetricDialect

disableSyncTriggers

public void disableSyncTriggers(ISqlTransaction transaction,
 String nodeId)

Specified by:

disableSyncTriggers 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

cleanDatabase

public void cleanDatabase()

Specified by:

cleanDatabase in interface ISymmetricDialect

truncateTable

public void truncateTable(String tableName)

Specified by:

truncateTable in interface ISymmetricDialect

Overrides:

truncateTable in class AbstractSymmetricDialect

getDbSpecificDataHasChangedCondition

protected String getDbSpecificDataHasChangedCondition(Trigger trigger)

Overrides:

getDbSpecificDataHasChangedCondition in class AbstractSymmetricDialect

getSourceNodeExpression

public String getSourceNodeExpression()

Specified by:

getSourceNodeExpression in interface ISymmetricDialect

Overrides:

getSourceNodeExpression in class AbstractSymmetricDialect

getDatabaseTimeSQL

public String getDatabaseTimeSQL()

Specified by:

getDatabaseTimeSQL in interface ISymmetricDialect

Overrides:

getDatabaseTimeSQL in class AbstractSymmetricDialect