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 java.lang.Object
implements DBUpdaterIfc

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
DBInserter(java.sql.Connection dbConn, java.util.Hashtable tableColumns, java.util.Hashtable lobData, java.util.List<java.util.List<java.lang.String>> reservedNamesList, LoggerIfc logger)

Method Summary

Methods

Modifier and Type	Method and Description
void	buildStatements()
protected boolean	checkColumn(JDBCOIRecord rec, java.lang.String tbl, java.lang.String[] col, int colIdx)
abstract boolean	isHealthy()
void	resetConnection(java.sql.Connection dbConn)
protected boolean	setColumnValue(JDBCOIRecord rec, java.lang.String tbl, java.lang.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 Detail

dbConn

protected java.sql.Connection dbConn

tableColumns

protected java.util.Hashtable tableColumns

lobData

protected java.util.Hashtable lobData

reservedColumnList

protected java.util.List<java.lang.String> reservedColumnList

reservedTableList

protected java.util.List<java.lang.String> reservedTableList

reservedNamesList

protected java.util.List<java.util.List<java.lang.String>> reservedNamesList

logger

protected LoggerIfc logger

inserts

protected java.util.Hashtable inserts

errMesg

protected java.lang.String errMesg

healthy

protected boolean healthy

invalidRecCount

protected int invalidRecCount

badRecDir

protected java.lang.String badRecDir

badRecFile

protected java.io.File badRecFile

badRecNarFile

protected java.io.File badRecNarFile

writer

protected java.io.PrintWriter writer

badRecCount

protected int badRecCount

fos

protected java.io.FileOutputStream fos

RECORD_SEPARATOR

protected static final java.lang.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 Detail

DBInserter

public DBInserter(java.sql.Connection dbConn,
          java.util.Hashtable tableColumns,
          java.util.Hashtable lobData,
          java.util.List<java.util.List<java.lang.String>> reservedNamesList,
          LoggerIfc logger)

Method Detail

resetConnection

public void resetConnection(java.sql.Connection dbConn)

Specified by:

resetConnection in interface DBUpdaterIfc

buildStatements

public void buildStatements()
                     throws java.sql.SQLException

Specified by:

buildStatements in interface DBUpdaterIfc

Throws:

java.sql.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,
                  java.lang.String tbl,
                  java.lang.String[] col,
                  int colIdx)

setColumnValue

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

Throws:

java.sql.SQLException

writeBadRecord

protected void writeBadRecord(JDBCOIRecord rec)

writeBadRecordNar

protected void writeBadRecordNar(JDBCOIRecord rec)

shutdown

public void shutdown()

Specified by:

shutdown in interface DBUpdaterIfc