Methods Summary |
---|
public boolean | createTable(java.sql.Connection connection)
super.con = connection;
return super.createTable(
TableInfo.CREATE_TABLE_METHOD_END_SQL,
TableInfo.METHOD_END_TABLE_NAME);
|
public boolean | dropTable(java.sql.Connection connection)
super.con = connection;
return super.createStatmentAndExecuteUpdate(
TableInfo.DROP_TABLE_METHOD_END_SQL,
TableInfo.METHOD_END_TABLE_NAME);
|
public java.lang.String | getDeleteSQL()
String newsql = super.updateSqlWithTableName (
TableInfo.DELETE_FROM_TABLE_METHOD_END_SQL,
TableInfo.METHOD_END_TABLE_NAME);
return newsql;
|
public java.lang.String | getInsertSQL()
String newsql = super.updateSqlWithTableName(
TableInfo.INSERT_INTO_TABLE_METHOD_END_SQL,
TableInfo.METHOD_END_TABLE_NAME);
return newsql;
|
public static synchronized TableAccessObject | getInstance()
return _singletonME;
|
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++) {
MethodEndTO methodEndTO = (MethodEndTO)transferObject[i];
pstmt.setString(1, methodEndTO.getRequestId());
pstmt.setLong(2, methodEndTO.getTimeStamp());
pstmt.setString(3, methodEndTO.getException());
pstmt.addBatch();
}
int[] updated = pstmt.executeBatch();
result = (updated.length == transferObject.length)? true : false;
addTotalEntriesProcessed(updated.length);
if (isTraceOn()){
logger.log(Level.INFO, "Callflow: MethodEndAccessObjectImpl " +
" 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;
|