weave.utils

Class BulkSQLLoader

java.lang.Object

weave.utils.BulkSQLLoader

Direct Known Subclasses:

BulkSQLLoader.BulkSQLLoader_CSV, BulkSQLLoader.BulkSQLLoader_Direct

public abstract class BulkSQLLoader
extends java.lang.Object

Author:

Andy Dufilie

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BulkSQLLoader.BulkSQLLoader_CSV
static class	BulkSQLLoader.BulkSQLLoader_Direct

Field Summary

Fields

Modifier and Type	Field and Description
protected java.sql.Connection	conn
protected java.lang.String[]	fieldNames
protected java.lang.String	schema
protected java.lang.String	table
static java.io.File	temporaryFilesDirectory

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	addRow(java.lang.Object... values)
static void	copyCsvToDatabase(java.sql.Connection conn, java.lang.String csvPath, java.lang.String sqlSchema, java.lang.String sqlTable)
abstract void	flush()
static BulkSQLLoader	newInstance(java.sql.Connection conn, java.lang.String schema, java.lang.String table, java.lang.String[] fieldNames)

Methods inherited from class java.lang.Object

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

Field Detail

temporaryFilesDirectory

public static java.io.File temporaryFilesDirectory

conn

protected java.sql.Connection conn

schema

protected java.lang.String schema

table

protected java.lang.String table

fieldNames

protected java.lang.String[] fieldNames

Method Detail

newInstance

public static BulkSQLLoader newInstance(java.sql.Connection conn,
                        java.lang.String schema,
                        java.lang.String table,
                        java.lang.String[] fieldNames)
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

addRow

public abstract void addRow(java.lang.Object... values)
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

flush

public abstract void flush()
                    throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

copyCsvToDatabase

public static void copyCsvToDatabase(java.sql.Connection conn,
                     java.lang.String csvPath,
                     java.lang.String sqlSchema,
                     java.lang.String sqlTable)
                              throws java.sql.SQLException,
                                     java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException