Package tilda.loader.csv.stores

Class PostgreSQLCSVImporter

java.lang.Object

tilda.loader.csv.stores.CSVImporter

tilda.loader.csv.stores.PostgreSQLCSVImporter

public class PostgreSQLCSVImporter
extends CSVImporter

Nested Class Summary

Nested classes/interfaces inherited from class tilda.loader.csv.stores.CSVImporter

CSVImporter.Results

Field Summary

Fields inherited from class tilda.loader.csv.stores.CSVImporter

BATCH_SIZE, C, cmsDO, COMMIT_SIZE, LOG, rootFolder

Constructor Summary

Constructors

Constructor	Description
PostgreSQLCSVImporter(Connection C, java.lang.String rootFolder, DataObject cmsDO)

Method Summary

Modifier and Type	Method	Description
protected java.lang.StringBuilder	GenerateSQL(boolean isUpsert, java.lang.String schemaName, java.lang.String tableName, java.lang.String[] columns, java.util.Map<java.lang.String,ColumnMeta> DBColumns, java.lang.String[] uniqueColumns)
protected long	insertData(boolean isUpsert, long t0, java.util.Map<java.lang.String,ColumnMeta> DBColumns, boolean withHeader, java.lang.Iterable<org.apache.commons.csv.CSVRecord> records, java.lang.StringBuilder Str, java.lang.String schemaName, java.lang.String tableName, java.lang.String[] headers, java.lang.String[] columns, java.util.Map<java.lang.String,ColumnHeader> columnMap, java.lang.String[] completeHeaders, java.lang.String[] uniqueColumns, java.lang.String DateTimePattern, java.lang.String DateTimeZoneInfoId, java.lang.String DatePattern)

Methods inherited from class tilda.loader.csv.stores.CSVImporter

createSchemaAndTable, GenerateInsertSQL, HandleFinally, initializeLoaders, isRecordAllNullOrEmpty, process, validateHeaders

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PostgreSQLCSVImporter

public PostgreSQLCSVImporter(Connection C,
                             java.lang.String rootFolder,
                             DataObject cmsDO)

Method Detail

insertData

protected long insertData(boolean isUpsert,
                          long t0,
                          java.util.Map<java.lang.String,ColumnMeta> DBColumns,
                          boolean withHeader,
                          java.lang.Iterable<org.apache.commons.csv.CSVRecord> records,
                          java.lang.StringBuilder Str,
                          java.lang.String schemaName,
                          java.lang.String tableName,
                          java.lang.String[] headers,
                          java.lang.String[] columns,
                          java.util.Map<java.lang.String,ColumnHeader> columnMap,
                          java.lang.String[] completeHeaders,
                          java.lang.String[] uniqueColumns,
                          java.lang.String DateTimePattern,
                          java.lang.String DateTimeZoneInfoId,
                          java.lang.String DatePattern)
                   throws java.lang.Exception

Specified by:

insertData in class CSVImporter

Throws:

java.lang.Exception

GenerateSQL

protected java.lang.StringBuilder GenerateSQL(boolean isUpsert,
                                              java.lang.String schemaName,
                                              java.lang.String tableName,
                                              java.lang.String[] columns,
                                              java.util.Map<java.lang.String,ColumnMeta> DBColumns,
                                              java.lang.String[] uniqueColumns)

Specified by:

GenerateSQL in class CSVImporter