+ Row row = results.one();
+ long njobs = row.getLong("Total") -1 ;
+ if (status.equals("OK")) {
+ long njobsOK = row.getLong("TotalOK") - 1;
+ String com1 = "DELETE FROM ProteinRow WHERE JobID = '" + jobid + "';";
+ System.out.println("Command: " + com1);
+ session.execute(com1);
+ String com2 = "DELETE FROM ProteinData WHERE JobID = '" + jobid + "' AND jobtime = " + date + ";";
+ System.out.println("Command: " + com2);
+ session.execute(com2);
+ UpdateJobDateInfo(date, "TotalOK", njobsOK, njobs);
+ } else {
+ String com6 = "DELETE FROM FailLog WHERE JobID = '" + jobid + "' AND jobtime = " + date + ";";
+ System.out.println("Command: " + com6);
+ session.execute(com6);
+ if (status.equals("STOPPED")) {
+ long njobsStopped = row.getLong("TotalStopped") - 1;
+ UpdateJobDateInfo(date, "TotalStopped", njobsStopped, njobs);
+ } else if (status.equals("ERROR")) {
+ long njobsError = row.getLong("TotalError") - 1;
+ UpdateJobDateInfo(date, "TotalError", njobsError, njobs);
+ } else if (status.equals("TIMEDOUT")) {
+ long njobsTimeOut = row.getLong("TotalTimeOut") - 1;
+ UpdateJobDateInfo(date, "TotalTimeOut", njobsTimeOut, njobs);
+ }
+ }
+ System.out.println("Remove jobs: " + jobid);
+ }
+
+ private void UpdateJobDateInfo(long date, String ColumnName, long totalcol, long total) {
+ String com4 = "UPDATE JobDateInfo SET " + ColumnName + " = " + totalcol + ", Total = " + total + " WHERE jobday = " + date + ";";