X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=datadb%2Fcompbio%2Fcassandra%2FCassandraReader.java;h=00f878ad1be07fa57361208257fa89cb7f6c65ea;hb=429ba39df7f7dbf7c7f940bafd5126cfab9fca61;hp=d2d2e1b48f9d32c49c6c09006f000cdfb7e4ec62;hpb=6097c3a4b7510ced14696c7ec98981b0cd0cea01;p=proteocache.git

diff --git a/datadb/compbio/cassandra/CassandraReader.java b/datadb/compbio/cassandra/CassandraReader.java
index d2d2e1b..00f878a 100644
--- a/datadb/compbio/cassandra/CassandraReader.java
+++ b/datadb/compbio/cassandra/CassandraReader.java
@@ -1,16 +1,39 @@
 package compbio.cassandra;
 
+import org.apache.log4j.Logger;
+
+import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.Session;
 
-public interface CassandraReader {
+public class CassandraReader {
+	private static long earlestDate = 0;
+	private Session session;
+	private static Logger log = Logger.getLogger(CassandraNativeConnector.class);
 
-	/*
-	 * Defines a source file with metainformation of Jpred Jobs
-	 **/
-	void setSession (Session s);
+	public CassandraReader() {
+		Session inis = CassandraNativeConnector.getSession();
+		setSession(inis);
+	}
+
+	public void setSession(Session s) {
+		assert s != null;
+		session = s;
+	}
+	
+	public ResultSet CassandraQuery(String column, String table, String condition) {
+		String com = "SELECT " + column + " FROM " + table + ";";
+		System.out.println("Command: " + com);
+		ResultSet results = session.execute(com);
+		return results;
+	}
 	
 	/*
-	 * Makes real parsing of the source file
-	 **/
-	/*void getResults();*/
+	 * find the earliest date in the database
+	 */
+	public static long earliestDate() {
+		earlestDate = CassandraNativeConnector.getEarliestDateInDB();
+		return earlestDate;
+	}
+
+	
 }