Package com.illumon.iris.importers

Class GeneralJdbcImporter

java.lang.Object

com.illumon.iris.importers.GeneralImporter<JdbcFieldWriter>

com.illumon.iris.importers.GeneralJdbcImporter

public class GeneralJdbcImporter
extends GeneralImporter<JdbcFieldWriter>

Jdbc SQL importer class, based off GeneralCsvImporter

Field Summary

Fields inherited from class com.illumon.iris.importers.GeneralImporter

customImportProperties, importTableWriterFactory, intradayPartitionColumn, strict

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
long	run()
long	run(long maxRows)	Execute the import, limiting the number of rows imported as specified.

Methods inherited from class com.illumon.iris.importers.GeneralImporter

getMaxOpenTableWriters, getTableEntry, shouldUseLegacyCsvForImport

Methods inherited from class java.lang.Object

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

Constructor Details

GeneralJdbcImporter

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

GeneralJdbcImporter

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

Method Details

run

public long run()

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