Package org.jumpmind.symmetric.db

Interface ISymmetricDialect

All Known Implementing Classes:
AbstractEmbeddedSymmetricDialect, AbstractSymmetricDialect, AseSymmetricDialect, Db2As400SymmetricDialect, Db2SymmetricDialect, Db2v9SymmetricDialect, Db2zOsSymmetricDialect, DerbySymmetricDialect, Firebird20SymmetricDialect, Firebird21SymmetricDialect, FirebirdSymmetricDialect, GenericSymmetricDialect, GreenplumSymmetricDialect, H2SymmetricDialect, HanaSymmetricDialect, HsqlDb2SymmetricDialect, HsqlDbSymmetricDialect, InformixSymmetricDialect, IngresSymmetricDialect, InterbaseSymmetricDialect, MariaDBSymmetricDialect, MsSql2000SymmetricDialect, MsSql2008SymmetricDialect, MsSql2016SymmetricDialect, MsSqlSymmetricDialect, MySqlSymmetricDialect, NuoDbSymmetricDialect, OracleSymmetricDialect, PostgreSqlSymmetricDialect, RaimaSymmetricDialect, RedshiftSymmetricDialect, SqlAnywhere12SymmetricDialect, SqlAnywhereSymmetricDialect, SqliteJdbcSymmetricDialect, SqliteSymmetricDialect, VoltDbSymmetricDialect
public interface ISymmetricDialect

  • Method Details

    • createTrigger

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

    • createTrigger

      void createTrigger(StringBuilder sqlBuffer, DataEventType dml, Trigger trigger, TriggerHistory hist, Channel channel, String tablePrefix, Table table)

    • createDdlTrigger

      void createDdlTrigger(String tablePrefix, StringBuilder sqlBuffer, String triggerName, String runtimeCatalog, String runtimeSchema)

    • getEngineName

      String getEngineName()

    • removeTrigger

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

    • removeTrigger

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

    • removeDdlTrigger

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

    • doesTriggerExist

      boolean doesTriggerExist(StringBuilder sqlBuffer, String catalogName, String schema, String tableName, String triggerName)

    • doesDdlTriggerExist

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

    • verifyDatabaseIsCompatible

      void verifyDatabaseIsCompatible()

    • initTablesAndDatabaseObjects

      void initTablesAndDatabaseObjects()

    • dropTablesAndDatabaseObjects

      void dropTablesAndDatabaseObjects()

    • createOrAlterTablesIfNecessary

      boolean createOrAlterTablesIfNecessary(String... tables)

    • dropRequiredDatabaseObjects

      void dropRequiredDatabaseObjects()

    • createRequiredDatabaseObjects

      void createRequiredDatabaseObjects()

    • getCreateRequiredDatabaseObjectsDDL

      String getCreateRequiredDatabaseObjectsDDL()

    • getPlatform

      IDatabasePlatform getPlatform()

    • getTargetPlatform

      IDatabasePlatform getTargetPlatform()

    • getTargetPlatform

      IDatabasePlatform getTargetPlatform(String tableName)

    • getName

      String getName()

    • getVersion

      String getVersion()

    • getMajorVersion

      int getMajorVersion()

    • getMinorVersion

      int getMinorVersion()

    • getProductVersion

      String getProductVersion()

    • getBinaryEncoding

      BinaryEncoding getBinaryEncoding()

    • getTransactionTriggerExpression

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

    • getTransactionId

      String getTransactionId(ISqlTransaction transaction)

    • createInitialLoadSqlFor

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

    • getColumnPositionUsingTemplate

      boolean[] getColumnPositionUsingTemplate(Table originalTable, TriggerHistory triggerHistory)

    • createPurgeSqlFor

      String createPurgeSqlFor(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory)

    • createPurgeSqlFor

      String createPurgeSqlFor(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory, List<TransformService.TransformTableNodeGroupLink> transforms)

    • createPurgeSqlFor

      String createPurgeSqlFor(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory, List<TransformService.TransformTableNodeGroupLink> transforms, String deleteSql)

    • createPurgeSqlForMultipleTables

      List<String> createPurgeSqlForMultipleTables(Node node, TriggerRouter triggerRouter, TriggerHistory triggerHistory, List<TransformService.TransformTableNodeGroupLink> transforms, String deleteSql)

    • createCsvDataSql

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

    • createCsvPrimaryKeySql

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

    • getMaxTriggerNameLength

      int getMaxTriggerNameLength()

    • supportsTransactionId

      boolean supportsTransactionId()

    • supportsTransactionViews

      boolean supportsTransactionViews()

    • supportsSubselectsInDelete

      boolean supportsSubselectsInDelete()

    • supportsSubselectsInUpdate

      boolean supportsSubselectsInUpdate()

    • supportsDdlTriggers

      boolean supportsDdlTriggers()

    • cleanDatabase

      void cleanDatabase()

    • disableSyncTriggers

      @Deprecated void disableSyncTriggers(ISqlTransaction transaction)
      Deprecated.

    • disableSyncTriggers

      void disableSyncTriggers(ISqlTransaction transaction, String nodeId)

    • enableSyncTriggers

      void enableSyncTriggers(ISqlTransaction transaction)

    • getSyncTriggersExpression

      String getSyncTriggersExpression()

    • getSyncTriggersOnIncomingExpression

      String getSyncTriggersOnIncomingExpression()

    • getSourceNodeExpression

      String getSourceNodeExpression()

    • getCreateSymmetricDDL

      String getCreateSymmetricDDL()

    • isBlobSyncSupported

      boolean isBlobSyncSupported()

    • isClobSyncSupported

      boolean isClobSyncSupported()

    • isTransactionIdOverrideSupported

      boolean isTransactionIdOverrideSupported()

    • insertWithGeneratedKey

      long insertWithGeneratedKey(String sql, SequenceIdentifier sequenceId)

    • insertWithGeneratedKey

      long insertWithGeneratedKey(String sql, SequenceIdentifier identifier, Object... args)

    • orderColumns

      @Deprecated Column[] orderColumns(String[] columnNames, Table table)
      Deprecated.

    • supportsOpenCursorsAcrossCommit

      boolean supportsOpenCursorsAcrossCommit()

    • getSqlKeywords

      Set<String> getSqlKeywords()

    • getInitialLoadTableAlias

      String getInitialLoadTableAlias()

    • preProcessTriggerSqlClause

      String preProcessTriggerSqlClause(String sqlClause)

    • truncateTable

      void truncateTable(String tableName)

    • getDatabaseTimeSQL

      String getDatabaseTimeSQL()

    • getDatabaseTime

      long getDatabaseTime()

    • areDatabaseTransactionsPendingSince

      boolean areDatabaseTransactionsPendingSince(long time)

    • getEarliestTransactionStartTime

      Date getEarliestTransactionStartTime()

    • needsToSelectLobData

      boolean needsToSelectLobData()

    • getDataHasChangedCondition

      String getDataHasChangedCondition(Trigger trigger)

    • canGapsOccurInCapturedDataIds

      boolean canGapsOccurInCapturedDataIds()

    • massageDataExtractionSql

      String massageDataExtractionSql(String sql, boolean isContainsBigLob)

    • massageForLob

      String massageForLob(String sql, boolean isContainsBigLob)

    • isInitialLoadTwoPassLob

      boolean isInitialLoadTwoPassLob(Table table)

    • getInitialLoadTwoPassLobSql

      String getInitialLoadTwoPassLobSql(String sql, Table table, boolean isFirstPass)

    • escapesTemplatesForDatabaseInserts

      boolean escapesTemplatesForDatabaseInserts()

    • getMasterCollation

      String getMasterCollation()

    • supportsBatchUpdates

      boolean supportsBatchUpdates()

    • cleanupTriggers

      void cleanupTriggers()

    • getDriverName

      String getDriverName()

    • getDriverVersion

      String getDriverVersion()

    • getSequenceName

      String getSequenceName(SequenceIdentifier identifier)

    • getSequenceKeyName

      String getSequenceKeyName(SequenceIdentifier identifier)

    • getCurrentSequenceValue

      long getCurrentSequenceValue(SequenceIdentifier identifier)

    • getTablePrefix

      String getTablePrefix()

    • readSymmetricSchemaFromXml

      Database readSymmetricSchemaFromXml()

    • getSymmetricDdlChanges

      String getSymmetricDdlChanges()

    • getTemplateNumberPrecisionSpec

      String getTemplateNumberPrecisionSpec()

    • getSqlReplacementTokens

      Map<String,String> getSqlReplacementTokens()

    • getSqlTypeForIds

      int getSqlTypeForIds()

    • getTriggerTemplate

      AbstractTriggerTemplate getTriggerTemplate()

    • getParameterService

      IParameterService getParameterService()

    • setExtensionService

      void setExtensionService(IExtensionService extensionService)

    • getSymTablePermissions

      PermissionType[] getSymTablePermissions()

    • getTargetDialect

      ISymmetricDialect getTargetDialect()

    • getTargetDialect

      ISymmetricDialect getTargetDialect(String tableName)

    • setTargetDialect

      void setTargetDialect(ISymmetricDialect targetDialect)