import compbio.cassandra.CassandraNativeConnector;
public class CassandraReader {
- private static long earlestDate = 0;
- private Session session;
+ protected static long earlestDate = 0;
+ protected Session session;
protected static Logger log = Logger.getLogger(CassandraNativeConnector.class);
public CassandraReader() {
ResultSet results = session.execute(command);
return results;
} catch (QueryExecutionException e) {
- String mess = "CassandraUserManagerImpl.findAllUsers: query execution exception...";
+ String mess = "ProteoCache Cassandra DB interface: query execution exception...\n Command: " + command;
System.out.println(mess);
log.error(mess);
log.error(e.getLocalizedMessage(), e.getCause());
return null;
} catch (QueryValidationException e) {
- String mess = "CassandraUserManagerImpl.findAllUsers: query validation exception... Command: " + command;
+ String mess = "CProteoCache Cassandra DB interface: query validation exception...\n Command: " + command;
System.out.println(mess);
log.error(mess);
log.error(e.getLocalizedMessage(), e.getCause());