+++ /dev/null
-package compbio.cassandra;
-
-import org.apache.log4j.Logger;
-
-import com.datastax.driver.core.ResultSet;
-import com.datastax.driver.core.Session;
-
-public class CassandraReader {
- private static long earlestDate = 0;
- private Session session;
- private static Logger log = Logger.getLogger(CassandraNativeConnector.class);
-
- 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;
- }
-
- /*
- * find the earliest date in the database
- */
- public static long earliestDate() {
- earlestDate = CassandraNativeConnector.getEarliestDateInDB();
- return earlestDate;
- }
-
-
-}