Package org.jumpmind.symmetric.db.mssql

Class MsSqlSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

org.jumpmind.symmetric.db.mssql.MsSqlSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

Direct Known Subclasses:

MsSql2000SymmetricDialect, MsSql2008SymmetricDialect

public class MsSqlSymmetricDialect
extends AbstractSymmetricDialect
implements ISymmetricDialect

Field Summary

Fields

Modifier and Type	Field	Description
protected int	noCount
protected static final String	SQL_DROP_FUNCTION
protected static final String	SQL_FUNCTION_INSTALLED
protected Boolean	supportsDisableTriggers

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

Method Summary

Modifier and Type	Method	Description
protected boolean	alterLockEscalation()
void	cleanDatabase()
protected void	createBase64EncodeFunction()
protected void	createNodeDisabledFunction()
boolean	createOrAlterTablesIfNecessary(String... tableNames)
void	createRequiredDatabaseObjects()
protected void	createTriggersDisabledFunction()
void	disableSyncTriggers(ISqlTransaction transaction, String nodeId)
protected boolean	doesTriggerExistOnPlatform(String catalogName, String schema, String tableName, String triggerName)
protected void	dropBase64EncodeFunction()
protected void	dropNodeDisabledFunction()
void	dropRequiredDatabaseObjects()
protected void	dropTriggersDisabledFunction()
void	enableSyncTriggers(ISqlTransaction transaction)
BinaryEncoding	getBinaryEncoding()
long	getCurrentSequenceValue(SequenceIdentifier identifier)
protected String	getDbSpecificDataHasChangedCondition(Trigger trigger)
PermissionType[]	getSymTablePermissions()
String	getSyncTriggersExpression()
String	getSyncTriggersOnIncomingExpression()
String	getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, Trigger trigger)
boolean	isTransactionIdOverrideSupported()
boolean	needsToSelectLobData()
protected void	postCreateTrigger(ISqlTransaction transaction, StringBuilder sqlBuffer, DataEventType dml, Trigger trigger, TriggerHistory hist, Channel channel, String tablePrefix, Table table)
Database	readSymmetricSchemaFromXml()
void	removeDdlTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName)
void	removeTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName, ISqlTransaction transaction)
protected void	setColumnToNtext(Column column)
protected void	setColumnToVarChar(Column column, boolean forceNtype)
protected boolean	supportsDisableTriggers()
boolean	supportsTransactionId()
protected String	switchCatalogForTriggerInstall(String catalog, ISqlTransaction transaction)
void	verifyDatabaseIsCompatible()

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, getDatabaseTime, getDatabaseTimeSQL, getDataHasChangedCondition, getDriverName, getDriverVersion, getDropTriggerSql, getEarliestTransactionStartTime, getEngineName, getInitialLoadTableAlias, getInitialLoadTwoPassLobLengthSql, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSequenceName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSqlTypeForIds, getSymmetricDdlChanges, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTemplateNumberPrecisionSpec, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, install, installed, isBlobSyncSupported, isClobSyncSupported, isInitialLoadTwoPassLob, logSql, massageDataExtractionSql, massageForLob, merge, orderColumns, postCreateDdlTrigger, prefixConfigDatabase, preProcessTriggerSqlClause, readDatabaseFromXml, readSymmetricSchemaFromDatabase, removeTrigger, replaceTokens, requiresAutoCommitFalseToSetFetchSize, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionViews, truncateTable, uninstall

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, getDatabaseTime, getDatabaseTimeSQL, getDataHasChangedCondition, getDriverName, getDriverVersion, getEarliestTransactionStartTime, getEngineName, getInitialLoadTableAlias, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSequenceName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSqlTypeForIds, getSymmetricDdlChanges, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTemplateNumberPrecisionSpec, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, isBlobSyncSupported, isClobSyncSupported, isInitialLoadTwoPassLob, massageDataExtractionSql, massageForLob, orderColumns, preProcessTriggerSqlClause, removeTrigger, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionViews, truncateTable

