in src/main/java/com/amazonaws/fixengineonaws/FixEngine.java [469:491]
private CallableStatement getHeartbeatSprocStmt(String jdbcDriver, String jdbcUrl, String jdbcUser, String jdbcPass) {
LOGGER.fine(MY_IP+"*********************GET HEARTBEAT PROC STATEMENT*********************");
String query = "{CALL EngineStatus(?, ?, ?, ?, ?, ?)}";
loadJdbcClass(jdbcDriver);
LOGGER.fine(MY_IP+"*****GETHEARTBEATPROCSTATEMENT: Making SQL connection");
Connection sqlDbConnection = getSqlDbConnection(jdbcUrl, jdbcUser, jdbcPass);
LOGGER.fine(MY_IP+"*****GETHEARTBEATPROCSTATEMENT: connected to SQL DB");
try {
CallableStatement stmt = sqlDbConnection.prepareCall(query);
stmt.setString(1, MY_IP);
stmt.registerOutParameter(2, java.sql.Types.INTEGER);
stmt.registerOutParameter(3, java.sql.Types.VARCHAR);
stmt.registerOutParameter(4, java.sql.Types.TIMESTAMP);
stmt.registerOutParameter(5, java.sql.Types.TIMESTAMP);
stmt.registerOutParameter(6, java.sql.Types.INTEGER);
LOGGER.fine(MY_IP+"****GETHEARTBEATPROCSTATEMENT: SPROC PREPARED STATEMENT CREATED");
return stmt;
} catch (SQLException e) {
LOGGER.severe(MY_IP+"****GET HEARTBEAT PROC STATEMENT: EXCEPTION: " + e);
e.printStackTrace();
}
return null;
}