Package com.illumon.iris.importers

Class JdbcSchemaCreator

java.lang.Object

com.illumon.iris.importers.JdbcSchemaCreator

public class JdbcSchemaCreator
extends Object

Reads a JDBC result set and attempts to infer column data types and create appropriate schema and importer instructions. Also legalizes column names and adds corresponding ImportColumn entries for translation of column names.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JdbcSchemaCreator.AssessmentMethod
static class	JdbcSchemaCreator.SchemaAssessmentError

Method Summary

Modifier and Type	Method	Description
static String	getTableImportSchema(com.fishlib.io.logger.Logger log, Connection connection, ResultSetMetaData resultSetMetaData, String namespace, String tableName, String groupingColumn, String partitionColumn, String sourceName, ImportStyle importStyle, String sourcePartitionColumn, String outPackage, CasingStyle casingStyle, String replacement, int logFormat, boolean useNanos, int maxError, String arrayDelimiter, Map<String,Class<?>> targetTypeMap)
static String	getTableImportSchema(com.fishlib.io.logger.Logger log, ResultSet resultSet, String namespace, String tableName, String groupingColumn, String partitionColumn, String sourceName, boolean bestFit, JdbcSchemaCreator.AssessmentMethod assessmentMethod, ImportStyle importStyle, String sourcePartitionColumn, String outPackage, CasingStyle casingStyle, String replacement, int logFormat, boolean useNanos, int maxError, String arrayDelimiter, Map<String,Class<?>> targetTypeMap, StatusCallback progress)
static org.jdom2.Document	getTableImportSchemaDocument(com.fishlib.io.logger.Logger log, Connection connection, ResultSetMetaData resultSetMetaData, String namespace, String tableName, String groupingColumn, String partitionColumn, String sourceName, ImportStyle importStyle, String sourcePartitionColumn, String outPackage, CasingStyle casingStyle, String replacement, int logFormat, boolean useNanos, int maxError, String arrayDelimiter, Map<String,Class<?>> targetTypeMap)
static void	main(String... args)	Regular main entry point, used when this module is called from a java command line, or from an IntelliJ run configuration.

Methods inherited from class java.lang.Object

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

Method Details

getTableImportSchema

public static String getTableImportSchema(com.fishlib.io.logger.Logger log, ResultSet resultSet, String namespace, String tableName, String groupingColumn, String partitionColumn, String sourceName, boolean bestFit, JdbcSchemaCreator.AssessmentMethod assessmentMethod, ImportStyle importStyle, String sourcePartitionColumn, String outPackage, CasingStyle casingStyle, String replacement, int logFormat, boolean useNanos, int maxError, String arrayDelimiter, Map<String,Class<?>> targetTypeMap, StatusCallback progress)

getTableImportSchema

public static String getTableImportSchema(com.fishlib.io.logger.Logger log, Connection connection, ResultSetMetaData resultSetMetaData, String namespace, String tableName, String groupingColumn, String partitionColumn, String sourceName, ImportStyle importStyle, String sourcePartitionColumn, String outPackage, CasingStyle casingStyle, String replacement, int logFormat, boolean useNanos, int maxError, String arrayDelimiter, Map<String,Class<?>> targetTypeMap)

getTableImportSchemaDocument

public static org.jdom2.Document getTableImportSchemaDocument(com.fishlib.io.logger.Logger log, Connection connection, ResultSetMetaData resultSetMetaData, String namespace, String tableName, String groupingColumn, String partitionColumn, String sourceName, ImportStyle importStyle, String sourcePartitionColumn, String outPackage, CasingStyle casingStyle, String replacement, int logFormat, boolean useNanos, int maxError, String arrayDelimiter, Map<String,Class<?>> targetTypeMap)

main

public static void main(String... args)

Regular main entry point, used when this module is called from a java command line, or from an IntelliJ run configuration.

Parameters:

args - Varargs list of arguments in Apache CLI format