Package org.jumpmind.symmetric.db.oracle

Class OracleSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

org.jumpmind.symmetric.db.oracle.OracleSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

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

Method Summary

Modifier and Type	Method	Description
final boolean	areDatabaseTransactionsPendingSince(long time)
protected void	buildSqlReplacementTokens()
void	cleanDatabase()
boolean	createOrAlterTablesIfNecessary(String... tableNames)
void	createRequiredDatabaseObjectsImpl(StringBuilder ddl)
void	createTrigger(StringBuilder sqlBuffer, DataEventType dml, Trigger trigger, TriggerHistory history, Channel channel, String tablePrefix, Table table, ISqlTransaction transaction)
void	disableSyncTriggers(ISqlTransaction transaction, String nodeId)
boolean	doesDdlTriggerExist(String catalogName, String schema, String triggerName)
protected boolean	doesTriggerExistOnPlatform(StringBuilder sqlBuffer, String catalog, String schema, String tableName, String triggerName)
void	dropRequiredDatabaseObjects()
void	enableSyncTriggers(ISqlTransaction transaction)
BinaryEncoding	getBinaryEncoding()
long	getCurrentSequenceValue(SequenceIdentifier identifier)
String	getDatabaseTimeSQL()
protected String	getDbSpecificDataHasChangedCondition(Trigger trigger)
protected String	getDropTriggerSql(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName)
Date	getEarliestTransactionStartTime()
String	getInitialLoadTwoPassLobLengthSql(Column column, boolean isFirstPass)
String	getSequenceName(SequenceIdentifier identifier)
protected String	getSymmetricPackageName()
PermissionType[]	getSymTablePermissions()
String	getSyncTriggersExpression()
String	getSyncTriggersOnIncomingExpression()
String	getTemplateNumberPrecisionSpec()
String	getTransactionId(ISqlTransaction transaction)
String	getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, Trigger trigger)
boolean	isInitialLoadTwoPassLob(Table table)
String	massageDataExtractionSql(String sql, boolean isContainsBigLob)
String	massageForLob(String sql, boolean isContainsBigLob)
Database	readSymmetricSchemaFromXml()
void	removeDdlTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName)
boolean	supportsTransactionId()

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

canGapsOccurInCapturedDataIds, cleanupTriggers, close, createCsvDataSql, createCsvPrimaryKeySql, createDdlTrigger, createInitialLoadSqlFor, createPostDdlTriggerDDL, createPostTriggerDDL, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlForMultipleTables, createRequiredDatabaseObjects, createTrigger, disableSyncTriggers, doesTriggerExist, dropTablesAndDatabaseObjects, escapesTemplatesForDatabaseInserts, getColumnPositionUsingTemplate, getCreateRequiredDatabaseObjectsDDL, getCreateSymmetricDDL, getDatabaseTime, getDataHasChangedCondition, getDriverName, getDriverVersion, getEngineName, getInitialLoadTableAlias, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSqlTypeForIds, getSymmetricDdlChanges, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, install, installed, isBlobSyncSupported, isClobSyncSupported, isTransactionIdOverrideSupported, logSql, merge, needsToSelectLobData, orderColumns, postCreateDdlTrigger, postCreateTrigger, prefixConfigDatabase, preProcessTriggerSqlClause, readDatabaseFromXml, readSymmetricSchemaFromDatabase, removeTrigger, removeTrigger, replaceTokens, requiresAutoCommitFalseToSetFetchSize, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, 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

canGapsOccurInCapturedDataIds, cleanupTriggers, createCsvDataSql, createCsvPrimaryKeySql, createDdlTrigger, createInitialLoadSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlForMultipleTables, createRequiredDatabaseObjects, createTrigger, disableSyncTriggers, doesTriggerExist, dropTablesAndDatabaseObjects, escapesTemplatesForDatabaseInserts, getColumnPositionUsingTemplate, getCreateRequiredDatabaseObjectsDDL, getCreateSymmetricDDL, getDatabaseTime, getDataHasChangedCondition, getDriverName, getDriverVersion, getEngineName, getInitialLoadTableAlias, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSqlTypeForIds, getSymmetricDdlChanges, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, isBlobSyncSupported, isClobSyncSupported, isTransactionIdOverrideSupported, needsToSelectLobData, orderColumns, preProcessTriggerSqlClause, removeTrigger, removeTrigger, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionViews, truncateTable, verifyDatabaseIsCompatible

Constructor Details

OracleSymmetricDialect

public OracleSymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

readSymmetricSchemaFromXml

public Database readSymmetricSchemaFromXml()

Specified by:

readSymmetricSchemaFromXml in interface ISymmetricDialect

Overrides:

readSymmetricSchemaFromXml in class AbstractSymmetricDialect

buildSqlReplacementTokens

protected void buildSqlReplacementTokens()

Overrides:

buildSqlReplacementTokens in class AbstractSymmetricDialect

doesTriggerExistOnPlatform

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

Specified by:

doesTriggerExistOnPlatform in class AbstractSymmetricDialect

getDropTriggerSql

protected String getDropTriggerSql(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName,
 String tableName)

Overrides:

