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 row1 = results.one();
27 ResultSet results1 = CassandraQuery("SELECT * FROM ProteinRow WHERE JobID = '" + jobid + "' ALLOW FILTERING;");
28 if (results1.isExhausted())
30 Row row2 = results1.one();
31 String program = row1.getString("ProgramName");
32 String version = row1.getString("ProgramVersion");
33 JobBean res = new JobBean(row1.getString("Protein"), row1.getString("JobID"), row1.getString("DataBegin"),
34 row1.getString("DataEnd"), row1.getString("ip"), row2.getMap("Predictions", String.class, String.class));
36 if (null != program && null != version) {
37 res.setProgramName(program);
38 res.setProgramVersion(version);
39 ResultSet results3 = CassandraQuery("SELECT * FROM Programs WHERE Program = '" + program + "' and Version = '" + version
40 + "' ALLOW FILTERING;");
41 if (results3.isExhausted())
43 Row row3 = results3.one();
44 String link = row3.getString("weblink");
46 res.setProgramLink(link);