X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=datadb%2Fcompbio%2Fcassandra%2FCassandraWriter.java;h=c478d6829c756dc9327989bafefb2525b966b0f6;hb=b5adc8392eb68caf1c1b929cbeb86d09adc1ad28;hp=6ee62fd3add4b6421a5389a6c3ff9ea3d46bfbc3;hpb=c4aca39f2d4a49b34e7e0b564450d100f442f3bf;p=proteocache.git diff --git a/datadb/compbio/cassandra/CassandraWriter.java b/datadb/compbio/cassandra/CassandraWriter.java index 6ee62fd..c478d68 100644 --- a/datadb/compbio/cassandra/CassandraWriter.java +++ b/datadb/compbio/cassandra/CassandraWriter.java @@ -67,7 +67,7 @@ public class CassandraWriter { allpredictions += "'" + predictionname + "':'" + prediction + "',"; } String final_prediction = ""; - if (null != allpredictions) { + if (!allpredictions.equals("")) { final_prediction = allpredictions.substring(0, allpredictions.length() - 1); } @@ -79,7 +79,7 @@ public class CassandraWriter { session.execute(com3); } - // update some internal tables + // update some internal query tables String check3 = "SELECT * FROM MainParameters WHERE Name = 'EarliestJobDate';"; ResultSet results3 = session.execute(check3); boolean updateparameter = true; @@ -93,15 +93,15 @@ public class CassandraWriter { + "');"; session.execute(com); } - String check4 = "SELECT * FROM MainParameters WHERE Name = 'TotalNumberOfJobs';"; + String check4 = "SELECT * FROM JobDateInfo WHERE jobday = " + jobtime + ";"; ResultSet results4 = session.execute(check4); updateparameter = true; int njobs = 1; if (!results4.isExhausted()) { Row r = results4.one(); - njobs += Integer.parseInt(r.getString("Value")); + njobs += r.getLong("Total"); } - String com = "INSERT INTO MainParameters " + "(Name, Value)" + " VALUES ('TotalNumberOfJobs','" + String.valueOf(njobs) + "');"; + String com = "INSERT INTO JobDateInfo " + "(jobday, Total)" + " VALUES (" + jobtime + "," + njobs + ");"; session.execute(com); return 1;