com.nt.udc.oi.node.jdbc

Class DBSingularInserter

java.lang.Object

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

com.nt.udc.oi.node.jdbc.DBSingularInserter

All Implemented Interfaces:

DBUpdaterIfc

public class DBSingularInserter
extends DBInserter

Field Summary

Fields

Modifier and Type	Field and Description
protected JDBCOITransport	transport

Fields inherited from class com.nt.udc.oi.node.jdbc.DBInserter

badRecCount, badRecDir, badRecFile, badRecNarFile, dbConn, errMesg, fos, healthy, inserts, invalidRecCount, lobData, logger, MAX_BAD_RECORDS_PER_FILE, RECORD_SEPARATOR, reservedColumnList, reservedNamesList, reservedTableList, tableColumns, writer

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isHealthy()
void	updateDB(JDBCOIRecord[] records)

Methods inherited from class com.nt.udc.oi.node.jdbc.DBInserter

buildStatements, checkColumn, resetConnection, setColumnValue, shutdown, writeBadRecord, writeBadRecordNar

Methods inherited from class java.lang.Object

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

Field Detail

transport

protected JDBCOITransport transport

Constructor Detail

DBSingularInserter

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

Method Detail

updateDB

public void updateDB(JDBCOIRecord[] records)

Specified by:

updateDB in interface DBUpdaterIfc

Specified by:

updateDB in class DBInserter

isHealthy

public boolean isHealthy()

Specified by:

isHealthy in interface DBUpdaterIfc

Specified by:

isHealthy in class DBInserter