oracle.pg.common.loader

Class LoaderUtils

java.lang.Object

oracle.pg.common.loader.LoaderUtils

public class LoaderUtils
extends java.lang.Object

A set of common utilities for parallel data loading

Constructor Summary

Constructors

Constructor and Description
LoaderUtils()

Method Summary

Modifier and Type	Method and Description
static void	createExternalTable(java.lang.String fileName, java.lang.String tableName, java.lang.String szDirectory, java.lang.String[] colNames, java.lang.Class<?>[] colDatatypes, java.sql.Connection conn)
static java.lang.String	createExternalTableFromCSVInputStream(java.io.InputStream is, java.lang.String fileName, java.lang.String szDirectory, char delimiter, java.sql.Connection conn)
static void	createTable(java.lang.String tableName, java.sql.Connection conn, java.lang.String[] pkColNames, java.lang.String[] colNames, java.lang.Class<?>[] dataTypes)
static java.lang.String	getDatatypeAsSQLType(java.lang.Class<?> type) This string values returned from this method MUST match opg_apis.check_col_type in opgapib.sql
static void	loadFileIntoDatabaseDirectory(java.io.BufferedReader br, java.lang.String szDirectory, java.lang.String fileName, java.sql.Connection conn)

Methods inherited from class java.lang.Object

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

Constructor Detail

LoaderUtils

public LoaderUtils()

Method Detail

createExternalTable

public static void createExternalTable(java.lang.String fileName,
                                       java.lang.String tableName,
                                       java.lang.String szDirectory,
                                       java.lang.String[] colNames,
                                       java.lang.Class<?>[] colDatatypes,
                                       java.sql.Connection conn)
                                throws java.io.IOException,
                                       java.sql.SQLException

Throws:

java.io.IOException

java.sql.SQLException

createExternalTableFromCSVInputStream

public static java.lang.String createExternalTableFromCSVInputStream(java.io.InputStream is,
                                                                     java.lang.String fileName,
                                                                     java.lang.String szDirectory,
                                                                     char delimiter,
                                                                     java.sql.Connection conn)
                                                              throws java.io.IOException,
                                                                     java.sql.SQLException

Throws:

java.io.IOException

java.sql.SQLException

createTable

public static void createTable(java.lang.String tableName,
                               java.sql.Connection conn,
                               java.lang.String[] pkColNames,
                               java.lang.String[] colNames,
                               java.lang.Class<?>[] dataTypes)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getDatatypeAsSQLType

public static java.lang.String getDatatypeAsSQLType(java.lang.Class<?> type)

This string values returned from this method MUST match opg_apis.check_col_type in opgapib.sql

loadFileIntoDatabaseDirectory

public static void loadFileIntoDatabaseDirectory(java.io.BufferedReader br,
                                                 java.lang.String szDirectory,
                                                 java.lang.String fileName,
                                                 java.sql.Connection conn)
                                          throws java.sql.SQLException

Throws:

java.sql.SQLException