1 package compbio.cassandra.readers;
3 import org.apache.log4j.Logger;
5 import com.datastax.driver.core.ResultSet;
6 import com.datastax.driver.core.Session;
7 import com.datastax.driver.core.exceptions.QueryExecutionException;
8 import com.datastax.driver.core.exceptions.QueryValidationException;
9 import compbio.cassandra.CassandraNativeConnector;
11 public class CassandraReader {
12 private static long earlestDate = 0;
13 private Session session;
14 protected static Logger log = Logger.getLogger(CassandraNativeConnector.class);
16 public CassandraReader() {
17 Session inis = CassandraNativeConnector.getSession();
21 public void setSession(Session s) {
26 protected ResultSet CassandraQuery(String command) {
28 ResultSet results = session.execute(command);
30 } catch (QueryExecutionException e) {
31 String mess = "CassandraUserManagerImpl.findAllUsers: query execution exception...";
32 System.out.println(mess);
34 log.error(e.getLocalizedMessage(), e.getCause());
36 } catch (QueryValidationException e) {
37 String mess = "CassandraUserManagerImpl.findAllUsers: query validation exception... Command: " + command;
38 System.out.println(mess);
40 log.error(e.getLocalizedMessage(), e.getCause());
47 * find the earliest date in the database
49 public static long earliestDate() {
50 earlestDate = CassandraNativeConnector.getEarliestDateInDB();