inserted 2 columns: version and pragramme name

[proteocache.git] / datadb / compbio / cassandra / CassandraWriter.java

diff --git a/datadb/compbio/cassandra/CassandraWriter.java b/datadb/compbio/cassandra/CassandraWriter.java
index 710d78b..05a03f0 100644 (file)
--- a/datadb/compbio/cassandra/CassandraWriter.java
+++ b/datadb/compbio/cassandra/CassandraWriter.java
@@ -74,10 +74,12 @@ public class CassandraWriter {
                        String protein = job.getProtein();
                        String finalstatus = job.getFinalStatus();
                        String execstatus = job.getExecutionStatus();
+                       String programmeName = job.getProgrammeName();
+                       String version = job.getVersion();
 
-                       String com1 = "INSERT INTO ProteinLog (JobID, IP, DataBegin, DataEnd, FinalStatus, ExecutionStatus, Protein) VALUES ('" + id
+                       String com1 = "INSERT INTO ProteinLog (JobID, IP, DataBegin, DataEnd, FinalStatus, ExecutionStatus, Protein, ProgrammeName, Version) VALUES ('" + id
                                        + "','" + job.getIP() + "','" + job.getStartingTimeStr() + "','" + job.getEndTimeStr() + "','" + finalstatus + "','"
-                                       + execstatus + "','" + protein + "');";
+                                       + execstatus + "','" + protein + "','" + programmeName + "','" + version + "');";
                        ResultSet insert = execute(com1);
                        if (null == insert) {
                                System.out.println("CassandraWriter.FormQueryTables: couldn't insert into ProteinLog");
@@ -191,7 +193,7 @@ public class CassandraWriter {
                if (JobisNotArchived(job.getJobID())) {
                        String id = job.getJobID();
                        String log = job.getLog().replaceAll("'", "");
-                       String com = "INSERT INTO JpredArchive (JobID, Protein, IP, StartTime, ExecTime, FinalStatus, ExecutionStatus, LOG, ArchiveLink) VALUES ('"
+                       String com = "INSERT INTO JpredArchive (JobID, Protein, IP, StartTime, ExecTime, FinalStatus, ExecutionStatus, LOG, ArchiveLink, ProgrammeName, Version) VALUES ('"
                                        + id
                                        + "','"
                                        + job.getProtein()
@@ -201,7 +203,7 @@ public class CassandraWriter {
                                        + job.getStartingTime()
                                        + ","
                                        + job.getExecutionTime()
-                                       + ",'" + job.getFinalStatus() + "','" + job.getExecutionStatus() + "','" + log + "','" + archivepath + "');";
+                                       + ",'" + job.getFinalStatus() + "','" + job.getExecutionStatus() + "','" + log + "','" + archivepath + "','" + job.getProgrammeName() + "','" + job.getVersion() + "');";
                        if (null == execute(com)) {
                                System.out.println("CassandraWriter.ArchiveData: couldn't insert into JpredArchive");
                        }