X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=datadb%2Fcompbio%2Fcassandra%2FCassandraReader.java;h=b5277388275e95d670b0ddbb2b03cba723519dc8;hb=8a0caa40d0fa288a0ad23f6af2aab1b0de0d50cd;hp=250c7053448d2b4d329f6e273f98c67fd2eb64c9;hpb=34b63209df068b7671e40e5b298eb184785c83ac;p=proteocache.git

diff --git a/datadb/compbio/cassandra/CassandraReader.java b/datadb/compbio/cassandra/CassandraReader.java
index 250c705..b527738 100644
--- a/datadb/compbio/cassandra/CassandraReader.java
+++ b/datadb/compbio/cassandra/CassandraReader.java
@@ -51,6 +51,30 @@ public class CassandraReader {
 	}
 
 	/*
+	 * getting data from the db
+	 */
+	public List<Pair<String, String>> ReadProteinData(long day) {
+		final long startTime = System.currentTimeMillis();
+		String com = "SELECT JobID, Protein FROM ProteinData WHERE jobtime = " + day + ";";
+		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");
+		List<Pair<String, String>> res = new ArrayList<Pair<String, String>>();
+		int c = 0;
+		for (Row r : rows) {
+			Pair<String, String> pair = new Pair<String, String>(r.getString("JobID"), r.getString("Protein"));
+			res.add(pair);
+			++c;
+		}
+		final long endTime = System.currentTimeMillis();
+		System.out.println(c + " rows analysed, execution time is " + (endTime - startTime) + " msec");
+		return res;
+	}
+	/*
 	 * getting data from the db JobDateInfo
 	 */
 	public List<Long> ReadDateTable(long queryDate) {
@@ -89,6 +113,10 @@ public class CassandraReader {
 		for (Row r : rows) {
 			StructureProteinPrediction structure = new StructureProteinPrediction(queryProtein, r.getString("JobID"), r.getMap(
 					"Predictions", String.class, String.class));
+			if (structure.getPrediction().containsKey("jnetpred"))
+				structure.setJnetpred(structure.getPrediction().get("jnetpred"));
+			else
+				structure.setJnetpred("");
 			res.add(structure);
 			++c;
 		}
@@ -157,7 +185,7 @@ public class CassandraReader {
 	}
 
 	/*
-	 * getting protein sequences by counter
+	 * getting log info for jobid
 	 */
 	public StructureJobLog ReadJobLog(String jobid) {
 		final long startTime = System.currentTimeMillis();