datadb/compbio/cassandra/readers/JobReader.java

   1 package compbio.cassandra.readers;
   2
   3 import com.datastax.driver.core.ResultSet;
   4 import com.datastax.driver.core.Row;
   5
   6 import compbio.beans.JobBean;
   7
   8 public class JobReader extends CassandraReader {
   9
  10         public JobReader() {
  11                 super();
  12         }
  13
  14         /**
  15          * query jobs log info
  16          *
  17          * @param jobid
  18          *
  19          * @return JobBean to the controller JobController
  20          *
  21          **/
  22         public JobBean readJobLog(String jobid) {
  23                 ResultSet results = CassandraQuery("SELECT * FROM ProteinLog WHERE JobID = '" + jobid + "';");
  24                 if (results.isExhausted())
  25                         return null;
  26                 Row row = results.one();
  27                 ResultSet results1 = CassandraQuery("SELECT * FROM ProteinRow WHERE JobID = '" + jobid + "' ALLOW FILTERING;");
  28                 if (results1.isExhausted())
  29                         return null;
  30                 Row row1 = results1.one();
  31                 JobBean res = new JobBean(row.getString("Protein"), row.getString("JobID"), row.getString("DataBegin"), row.getString("DataEnd"),
  32                                 row.getString("ip"), row1.getMap("Predictions", String.class, String.class), row.getString("ProgrammeName"), row.getString("Version"));
  33                 return res;
  34         }
  35 }