getDropTriggerSql in class AbstractSymmetricDialect

createTrigger

public void createTrigger(StringBuilder sqlBuffer,
 DataEventType dml,
 Trigger trigger,
 TriggerHistory history,
 Channel channel,
 String tablePrefix,
 Table table,
 ISqlTransaction transaction)

Specified by:

createTrigger in interface ISymmetricDialect

Overrides:

createTrigger in class AbstractSymmetricDialect

doesDdlTriggerExist

public boolean doesDdlTriggerExist(String catalogName,
 String schema,
 String triggerName)

Specified by:

doesDdlTriggerExist in interface ISymmetricDialect

Overrides:

doesDdlTriggerExist 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

createRequiredDatabaseObjectsImpl

public void createRequiredDatabaseObjectsImpl(StringBuilder ddl)

Overrides:

createRequiredDatabaseObjectsImpl in class AbstractSymmetricDialect

createOrAlterTablesIfNecessary

public boolean createOrAlterTablesIfNecessary(String... tableNames)

Specified by:

createOrAlterTablesIfNecessary in interface ISymmetricDialect

Overrides:

createOrAlterTablesIfNecessary in class AbstractSymmetricDialect

dropRequiredDatabaseObjects

public void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

dropRequiredDatabaseObjects in class AbstractSymmetricDialect

getBinaryEncoding

public BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

Specified by:

getBinaryEncoding in class AbstractSymmetricDialect

getTransactionTriggerExpression

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

Specified by:

getTransactionTriggerExpression in interface ISymmetricDialect

Overrides:

getTransactionTriggerExpression in class AbstractSymmetricDialect

getTransactionId

public String getTransactionId(ISqlTransaction transaction)

Specified by:

getTransactionId in interface ISymmetricDialect

Overrides:

getTransactionId in class AbstractSymmetricDialect

supportsTransactionId

public boolean supportsTransactionId()

Specified by:

supportsTransactionId in interface ISymmetricDialect

Overrides:

supportsTransactionId in class AbstractSymmetricDialect

getSequenceName

public String getSequenceName(SequenceIdentifier identifier)

Specified by:

getSequenceName in interface ISymmetricDialect

Overrides:

getSequenceName in class AbstractSymmetricDialect

getCurrentSequenceValue

public long getCurrentSequenceValue(SequenceIdentifier identifier)

Specified by:

getCurrentSequenceValue in interface ISymmetricDialect

Overrides:

getCurrentSequenceValue in class AbstractSymmetricDialect

cleanDatabase

public void cleanDatabase()

Specified by:

cleanDatabase in interface ISymmetricDialect

getSymmetricPackageName

protected String getSymmetricPackageName()

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

areDatabaseTransactionsPendingSince

public final boolean areDatabaseTransactionsPendingSince(long time)

Specified by:

areDatabaseTransactionsPendingSince in interface ISymmetricDialect

Overrides:

areDatabaseTransactionsPendingSince in class AbstractSymmetricDialect

getEarliestTransactionStartTime

public Date getEarliestTransactionStartTime()

Specified by:

getEarliestTransactionStartTime in interface ISymmetricDialect

Overrides:

getEarliestTransactionStartTime in class AbstractSymmetricDialect

massageDataExtractionSql

public String massageDataExtractionSql(String sql,
 boolean isContainsBigLob)

Specified by:

massageDataExtractionSql in interface ISymmetricDialect

Overrides:

massageDataExtractionSql in class AbstractSymmetricDialect

massageForLob

public String massageForLob(String sql,
 boolean isContainsBigLob)

Specified by:

massageForLob in interface ISymmetricDialect

Overrides:

massageForLob in class AbstractSymmetricDialect

isInitialLoadTwoPassLob

public boolean isInitialLoadTwoPassLob(Table table)

Specified by:

isInitialLoadTwoPassLob in interface ISymmetricDialect

Overrides:

isInitialLoadTwoPassLob in class AbstractSymmetricDialect

getInitialLoadTwoPassLobLengthSql

public String getInitialLoadTwoPassLobLengthSql(Column column,
 boolean isFirstPass)

Overrides:

getInitialLoadTwoPassLobLengthSql in class AbstractSymmetricDialect

getDbSpecificDataHasChangedCondition

protected String getDbSpecificDataHasChangedCondition(Trigger trigger)

Overrides:

getDbSpecificDataHasChangedCondition in class AbstractSymmetricDialect

getTemplateNumberPrecisionSpec

public String getTemplateNumberPrecisionSpec()

Specified by:

getTemplateNumberPrecisionSpec in interface ISymmetricDialect

Overrides:

getTemplateNumberPrecisionSpec in class AbstractSymmetricDialect

getSymTablePermissions

public PermissionType[] getSymTablePermissions()

Specified by:

getSymTablePermissions in interface ISymmetricDialect

Overrides:

getSymTablePermissions in class AbstractSymmetricDialect

getDatabaseTimeSQL

public String getDatabaseTimeSQL()

Specified by:

getDatabaseTimeSQL in interface ISymmetricDialect

Overrides:

getDatabaseTimeSQL in class AbstractSymmetricDialect