Notes

String query = "SELECT * FROM ram_request_detail WHERE cron_date>=DATE(NOW()) AND cron_time>=NOW() AND agent_number=4";
HRPreparedStatement hps = null;
ResultSet rs = null;
try {
hps =new HRPreparedStatement(con, query);
rs = hps.executeQuery();
while (rs.next()) {
ScheduledEntry entry = new ScheduledEntry();
entry.setRamId(rs.getInt("ram_request_id"));
entry.setId(rs.getInt("scheduled_agent_id"));
entry.setConfig(rs.getString("config"));
entry.setCronExpression(rs.getString("cron_expression"));
entry.setProcessor(Processor.valueOf(rs.getString("processor")));
entries.add(entry);
}
} catch (Exception e) {
LOG.error("Unable to execute the query in getRamEntries method:"+e.getMessage(),e);
} finally {
Util.close(null, hps, rs);
}
return entries;
}


public static ScheduledEntry getEntryById(int id1){
// Connection con = dbHelper.getDBConnection();
Session session = null;
Connection con = null;
String sql = "select scheduled_agent_id, processor, config from scheduled_agent where scheduled_agent_id="+id1;
PreparedStatement ps = null;
ResultSet rs = null;
ScheduledEntry entry = new ScheduledEntry();
try{
session = BaseHelper.getDBSession();
con = SessionUtil.getDBConnection(session);
ps = con.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
rs = ps.executeQuery();

if(rs.next()){
int id = rs.getInt("scheduled_agent_id");
String processor = rs.getString("processor");
String config = rs.getString("config");
try{
Processor p = Processor.valueOf(processor);

entry.setProcessor(p);
entry.setId(id);
populateEntry(entry, config, con);
populateLatesDates(entry, con);
}catch (Exception e) {
LOG.error(e.getMessage(),e);
}
}
}catch (Exception e) {
LOG.error("MyAgentLauncher::SQLException:"+e.getMessage(),e);
}finally{
Util.close(con,ps,rs);
Util.closeSession(session);
}
return entry;
}

// /*public static boolean isRunning(int id){
// return currentlyRunning.contains(String.valueOf(id));
// }*/
private static List<ScheduledEntry> getScheduledEntries(){
List<ScheduledEntry> entries = new ArrayList<>();
// DBHelper dbHelper = new DBHelper();
// Connection con = dbHelper.getDBConnection();
Session session = null;
Connection con = null;
String sql = "select scheduled_agent_id, processor, cron_expression, config from scheduled_agent";
PreparedStatement ps = null;
ResultSet rs = null;
try{
session = BaseHelper.getDBSession();
con = SessionUtil.getDBConnection(session);
ps = con.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
rs = ps.executeQuery();

while(rs.next()){
int id = rs.getInt("scheduled_agent_id");
String processor = rs.getString("processor");
String cronExpression = rs.getString("cron_expression");
String config = rs.getString("config");
ScheduledEntry entry = new ScheduledEntry();
Processor p =null;
if(processor != null && processor.trim().length()!=0){
try{
p = Processor.valueOf(processor);
}catch (Exception e) {
e.printStackTrace();
}
}
entry.setProcessor(p);
entry.setId(id);
entry.setCronExpression(cronExpression);
populateEntry(entry, config, con);
populateLatesDates(entry, con);
entries.add(entry);
}
}catch (Exception e) {
LOG.error("MyAgentLauncher::SQLException:"+e.getMessage(),e);
}finally{
Util.close(con,ps,rs);
Util.closeSession(session);
}
LOG.debug(entries.size());
return entries;
}


private static void populateEntry(ScheduledEntry entry, String confStr,
Connection con) throws IOException {
String config = confStr;
if(config == null){
config="";
}