Rebuild tables for queries

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

diff --git a/datadb/compbio/cassandra/CassandraNewTableWriter.java b/datadb/compbio/cassandra/CassandraNewTableWriter.java
index 1832750..88a4ca2 100644 (file)
--- a/datadb/compbio/cassandra/CassandraNewTableWriter.java
+++ b/datadb/compbio/cassandra/CassandraNewTableWriter.java
@@ -2,7 +2,6 @@ package compbio.cassandra;
 
 import java.util.Calendar;
 import java.util.Date;
-import java.util.List;
 
 import org.apache.log4j.Logger;
 
@@ -11,10 +10,10 @@ import com.datastax.driver.core.Session;
 import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.PreparedStatement;
 import com.datastax.driver.core.BoundStatement;
+import com.datastax.driver.core.exceptions.QueryExecutionException;
 
 import compbio.engine.ProteoCachePropertyHelperManager;
 import compbio.cassandra.CassandraNativeConnector;
-import compbio.util.PropertyHelper;
 
 public class CassandraNewTableWriter {
        private Session session;
@@ -56,18 +55,26 @@ public class CassandraNewTableWriter {
                Calendar endcal = Calendar.getInstance();
                Date end = endcal.getTime();
                for (Date date = start.getTime(); !start.after(end); start.add(Calendar.DATE, 1), date = start.getTime()) {
+                       final long startTime = System.currentTimeMillis();
                        String query1 = "SELECT * FROM ProteinData WHERE jobtime = " + date.getTime() + ";";
                        System.out.println("Query db: " + query1);
-                       ResultSet results = session.execute(query1);
-                       String query2 = "INSERT INTO JobDateInfo " + "(jobday, Total)" + " VALUES (" + date.getTime() + "," + results.all().size()+ ");";
-                       System.out.println("Insert DB: " + query2);
-                       session.execute(query2);
+                       try {
+                               ResultSet results = session.execute(query1);
+                               final long queryTime = System.currentTimeMillis();
+                               System.out.println("Query time for " + date.toString() + " is " + (queryTime - startTime) + " msec");
+                               String query2 = "INSERT INTO JobDateInfo " + "(jobday, Total)" + " VALUES (" + date.getTime() + "," + results.all().size()
+                                               + ");";
+                               System.out.println("Insert DB: " + query2);
+                               session.execute(query2);
+                       } catch (QueryExecutionException e) {
+                               e.printStackTrace();
+                       }
                }
                System.out.println("Table JobDateInfo filled");
        }
-       
+
        /*
-        * fill new table
+        * fill a table with the database global parameters
         */
        public void FillParameters() {
                Date bubu = new Date(CassandraNativeConnector.getEarliestDateInDB());