package compbio.cassandra.readers;

import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;

import compbio.beans.JobBean;

public class JobReader extends CassandraReader {

	public JobReader() {
		super();
	}

	/**
	 * query jobs log info
	 * 
	 * @param jobid
	 * 
	 * @return JobBean to the controller JobController
	 * 
	 **/
	public JobBean readJobLog(String jobid) {
		ResultSet results = CassandraQuery("SELECT * FROM ProteinLog WHERE JobID = '" + jobid + "';");
		if (results.isExhausted())
			return null;
		Row row = results.one();
		ResultSet results1 = CassandraQuery("SELECT * FROM ProteinRow WHERE JobID = '" + jobid + "' ALLOW FILTERING;");
		if (results1.isExhausted())
			return null;
		Row row1 = results1.one();
		JobBean res = new JobBean(row.getString("Protein"), row.getString("JobID"), row.getString("DataBegin"), row.getString("DataEnd"),
				row.getString("ip"), row1.getMap("Predictions", String.class, String.class), row.getString("ProgramName"),
				row.getString("ProgramVersion"));
		return res;
	}
}