X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=datadb%2Fcompbio%2Fcassandra%2Freaders%2FCassandraReader.java;h=a4561be889833600ef42cbbf2bfc194b538924df;hb=5aec34fb583587602104757aaadc13e7a32ca75c;hp=f9706595d479aa51e60342b4e7ec0c6cffa94d58;hpb=189cef1556fdfed2d73f16d197e7d590417cb881;p=proteocache.git diff --git a/datadb/compbio/cassandra/readers/CassandraReader.java b/datadb/compbio/cassandra/readers/CassandraReader.java index f970659..a4561be 100644 --- a/datadb/compbio/cassandra/readers/CassandraReader.java +++ b/datadb/compbio/cassandra/readers/CassandraReader.java @@ -9,11 +9,22 @@ import com.datastax.driver.core.exceptions.QueryValidationException; import compbio.cassandra.CassandraNativeConnector; +/** + * basic reader of the ProteoCache database. It depends on open + * CassandraNativeConnector, which should provide an open session to the + * ProteoCache DB (in the default constructor) + * + * @author as373024 + * + */ public class CassandraReader { protected static long earlestDate = 0; protected Session session; protected static Logger log = Logger.getLogger(CassandraNativeConnector.class); + /** + * default constructor. + */ public CassandraReader() { Session inis = CassandraNativeConnector.getSession(); setSession(inis); @@ -24,6 +35,13 @@ public class CassandraReader { session = s; } + /** + * Basic query to the DB. The method throws exception if the input command + * is not valid or if there is a problem with execution of the command + * + * @param command - reading CQL command + * @return resulting outout of the command + */ protected ResultSet CassandraQuery(String command) { try { ResultSet results = session.execute(command); @@ -44,14 +62,16 @@ public class CassandraReader { } - /* - * find the earliest date in the database + /** + * finds the earliest date in the database + * + * @return the earliest date (long) */ public static long earliestDate() { earlestDate = CassandraNativeConnector.getEarliestDateInDB(); return earlestDate; } - + /** * prepares an example of either job id or IP for the DB *