Field Details

SQL_DROP_FUNCTION

protected static final String SQL_DROP_FUNCTION

See Also:

• Constant Field Values

SQL_FUNCTION_INSTALLED

protected static final String SQL_FUNCTION_INSTALLED

See Also:

• Constant Field Values

supportsDisableTriggers

protected Boolean supportsDisableTriggers

noCount

protected int noCount

Constructor Details

MsSqlSymmetricDialect

public MsSqlSymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

readSymmetricSchemaFromXml

public Database readSymmetricSchemaFromXml()

Specified by:

readSymmetricSchemaFromXml in interface ISymmetricDialect

Overrides:

readSymmetricSchemaFromXml in class AbstractSymmetricDialect

setColumnToNtext

protected void setColumnToNtext(Column column)

setColumnToVarChar

protected void setColumnToVarChar(Column column,
 boolean forceNtype)

createOrAlterTablesIfNecessary

public boolean createOrAlterTablesIfNecessary(String... tableNames)

Specified by:

createOrAlterTablesIfNecessary in interface ISymmetricDialect

Overrides:

createOrAlterTablesIfNecessary in class AbstractSymmetricDialect

alterLockEscalation

protected boolean alterLockEscalation()

verifyDatabaseIsCompatible

public void verifyDatabaseIsCompatible()

Specified by:

verifyDatabaseIsCompatible in interface ISymmetricDialect

Overrides:

verifyDatabaseIsCompatible in class AbstractSymmetricDialect

createRequiredDatabaseObjects

public void createRequiredDatabaseObjects()

Specified by:

createRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

createRequiredDatabaseObjects in class AbstractSymmetricDialect

createBase64EncodeFunction

protected void createBase64EncodeFunction()

createTriggersDisabledFunction

protected void createTriggersDisabledFunction()

createNodeDisabledFunction

protected void createNodeDisabledFunction()

dropRequiredDatabaseObjects

public void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

dropRequiredDatabaseObjects in class AbstractSymmetricDialect

dropBase64EncodeFunction

protected void dropBase64EncodeFunction()

dropTriggersDisabledFunction

protected void dropTriggersDisabledFunction()

dropNodeDisabledFunction

protected void dropNodeDisabledFunction()

supportsDisableTriggers

protected boolean supportsDisableTriggers()

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

postCreateTrigger

protected void postCreateTrigger(ISqlTransaction transaction,
 StringBuilder sqlBuffer,
 DataEventType dml,
 Trigger trigger,
 TriggerHistory hist,
 Channel channel,
 String tablePrefix,
 Table table)

Overrides:

postCreateTrigger in class AbstractSymmetricDialect

getBinaryEncoding

public BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

Specified by:

getBinaryEncoding in class AbstractSymmetricDialect

doesTriggerExistOnPlatform

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

Specified by:

doesTriggerExistOnPlatform in class AbstractSymmetricDialect

removeDdlTrigger

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

Specified by:

removeDdlTrigger in interface ISymmetricDialect

Overrides:

removeDdlTrigger 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

getSyncTriggersOnIncomingExpression

public String getSyncTriggersOnIncomingExpression()

Specified by:

getSyncTriggersOnIncomingExpression in interface ISymmetricDialect

Overrides:

getSyncTriggersOnIncomingExpression in class AbstractSymmetricDialect

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

getDbSpecificDataHasChangedCondition

protected String getDbSpecificDataHasChangedCondition(Trigger trigger)

Overrides:

getDbSpecificDataHasChangedCondition in class AbstractSymmetricDialect

getCurrentSequenceValue

public long getCurrentSequenceValue(SequenceIdentifier identifier)

Specified by:

getCurrentSequenceValue in interface ISymmetricDialect

Overrides:

getCurrentSequenceValue in class AbstractSymmetricDialect

getSymTablePermissions

public PermissionType[] getSymTablePermissions()

Specified by:

getSymTablePermissions in interface ISymmetricDialect

Overrides:

getSymTablePermissions in class AbstractSymmetricDialect