public abstract class AbstractTable
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected BulkSQLLoader |
bulkLoader |
protected ConnectionConfig |
connectionConfig |
protected java.lang.String[] |
fieldNames |
protected java.lang.String |
schemaName |
protected java.lang.String |
tableName |
Constructor and Description |
---|
AbstractTable(ConnectionConfig connectionConfig,
java.lang.String schemaName,
java.lang.String tableName,
java.lang.String... fieldNames) |
Modifier and Type | Method and Description |
---|---|
protected void |
addForeignKey(java.lang.String localColumn,
AbstractTable foreignTable,
java.lang.String foreignColumn) |
void |
flushInserts() |
protected void |
insertRecord(java.lang.Object... values) |
protected boolean |
tableExists() |
protected ConnectionConfig connectionConfig
protected java.lang.String tableName
protected java.lang.String schemaName
protected BulkSQLLoader bulkLoader
protected java.lang.String[] fieldNames
public AbstractTable(ConnectionConfig connectionConfig, java.lang.String schemaName, java.lang.String tableName, java.lang.String... fieldNames) throws java.rmi.RemoteException
java.rmi.RemoteException
protected boolean tableExists() throws java.rmi.RemoteException
java.rmi.RemoteException
protected void addForeignKey(java.lang.String localColumn, AbstractTable foreignTable, java.lang.String foreignColumn) throws java.rmi.RemoteException
java.rmi.RemoteException
protected void insertRecord(java.lang.Object... values) throws java.rmi.RemoteException, java.sql.SQLException
java.rmi.RemoteException
java.sql.SQLException
public void flushInserts() throws java.rmi.RemoteException, java.sql.SQLException
java.rmi.RemoteException
java.sql.SQLException