From 8215583c983bd98c91f6726c5a2b991782b66a7f Mon Sep 17 00:00:00 2001 From: Sasha Sherstnev Date: Wed, 22 Jan 2014 09:26:48 +0000 Subject: [PATCH] add check for a Cassandra request --- datadb/compbio/cassandra/CassandraRemover.java | 29 ++++++++++++++++++------ 1 file changed, 22 insertions(+), 7 deletions(-) diff --git a/datadb/compbio/cassandra/CassandraRemover.java b/datadb/compbio/cassandra/CassandraRemover.java index 48a5893..76cc787 100644 --- a/datadb/compbio/cassandra/CassandraRemover.java +++ b/datadb/compbio/cassandra/CassandraRemover.java @@ -11,6 +11,8 @@ import org.apache.log4j.Logger; import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Row; import com.datastax.driver.core.Session; +import com.datastax.driver.core.exceptions.QueryExecutionException; +import com.datastax.driver.core.exceptions.QueryValidationException; public class CassandraRemover { private Session session; @@ -110,14 +112,11 @@ public class CassandraRemover { } } String comm = "SELECT JobID FROM FailLog WHERE jobtime = " + date.getTime() + ";"; - System.out.println("^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^: " + comm); ResultSet resultsfail = session.execute(comm); - System.out.println("^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^: " + comm); if (!resultsfail.isExhausted()) { List rows = resultsfail.all(); for (Row r : rows) { String jobid = r.getString("JobID"); - System.out.println("^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^: " + jobid); if (jobid != null) { RemoveJob(jobid, date.getTime()); numremover++; @@ -174,10 +173,26 @@ public class CassandraRemover { } private String FindStatus(String jobid) { - String com = "SELECT FinalStatus FROM ProteinLog WHERE JobID = '" + jobid + "';"; - System.out.println("Command: " + com); - ResultSet results = session.execute(com); - String status = results.one().getString("FinalStatus"); + String status = "UNKNOWN"; + String command = "SELECT FinalStatus FROM ProteinLog WHERE JobID = '" + jobid + "';"; + try { + System.out.println("Command: " + command); + ResultSet results = session.execute(command); + Row raw = results.one(); + if (null != raw) { + status = raw.getString("FinalStatus"); + } + } catch (QueryExecutionException e) { + String mess = "CassandraRemover: query execution exception..."; + System.out.println(mess); + log.error(mess); + log.error(e.getLocalizedMessage(), e.getCause()); + } catch (QueryValidationException e) { + String mess = "CassandraRemover: query validation exception... Command: " + command; + System.out.println(mess); + log.error(mess); + log.error(e.getLocalizedMessage(), e.getCause()); + } System.out.println("*****status: " + status); return status; } -- 1.7.10.2