fix data report, protein report

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

diff --git a/datadb/compbio/cassandra/CassandraNativeConnector.java b/datadb/compbio/cassandra/CassandraNativeConnector.java
index d87f89e..766c376 100644 (file)
--- a/datadb/compbio/cassandra/CassandraNativeConnector.java
+++ b/datadb/compbio/cassandra/CassandraNativeConnector.java
@@ -237,7 +237,7 @@ public class CassandraNativeConnector {
                        return 0;
                List<Row> rows = results.all();
                final long endTime = System.currentTimeMillis();
-               System.out.println ("Processing time is " + (endTime - queryTime) + " msec");        
+               System.out.println ("Processing time is " + (endTime - queryTime) + " msec");
                return rows.size();
        }
 
@@ -253,7 +253,7 @@ public class CassandraNativeConnector {
                        return null;
                final long queryTime = System.currentTimeMillis();
                List<Row> rows = results.all();
-               System.out.println ("Query time is " + (queryTime - startTime) + " msec");   
+               System.out.println ("Query time is " + (queryTime - startTime) + " msec");
                System.out.println (" rows analysed,  " + rows.size());
                List<StructureProteinPrediction> res = new ArrayList<StructureProteinPrediction>();
                int c = 0;
@@ -268,6 +268,22 @@ public class CassandraNativeConnector {
        }
 
        /*
+        * getting data from the db ProteinData
+        */
+       public Integer ReadDateTable(long queryDate) {
+               final long startTime = System.currentTimeMillis();
+               String com = "SELECT jobtime, JobID FROM ProteinKeyspace.ProteinData WHERE jobtime = " + queryDate + ";";
+               System.out.println("Command: " + com);
+               ResultSet results = session.execute(com);
+               if (results.isExhausted())
+                       return null;
+               final long queryTime = System.currentTimeMillis();
+               List<Row> rows = results.all();
+               System.out.println ("Query time is " + (queryTime - startTime) + " msec");
+               return rows.size();
+       }
+
+       /*
         * getting part of protein sequence from the db ProteinRow
         */
        public List<StructureProteinPrediction>  ReadPartOfSequence(String queryProtein) {
@@ -279,7 +295,7 @@ public class CassandraNativeConnector {
                        return null;
                final long queryTime = System.currentTimeMillis();
                List<Row> rows = results.all();
-               System.out.println ("Query time is " + (queryTime - startTime) + " msec");   
+               System.out.println ("Query time is " + (queryTime - startTime) + " msec");
                System.out.println (" rows analysed,  " + rows.size());
                List<StructureProteinPrediction>  res = new ArrayList<StructureProteinPrediction>();
                int c = 0;
@@ -308,7 +324,7 @@ public class CassandraNativeConnector {
                        return null;
                final long queryTime = System.currentTimeMillis();
                List<Row> rows = results.all();
-               System.out.println ("Query time is " + (queryTime - startTime) + " msec");   
+               System.out.println ("Query time is " + (queryTime - startTime) + " msec");
                System.out.println (" rows analysed,  " + rows.size());
                Map<String, Integer> res = new HashMap<String, Integer>();
                int c = 0;
@@ -354,7 +370,7 @@ public class CassandraNativeConnector {
         */
        public long getEarliestDateInDB() {
                final long startTime = System.currentTimeMillis();
-               String com = "SELECT jobtime FROM ProteinKeyspace.ProteinData;";
+               String com = "SELECT jobtime,JobID FROM ProteinKeyspace.ProteinData;";
                System.out.println("Command: " + com);
                ResultSet results = session.execute(com);
                final long queryTime = System.currentTimeMillis();