Package com.nt.udc.oi.node.jdbc

Class DBInserter

java.lang.Object

com.nt.udc.oi.node.jdbc.DBInserter

All Implemented Interfaces:

DBUpdaterIfc

Direct Known Subclasses:

DBBatchInserter, DBSingularInserter

public abstract class DBInserter
extends Object
implements DBUpdaterIfc

Field Summary

Fields

Modifier and Type	Field	Description
protected int	badRecCount
protected String	badRecDir
protected File	badRecFile
protected File	badRecNarFile
protected Connection	dbConn
protected String	errMesg
protected FileOutputStream	fos
protected boolean	healthy
protected Hashtable	inserts
protected int	invalidRecCount
protected Hashtable	lobData
protected LoggerIfc	logger
protected static final int	MAX_BAD_RECORDS_PER_FILE
protected static final String	RECORD_SEPARATOR
protected List<String>	reservedColumnList
protected List<List<String>>	reservedNamesList
protected List<String>	reservedTableList
protected Hashtable	tableColumns
protected PrintWriter	writer

Constructor Summary

Constructors

Constructor	Description
DBInserter(Connection dbConn, Hashtable tableColumns, Hashtable lobData, List<List<String>> reservedNamesList, LoggerIfc logger)

Method Summary

Modifier and Type	Method	Description
void	buildStatements()
protected boolean	checkColumn(JDBCOIRecord rec, String tbl, String[] col, int colIdx)
abstract boolean	isHealthy()
void	resetConnection(Connection dbConn)
protected boolean	setColumnValue(JDBCOIRecord rec, String tbl, String[] col, int colIdx)
void	shutdown()
abstract void	updateDB(JDBCOIRecord[] records)
protected void	writeBadRecord(JDBCOIRecord rec)
protected void	writeBadRecordNar(JDBCOIRecord rec)

Methods inherited from class java.lang.Object

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

Field Details

dbConn

protected Connection dbConn

tableColumns

protected Hashtable tableColumns

lobData

protected Hashtable lobData

reservedColumnList

protected List<String> reservedColumnList

reservedTableList

protected List<String> reservedTableList

reservedNamesList

protected List<List<String>> reservedNamesList

logger

protected LoggerIfc logger

inserts

protected Hashtable inserts

errMesg

protected String errMesg

healthy

protected boolean healthy

invalidRecCount

protected int invalidRecCount

badRecDir

protected String badRecDir

badRecFile

protected File badRecFile

badRecNarFile

protected File badRecNarFile

writer

protected PrintWriter writer

badRecCount

protected int badRecCount

fos

protected FileOutputStream fos

RECORD_SEPARATOR

protected static final String RECORD_SEPARATOR

See Also:

• Constant Field Values

MAX_BAD_RECORDS_PER_FILE

protected static final int MAX_BAD_RECORDS_PER_FILE

See Also:

• Constant Field Values

Constructor Details

DBInserter

public DBInserter(Connection dbConn,
 Hashtable tableColumns,
 Hashtable lobData,
 List<List<String>> reservedNamesList,
 LoggerIfc logger)

Method Details

resetConnection

public void resetConnection(Connection dbConn)

Specified by:

resetConnection in interface DBUpdaterIfc

buildStatements

public void buildStatements()
                     throws SQLException

Specified by:

buildStatements in interface DBUpdaterIfc

Throws:

SQLException

updateDB

public abstract void updateDB(JDBCOIRecord[] records)

Specified by:

updateDB in interface DBUpdaterIfc

isHealthy

public abstract boolean isHealthy()

Specified by:

isHealthy in interface DBUpdaterIfc

checkColumn

protected boolean checkColumn(JDBCOIRecord rec,
 String tbl,
 String[] col,
 int colIdx)

setColumnValue

protected boolean setColumnValue(JDBCOIRecord rec,
 String tbl,
 String[] col,
 int colIdx)
                          throws SQLException

Throws:

SQLException

writeBadRecord

protected void writeBadRecord(JDBCOIRecord rec)

writeBadRecordNar

protected void writeBadRecordNar(JDBCOIRecord rec)

shutdown

public void shutdown()

Specified by:

shutdown in interface DBUpdaterIfc