Package org.jumpmind.symmetric.io.data.writer

Class DatabaseWriterSettings

java.lang.Object
org.jumpmind.symmetric.io.data.writer.DatabaseWriterSettings
public class DatabaseWriterSettings extends Object

  • Field Details

    • maxRowsBeforeCommit

      protected long maxRowsBeforeCommit

    • commitSleepInterval

      protected long commitSleepInterval

    • treatDateTimeFieldsAsVarchar

      protected boolean treatDateTimeFieldsAsVarchar

    • treatBitFieldsAsInteger

      protected boolean treatBitFieldsAsInteger

    • usePrimaryKeysFromSource

      protected boolean usePrimaryKeysFromSource

    • defaultConflictSetting

      protected Conflict defaultConflictSetting

    • createTableFailOnError

      protected boolean createTableFailOnError

    • alterTable

      protected boolean alterTable

    • createTableDropFirst

      protected boolean createTableDropFirst

    • applyChangesOnly

      protected boolean applyChangesOnly

    • createTableAlterCaseToMatchDatabaseDefault

      protected boolean createTableAlterCaseToMatchDatabaseDefault

    • createTableWithoutDefaultsOnError

      protected boolean createTableWithoutDefaultsOnError

    • ignoreMissingTables

      protected boolean ignoreMissingTables

    • saveCurrentValueOnError

      protected boolean saveCurrentValueOnError

    • fitToColumn

      protected boolean fitToColumn

    • autoResolveForeignKeyViolationDelete

      protected boolean autoResolveForeignKeyViolationDelete

    • autoResolvePrimaryKeyViolation

      protected boolean autoResolvePrimaryKeyViolation

    • autoResolveUniqueIndexViolation

      protected boolean autoResolveUniqueIndexViolation

    • autoResolveUniqueIndexIgnoreNullValues

      protected boolean autoResolveUniqueIndexIgnoreNullValues

    • autoResolveCaptureDeleteMissingRows

      protected boolean autoResolveCaptureDeleteMissingRows

    • logConflictResolution

      protected boolean logConflictResolution

    • logSqlParamsOnError

      protected boolean logSqlParamsOnError

    • textColumnExpression

      protected String textColumnExpression

    • conflictSettingsByChannel

      protected Map<String,Conflict> conflictSettingsByChannel

    • conflictSettingsByTable

      protected Map<String,Conflict> conflictSettingsByTable

    • databaseWriterFilters

      protected List<IDatabaseWriterFilter> databaseWriterFilters

    • databaseWriterErrorHandlers

      protected List<IDatabaseWriterErrorHandler> databaseWriterErrorHandlers

    • resolvedData

      protected List<ResolvedData> resolvedData

    • alterDatabaseInterceptors

      protected IAlterDatabaseInterceptor[] alterDatabaseInterceptors

    • conflictLosingParentRows

      protected Set<String> conflictLosingParentRows

    • ignoreSqlDataEventFailures

      protected boolean ignoreSqlDataEventFailures

    • createIndexConvertUniqueToNonuniqueWhenColumnsNotRequired

      protected boolean createIndexConvertUniqueToNonuniqueWhenColumnsNotRequired

    • stripOutCommentsInScripts

      protected boolean stripOutCommentsInScripts

    • runtimeConfigTriggerPrefix

      protected String runtimeConfigTriggerPrefix

    • createTableIncludeApplicationTriggers

      protected boolean createTableIncludeApplicationTriggers

    • keepBulkStagingFiles

      protected boolean keepBulkStagingFiles

    • msSqlBulkLoadBcpCodePage

      protected String msSqlBulkLoadBcpCodePage

  • Constructor Details

    • DatabaseWriterSettings

      public DatabaseWriterSettings()

  • Method Details

    • setAlterDatabaseInterceptors

      public void setAlterDatabaseInterceptors(IAlterDatabaseInterceptor[] alterDatabaseInterceptors)

    • getAlterDatabaseInterceptors

      public IAlterDatabaseInterceptor[] getAlterDatabaseInterceptors()

    • isAlterTable

      public boolean isAlterTable()

    • setAlterTable

      public void setAlterTable(boolean alterTable)

    • isCreateTableDropFirst

      public boolean isCreateTableDropFirst()

    • setCreateTableDropFirst

      public void setCreateTableDropFirst(boolean createTableDropFirst)

    • isCreateTableFailOnError

      public boolean isCreateTableFailOnError()

    • setCreateTableFailOnError

      public void setCreateTableFailOnError(boolean createTableFailOnError)

    • getMaxRowsBeforeCommit

      public long getMaxRowsBeforeCommit()

    • setMaxRowsBeforeCommit

      public void setMaxRowsBeforeCommit(long maxRowsBeforeCommit)

    • isTreatDateTimeFieldsAsVarchar

      public boolean isTreatDateTimeFieldsAsVarchar()

    • setTreatDateTimeFieldsAsVarchar

      public void setTreatDateTimeFieldsAsVarchar(boolean treatDateTimeFieldsAsVarchar)

    • isTreatBitFieldsAsInteger

      public boolean isTreatBitFieldsAsInteger()

    • setTreatBitFieldsAsInteger

      public void setTreatBitFieldsAsInteger(boolean treatBitFieldsAsInteger)

    • isUsePrimaryKeysFromSource

      public boolean isUsePrimaryKeysFromSource()

    • setUsePrimaryKeysFromSource

      public void setUsePrimaryKeysFromSource(boolean usePrimaryKeysFromSource)

    • getDefaultConflictSetting

      public Conflict getDefaultConflictSetting()

    • setDefaultConflictSetting

      public void setDefaultConflictSetting(Conflict defaultConflictSetting)

    • isCreateTableAlterCaseToMatchDatabaseDefault

      public boolean isCreateTableAlterCaseToMatchDatabaseDefault()

    • setCreateTableAlterCaseToMatchDatabaseDefault

      public void setCreateTableAlterCaseToMatchDatabaseDefault(boolean createTableAlterCaseToMatchDatabaseDefault)

    • isCreateTableWithoutDefaultsOnError

      public boolean isCreateTableWithoutDefaultsOnError()

    • setCreateTableWithoutDefaultsOnError

      public void setCreateTableWithoutDefaultsOnError(boolean createTableWithoutDefaultsOnError)

    • getConflictSettingsByChannel

      public Map<String,Conflict> getConflictSettingsByChannel()

    • setConflictSettingsByChannel

      public void setConflictSettingsByChannel(Map<String,Conflict> conflictSettingsByChannel)

    • getConflictSettingsByTable

      public Map<String,Conflict> getConflictSettingsByTable()

    • setConflictSettingsByTable

      public void setConflictSettingsByTable(Map<String,Conflict> conflictSettingsByTable)

    • getDatabaseWriterFilters

      public List<IDatabaseWriterFilter> getDatabaseWriterFilters()

    • setDatabaseWriterFilters

      public void setDatabaseWriterFilters(List<IDatabaseWriterFilter> databaseWriterFilters)

    • setResolvedData

      public void setResolvedData(ResolvedData... resolvedData)

    • setResolvedData

      public void setResolvedData(List<ResolvedData> resolvedData)

    • getResolvedData

      public List<ResolvedData> getResolvedData()

    • setDatabaseWriterErrorHandlers

      public void setDatabaseWriterErrorHandlers(List<IDatabaseWriterErrorHandler> databaseWriterErrorHandlers)

    • getDatabaseWriterErrorHandlers

      public List<IDatabaseWriterErrorHandler> getDatabaseWriterErrorHandlers()

    • getResolvedData

      public ResolvedData getResolvedData(long rowNumber)

    • setIgnoreMissingTables

      public void setIgnoreMissingTables(boolean ignoreMissingTables)

    • isIgnoreMissingTables

      public boolean isIgnoreMissingTables()

    • addErrorHandler

      public void addErrorHandler(IDatabaseWriterErrorHandler handler)

    • pickConflict

      public Conflict pickConflict(Table table, Batch batch)

    • getCommitSleepInterval

      public long getCommitSleepInterval()

    • setCommitSleepInterval

      public void setCommitSleepInterval(long commitSleepInterval)

    • isSaveCurrentValueOnError

      public boolean isSaveCurrentValueOnError()

    • setSaveCurrentValueOnError

      public void setSaveCurrentValueOnError(boolean saveCurrentValueOnError)

    • setFitToColumn

      public void setFitToColumn(boolean fitToColumn)

    • isFitToColumn

      public boolean isFitToColumn()

    • isAutoResolveForeignKeyViolationDelete

      public boolean isAutoResolveForeignKeyViolationDelete()

    • setAutoResolveForeignKeyViolationDelete

      public void setAutoResolveForeignKeyViolationDelete(boolean autoResolveForeignKeyViolationDelete)

    • isAutoResolvePrimaryKeyViolation

      public boolean isAutoResolvePrimaryKeyViolation()

    • setAutoResolvePrimaryKeyViolation

      public void setAutoResolvePrimaryKeyViolation(boolean autoResolvePrimaryKeyViolation)

    • isAutoResolveUniqueIndexViolation

      public boolean isAutoResolveUniqueIndexViolation()

    • setAutoResolveUniqueIndexViolation

      public void setAutoResolveUniqueIndexViolation(boolean autoResolveUniqueIndexViolation)

    • isAutoResolveUniqueIndexIgnoreNullValues

      public boolean isAutoResolveUniqueIndexIgnoreNullValues()

    • setAutoResolveUniqueIndexIgnoreNullValues

      public void setAutoResolveUniqueIndexIgnoreNullValues(boolean autoResolveUniqueIndexIgnoreNullValues)

    • isAutoResolveCaptureDeleteMissingRows

      public boolean isAutoResolveCaptureDeleteMissingRows()

    • setAutoResolveCaptureDeleteMissingRows

      public void setAutoResolveCaptureDeleteMissingRows(boolean autoResolveCaptureDeleteMissingRows)

    • setLogConflictResolution

      public void setLogConflictResolution(boolean logConflictResolution)

    • isLogConflictResolution

      public boolean isLogConflictResolution()

    • setLogSqlParamsOnError

      public void setLogSqlParamsOnError(boolean logSqlParamsOnError)

    • isLogSqlParamsOnError

      public boolean isLogSqlParamsOnError()

    • setTextColumnExpression

      public void setTextColumnExpression(String textColumnExpression)

    • getTextColumnExpression

      public String getTextColumnExpression()

    • setApplyChangesOnly

      public void setApplyChangesOnly(boolean applyChangesOnly)

    • isApplyChangesOnly

      public boolean isApplyChangesOnly()

    • getConflictLosingParentRows

      public Set<String> getConflictLosingParentRows()

    • setConflictLosingParentRows

      public void setConflictLosingParentRows(Set<String> conflictLosingParentRows)

    • isIgnoreSqlDataEventFailures

      public boolean isIgnoreSqlDataEventFailures()

    • setIgnoreSqlDataEventFailures

      public void setIgnoreSqlDataEventFailures(boolean ignoreSqlDataEventFailures)

    • isCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired

      public boolean isCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired()

    • setCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired

      public void setCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired(boolean createIndexConvertUniqueToNonuniqueWhenColumnsNotRequired)

    • isStripOutCommentsInScripts

      public boolean isStripOutCommentsInScripts()

    • setStripOutCommentsInScripts

      public void setStripOutCommentsInScripts(boolean stripOutCommentsInScripts)

    • getRuntimeConfigTriggerPrefix

      public String getRuntimeConfigTriggerPrefix()

    • setRuntimeConfigTriggerPrefix

      public void setRuntimeConfigTriggerPrefix(String runtimeConfigTriggerPrefix)

    • isCreateTableIncludeApplicationTriggers

      public boolean isCreateTableIncludeApplicationTriggers()

    • setCreateTableIncludeApplicationTriggers

      public void setCreateTableIncludeApplicationTriggers(boolean createTableIncludeApplicationTriggers)

    • isKeepBulkStagingFiles

      public boolean isKeepBulkStagingFiles()

    • setKeepBulkStagingFiles

      public void setKeepBulkStagingFiles(boolean keepBulkStagingFiles)

    • getMsSqlBulkLoadBcpCodePage

      public String getMsSqlBulkLoadBcpCodePage()

    • setMsSqlBulkLoadBcpCodePage

      public void setMsSqlBulkLoadBcpCodePage(String msSqlBulkLoadBcpCodePage)