com.splicemachine.db.impl.load

Class Import

java.lang.Object

com.splicemachine.db.vti.VTITemplateBase

com.splicemachine.db.vti.VTITemplate

com.splicemachine.db.impl.load.ImportAbstract

com.splicemachine.db.impl.load.Import

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.ResultSet, java.sql.Wrapper

public class Import
extends ImportAbstract

This class implements import of data from a URL into a table. Import functions provided here in this class shouble be called through Systement Procedures. Import uses VTI , which is supprted only through Systemem procedures mechanism.

Field Summary

Fields inherited from class com.splicemachine.db.impl.load.ImportAbstract

COLUMNNAMEPREFIX, columnNames, columnTypeNames, columnTypeNamesString, columnWidths, controlFileReader, importReadData, importResultSetMetaData, lineNumber, lobsInExtFile, nextRow, noOfColumnsExpected, numberOfColumns, tableColumnTypes, tableColumnTypesStr, udtClasses, udtClassNamesString

Fields inherited from interface java.sql.ResultSet

CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE

Constructor Summary

Constructors

Constructor and Description
Import(java.lang.String inputFileName, java.lang.String columnDelimiter, java.lang.String characterDelimiter, java.lang.String codeset, int noOfColumnsExpected, java.lang.String columnTypes, boolean lobsInExtFile, int importCounter, java.lang.String columnTypeNames, java.lang.String udtClassNamesString) Constructior to Invoke Import from a select statement

Method Summary

Modifier and Type	Method and Description
(package private) ImportReadData	getImportReadData() virtual method from the abstract class
static void	importData(java.sql.Connection connection, java.lang.String schemaName, java.lang.String tableName, java.lang.String insertColumnList, java.lang.String columnIndexes, java.lang.String inputFileName, java.lang.String columnDelimiter, java.lang.String characterDelimiter, java.lang.String tableDefinition, boolean lobsInExtFile) SYSCS_IMPORT_DATA system Procedure from ij or from a Java application invokes this method to perform import to a table from a file.
static void	importTable(java.sql.Connection connection, java.lang.String schemaName, java.lang.String tableName, java.lang.String inputFileName, java.lang.String columnDelimiter, java.lang.String characterDelimiter, java.lang.String tableDefinition, boolean lobsInExtFile) SYSCS_IMPORT_TABLE system Procedure from ij or from a Java application invokes this method to perform import to a table from a file.

Methods inherited from class com.splicemachine.db.impl.load.ImportAbstract

close, destringifyObject, doAllTheWork, getBlob, getBytes, getClob, getCurrentLineNumber, getMetaData, getObject, getRow, getString, importError, loadColumnNames, next, readObject, wasNull

Methods inherited from class com.splicemachine.db.vti.VTITemplate

getBigDecimal, getBigDecimal, getBoolean, getByte, getBytes, getDate, getDouble, getFloat, getInt, getLong, getObject, getShort, getString, getTime, getTimestamp

Methods inherited from class com.splicemachine.db.vti.VTITemplateBase

absolute, afterLast, beforeFirst, cancelRowUpdates, clearWarnings, deleteRow, findColumn, first, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBoolean, getByte, getCharacterStream, getCharacterStream, getClob, getConcurrency, getCursorName, getDate, getDate, getDate, getDouble, getFetchDirection, getFetchSize, getFloat, getHoldability, getInt, getLong, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getRef, getRef, getRowId, getRowId, getShort, getSQLXML, getSQLXML, getStatement, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, isWrapperFor, last, moveToCurrentRow, moveToInsertRow, notImplemented, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, unwrap, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNString, updateNString, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.ResultSet

updateObject, updateObject, updateObject, updateObject

Constructor Detail

Import

public Import(java.lang.String inputFileName,
              java.lang.String columnDelimiter,
              java.lang.String characterDelimiter,
              java.lang.String codeset,
              int noOfColumnsExpected,
              java.lang.String columnTypes,
              boolean lobsInExtFile,
              int importCounter,
              java.lang.String columnTypeNames,
              java.lang.String udtClassNamesString)
       throws java.sql.SQLException

Constructior to Invoke Import from a select statement

Parameters:

inputFileName - The URL of the ASCII file from which import will happen

Throws:

java.lang.Exception - on error

java.sql.SQLException

Method Detail

importTable

public static void importTable(java.sql.Connection connection,
                               java.lang.String schemaName,
                               java.lang.String tableName,
                               java.lang.String inputFileName,
                               java.lang.String columnDelimiter,
                               java.lang.String characterDelimiter,
                               java.lang.String tableDefinition,
                               boolean lobsInExtFile)
                        throws java.sql.SQLException

SYSCS_IMPORT_TABLE system Procedure from ij or from a Java application invokes this method to perform import to a table from a file.

Parameters:

connection - The Derby database connection URL for the database containing the table

schemaName - The name of the schema where table to import exists

tableName - Name of the Table the data has to be imported to.

inputFileName - Name of the file from which data has to be imported.

columnDelimiter - Delimiter that seperates columns in the file

characterDelimiter - Delimiter that is used to quiote non-numeric types

tableDefinition - table definition for the data in the file

lobsInExtFile - true, if the lobs data is stored in an external file, and the reference to it is stored in the main import file.

Throws:

java.sql.SQLException - on errors

importData

public static void importData(java.sql.Connection connection,
                              java.lang.String schemaName,
                              java.lang.String tableName,
                              java.lang.String insertColumnList,
                              java.lang.String columnIndexes,
                              java.lang.String inputFileName,
                              java.lang.String columnDelimiter,
                              java.lang.String characterDelimiter,
                              java.lang.String tableDefinition,
                              boolean lobsInExtFile)
                       throws java.sql.SQLException

SYSCS_IMPORT_DATA system Procedure from ij or from a Java application invokes this method to perform import to a table from a file.

Parameters:

connection - The Derby database connection URL for the database containing the table

schemaName - The name of the schema where table to import exists

tableName - Name of the Table the data has to be imported to.

insertColumnList - Comma Seperated column name list to which data has to be imported from file.eg: 'c2,c2,'c3'.

columnIndexes - Comma sepearted Lit Index of the columns in the file(first column starts at 1). eg: '3 ,4 , 5'

inputFileName - Name of the file from which data has to be imported.

columnDelimiter - Delimiter that seperates columns in the file

characterDelimiter - Delimiter that is used to quiote non-numeric types

tableDefinition - table definition for the data in the file

lobsInExtFile - true, if the lobs data is stored in an external file, and the reference is stored in the main import file.

Throws:

java.sql.SQLException - on errors

getImportReadData

ImportReadData getImportReadData()
                          throws java.lang.Exception

virtual method from the abstract class

Specified by:

getImportReadData in class ImportAbstract

Throws:

java.lang.Exception - on error