inserted 2 columns: version and pragramme name

[proteocache.git] / datadb / compbio / cassandra / CassandraNewTableWriter.java

diff --git a/datadb/compbio/cassandra/CassandraNewTableWriter.java b/datadb/compbio/cassandra/CassandraNewTableWriter.java
index 0d68b1a..6cb9c98 100644 (file)
--- a/datadb/compbio/cassandra/CassandraNewTableWriter.java
+++ b/datadb/compbio/cassandra/CassandraNewTableWriter.java
@@ -2,6 +2,7 @@ package compbio.cassandra;
 
 import java.util.Calendar;
 import java.util.Date;
+import java.util.List;
 
 import org.apache.log4j.Logger;
 
@@ -44,6 +45,39 @@ public class CassandraNewTableWriter {
                }
                return false;
        }
+       
+       /*
+        * update programme name and version
+        */
+       public void FillNewParameter() {
+               System.out.println("Updating....");
+
+               final long StartTime = System.currentTimeMillis();
+               long erldate = CassandraNativeConnector.getEarliestDateInDB();
+               Calendar runnicCal = Calendar.getInstance();
+               runnicCal.setTime(new Date(erldate));
+               Calendar endcal = Calendar.getInstance();
+               long endTime = endcal.getTime().getTime();
+               for (Date date = runnicCal.getTime(); date.getTime() < endTime; runnicCal.add(Calendar.DATE, 1), date = runnicCal.getTime()) {
+                       try {
+                               String com = "SELECT JobID, Protein FROM ProteinData WHERE jobtime = " + date.getTime() + ";";
+                               System.out.println(com);
+                               ResultSet results = session.execute(com);
+                               if (results == null || results.isExhausted())
+                                       continue;
+                               List<Row> rows = results.all();
+                               System.out.println(rows.size());
+                               for (Row r : rows) {
+                                       session.execute("UPDATE  ProteinLog SET ProgrammeName = 'Jpred', Version = '3.0.1' WHERE JobID = '" + r.getString("JobID") + "';");
+                                       session.execute("UPDATE  JpredArchive SET ProgrammeName = 'Jpred', Version = '3.0.1' WHERE JobID = '" + r.getString("JobID") + "';");                                   
+                               }
+                       } catch (QueryExecutionException e) {
+                               e.printStackTrace();
+                       }
+               }
+               System.out.println("Table ProteinLog filled: total time is " + (System.currentTimeMillis() - StartTime) + " msec");
+       }
+
 
        /*
         * fill new table