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;
	}

	
}