Methods Summary |
---|
public boolean | createTable(java.sql.Connection connection)
super.con = connection;
return super.createTable(
TableInfo.CREATE_TABLE_START_TIME_SQL,
TableInfo.START_TIME_TABLE_NAME);
|
public boolean | dropTable(java.sql.Connection connection)
super.con = connection;
return super.createStatmentAndExecuteUpdate(
TableInfo.DROP_TABLE_START_TIME_SQL,
TableInfo.START_TIME_TABLE_NAME);
|
public java.lang.String | getDeleteSQL()
String newsql = super.updateSqlWithTableName (
TableInfo.DELETE_FROM_TABLE_START_TIME_SQL,
TableInfo.START_TIME_TABLE_NAME);
return newsql;
|
public java.lang.String | getInsertSQL()
String newsql = super.updateSqlWithTableName(
TableInfo.INSERT_INTO_TABLE_START_TIME_SQL,
TableInfo.START_TIME_TABLE_NAME);
return newsql;
|
public static synchronized TableAccessObject | getInstance()
return _singletonST;
|
public boolean | insert(java.sql.PreparedStatement pstmt, TransferObject[] transferObject)
// sanity
if (pstmt == null)
return false;
boolean result = false;
try{
for (int i = 0 ; i<transferObject.length; i++) {
StartTimeTO startTimeTO = (StartTimeTO)transferObject[i];
pstmt.setString(1, startTimeTO.getRequestId());
pstmt.setLong(2, startTimeTO.getTimeStamp());
pstmt.setString(
3, startTimeTO.getContainerTypeOrApplicationType());
pstmt.addBatch();
}
int[] updated = pstmt.executeBatch();
result = (updated.length == transferObject.length)? true : false;
addTotalEntriesProcessed(updated.length);
if (super.isTraceOn()){
logger.log(Level.INFO, "Callflow: StartTimeAccessObjectImpl " +
" Attempting to Insert : " + transferObject.length +
" Inserted "+updated.length+ " rows."+
" Total Entries written so far: "+
getTotalEntriesProcessed());
}
} catch(BatchUpdateException bue) {
// log it
logger.log(Level.FINE, "Error inserting data into CallFlow tables", bue);
result = false;
}catch (SQLException se) {
// log it
logger.log(Level.FINE, "Error inserting data into CallFlow tables", se);
result = false;
}
return result;
|