Package org.jumpmind.symmetric.io.data

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()

    • 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)