Package io.deephaven.importers.jdbc

Class GeneralJdbcImporter

java.lang.Object

io.deephaven.importers.GeneralImporter<JdbcFieldWriter>

io.deephaven.importers.jdbc.GeneralJdbcImporter

public class GeneralJdbcImporter
extends GeneralImporter<JdbcFieldWriter>

Import data from a JDBC source.

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.importers.GeneralImporter

GeneralImporter.CacheEntry, GeneralImporter.IntradayPartitionSupplier<Context>

Field Summary

Fields inherited from class io.deephaven.importers.GeneralImporter

customImportProperties, importTableWriterFactory, intradayPartitionColumn, strict

Constructor Summary

Constructors

Constructor	Description
GeneralJdbcImporter(Logger log, ImportTableWriterFactory importTableWriterFactory, String intradayPartitionColumn, io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement, String driver, String connectionUrl, String user, String password, String catalog, TimeZone sourceTimeZone, String query, JdbcFieldWriter.Factory factory, boolean strict, io.deephaven.shadow.enterprise.com.illumon.util.progress.StatusCallback progress)
GeneralJdbcImporter(Logger log, ImportTableWriterFactory importTableWriterFactory, String intradayPartitionColumn, io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement, TimeZone sourceTimeZone, ResultSet resultSet, JdbcFieldWriter.Factory factory, boolean strict, io.deephaven.shadow.enterprise.com.illumon.util.progress.StatusCallback progress)

Method Summary

Modifier and Type	Method	Description
JdbcFieldWriter	buildEndOfRecordFieldWriter(io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.TableWriter tableWriter)
Function<io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.RowSetter,JdbcFieldWriter>	buildFieldWriterFactory(ImporterColumnDefinition column, Class setterType, Map<String,String> importProperties, String actualPartition)
Map<String,ImporterColumnDefinition>	getColumnDefinitions()
long	run()	Execute the import with no limit to the number of rows imported as specified.
long	run(long maxRows)	Execute the import, limiting the number of rows imported as specified.

Methods inherited from class io.deephaven.importers.GeneralImporter

closeAllWriters, getImportTableWriterFactory, getMaxOpenTableWriters, getTableEntry, setMaxOpenTableWriters

Methods inherited from class java.lang.Object

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

Constructor Details

GeneralJdbcImporter

public GeneralJdbcImporter(Logger log,
 ImportTableWriterFactory importTableWriterFactory,
 String intradayPartitionColumn,
 io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement,
 String driver,
 String connectionUrl,
 String user,
 String password,
 String catalog,
 TimeZone sourceTimeZone,
 String query,
 JdbcFieldWriter.Factory factory,
 boolean strict,
 io.deephaven.shadow.enterprise.com.illumon.util.progress.StatusCallback progress)

GeneralJdbcImporter

public GeneralJdbcImporter(Logger log,
 ImportTableWriterFactory importTableWriterFactory,
 String intradayPartitionColumn,
 io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement,
 TimeZone sourceTimeZone,
 ResultSet resultSet,
 JdbcFieldWriter.Factory factory,
 boolean strict,
 io.deephaven.shadow.enterprise.com.illumon.util.progress.StatusCallback progress)

Method Details

getColumnDefinitions

public Map<String,ImporterColumnDefinition> getColumnDefinitions()

Specified by:

getColumnDefinitions in class GeneralImporter<JdbcFieldWriter>

buildFieldWriterFactory

public Function<io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.RowSetter,JdbcFieldWriter> buildFieldWriterFactory(ImporterColumnDefinition column,
 Class setterType,
 Map<String,String> importProperties,
 String actualPartition)

Specified by:

buildFieldWriterFactory in class GeneralImporter<JdbcFieldWriter>

buildEndOfRecordFieldWriter

public JdbcFieldWriter buildEndOfRecordFieldWriter(io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.TableWriter tableWriter)

Specified by:

buildEndOfRecordFieldWriter in class GeneralImporter<JdbcFieldWriter>

run

public long run()

Execute the import with no limit to the number of rows imported as specified.

Returns:

the number of rows imported

run

public long run(long maxRows)

Execute the import, limiting the number of rows imported as specified. If a number less than zero is given, no limit is imposed.

Parameters:

maxRows - maximum number of rows to import

Returns:

the number of rows imported