Loading src/main/java/it/inaf/oats/vospace/persistence/JobDAO.java +18 −4 Original line number Diff line number Diff line Loading @@ -54,8 +54,22 @@ public class JobDAO { String sql = "INSERT INTO job(job_id, owner_id, job_type, phase, job_info, transfer_details, " + " results, error_message, error_type, error_has_detail, error_detail) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; + " results, error_message, error_type, error_has_detail, error_detail, start_time, end_time) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, "; switch (jobSummary.getPhase()) { case EXECUTING: sql += "NOW(), NULL)"; break; case ERROR: case COMPLETED: case ABORTED: sql += "NOW(), NOW())"; break; default: sql += "NULL, NULL)"; break; } jdbcTemplate.update(sql, ps -> { int i = 0; Loading Loading
src/main/java/it/inaf/oats/vospace/persistence/JobDAO.java +18 −4 Original line number Diff line number Diff line Loading @@ -54,8 +54,22 @@ public class JobDAO { String sql = "INSERT INTO job(job_id, owner_id, job_type, phase, job_info, transfer_details, " + " results, error_message, error_type, error_has_detail, error_detail) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; + " results, error_message, error_type, error_has_detail, error_detail, start_time, end_time) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, "; switch (jobSummary.getPhase()) { case EXECUTING: sql += "NOW(), NULL)"; break; case ERROR: case COMPLETED: case ABORTED: sql += "NOW(), NOW())"; break; default: sql += "NULL, NULL)"; break; } jdbcTemplate.update(sql, ps -> { int i = 0; Loading