1 package compbio.cassandra.readers;
3 import com.datastax.driver.core.ResultSet;
4 import com.datastax.driver.core.Row;
6 import compbio.beans.JobBean;
8 public class JobReader extends CassandraReader {
19 * @return JobBean to the controller JobController
22 public JobBean readJobLog(String jobid) {
23 ResultSet results = CassandraQuery("SELECT * FROM ProteinLog WHERE JobID = '" + jobid + "';");
24 if (results.isExhausted())
26 Row row = results.one();
27 ResultSet results1 = CassandraQuery("SELECT * FROM ProteinRow WHERE JobID = '" + jobid + "' ALLOW FILTERING;");
28 if (results1.isExhausted())
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"));