datadb/compbio/cassandra/CassandraReader.java

   1 package compbio.cassandra;
   2
   3 import org.apache.log4j.Logger;
   4
   5 import com.datastax.driver.core.ResultSet;
   6 import com.datastax.driver.core.Session;
   7
   8 public class CassandraReader {
   9         private static long earlestDate = 0;
  10         private Session session;
  11         private static Logger log = Logger.getLogger(CassandraNativeConnector.class);
  12
  13         public CassandraReader() {
  14                 Session inis = CassandraNativeConnector.getSession();
  15                 setSession(inis);
  16         }
  17
  18         public void setSession(Session s) {
  19                 assert s != null;
  20                 session = s;
  21         }
  22
  23         public ResultSet CassandraQuery(String column, String table, String condition) {
  24                 String com = "SELECT " + column + " FROM " + table + ";";
  25                 System.out.println("Command: " + com);
  26                 ResultSet results = session.execute(com);
  27                 return results;
  28         }
  29
  30         /*
  31          * find the earliest date in the database
  32          */
  33         public static long earliestDate() {
  34                 earlestDate = CassandraNativeConnector.getEarliestDateInDB();
  35                 return earlestDate;
  36         }
  37
  38
  39 }