Class DbImport

java.lang.Object
org.jumpmind.symmetric.io.data.DbImport

public class DbImport extends Object
Import data from file to database tables.
  • Field Details

  • Constructor Details

    • DbImport

      public DbImport()
    • DbImport

      public DbImport(IDatabasePlatform symmetricPlatform)
  • Method Details

    • importTables

      public void importTables(String importData, String tableName)
    • importTables

      public void importTables(String importData)
    • importTables

      public void importTables(InputStream in)
    • importTables

      public void importTables(InputStream in, String tableName)
    • buildConflictSettings

      protected Conflict buildConflictSettings()
    • buildDatabaseWriterSettings

      protected DatabaseWriterSettings buildDatabaseWriterSettings()
    • importTablesFromCsv

      protected void importTablesFromCsv(InputStream in, String tableName)
    • importTablesFromCsvDquote

      protected void importTablesFromCsvDquote(InputStream in, String tableName)
    • importTablesFromXml

      protected void importTablesFromXml(InputStream in)
    • importTablesFromSymXml

      protected void importTablesFromSymXml(InputStream in)
    • importTablesFromSql

      protected void importTablesFromSql(InputStream in)
    • getFormat

      public DbImport.Format getFormat()
    • setFormat

      public void setFormat(DbImport.Format format)
    • getCatalog

      public String getCatalog()
    • setCatalog

      public void setCatalog(String catalog)
    • getSchema

      public String getSchema()
    • setSchema

      public void setSchema(String schema)
    • setIgnoreMissingTables

      public void setIgnoreMissingTables(boolean ignoreMissingTables)
    • isIgnoreMissingTables

      public boolean isIgnoreMissingTables()
    • setCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired

      public void setCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired(boolean createIndexConvertUniqueToNonuniqueWhenColumnsNotRequired)
    • isCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired

      public boolean isCreateIndexConvertUniqueToNonuniqueWhenColumnsNotRequired()
    • isUseVariableDates

      public boolean isUseVariableDates()
    • setUseVariableForDates

      public void setUseVariableForDates(boolean useVariableDates)
    • setAlterCaseToMatchDatabaseDefaultCase

      public void setAlterCaseToMatchDatabaseDefaultCase(boolean alterCaseToMatchDatabaseDefaultCase)
    • isAlterCaseToMatchDatabaseDefaultCase

      public boolean isAlterCaseToMatchDatabaseDefaultCase()
    • setCommitRate

      public void setCommitRate(long commitRate)
    • getCommitRate

      public long getCommitRate()
    • setForceImport

      public void setForceImport(boolean forceImport)
    • isForceImport

      public boolean isForceImport()
    • setIgnoreCollisions

      public void setIgnoreCollisions(boolean ignoreConflicts)
    • isIgnoreCollisions

      public boolean isIgnoreCollisions()
    • setReplaceRows

      public void setReplaceRows(boolean replaceRows)
    • isReplaceRows

      public boolean isReplaceRows()
    • setAlterTables

      public void setAlterTables(boolean alterTables)
    • isAlterTables

      public boolean isAlterTables()
    • setDropIfExists

      public void setDropIfExists(boolean dropIfExists)
    • isDropIfExists

      public boolean isDropIfExists()
    • addDatabaseWriterFilter

      public void addDatabaseWriterFilter(IDatabaseWriterFilter filter)
    • removeDatabaseWriterFilter

      public void removeDatabaseWriterFilter(IDatabaseWriterFilter filter)
    • getInterval

      public int getInterval()
    • setInterval

      public void setInterval(int interval)