import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.ResultSet;
-import com.datastax.driver.core.PreparedStatement;
-import com.datastax.driver.core.BoundStatement;
import com.datastax.driver.core.exceptions.QueryExecutionException;
-import compbio.engine.ProteoCachePropertyHelperManager;
import compbio.cassandra.CassandraNativeConnector;
public class CassandraNewTableWriter {
}
return false;
}
-
+
/*
* update programme name and version
*/
List<Row> rows = results.all();
System.out.println(rows.size());
for (Row r : rows) {
- session.execute("UPDATE ProteinLog SET ProgrammeName = 'Jpred', Version = '3.0.1' WHERE JobID = '" + r.getString("JobID") + "';");
- session.execute("UPDATE JpredArchive SET ProgrammeName = 'Jpred', Version = '3.0.1' WHERE JobID = '" + r.getString("JobID") + "';");
+ session.execute("UPDATE ProteinLog SET ProgramName = 'Jpred', ProgramVersion = '3.0.1' WHERE JobID = '"
+ + r.getString("JobID") + "';");
+ session.execute("UPDATE JpredArchive SET ProgramName = 'Jpred', ProgramVersion = '3.0.1' WHERE JobID = '"
+ + r.getString("JobID") + "';");
}
} catch (QueryExecutionException e) {
e.printStackTrace();
System.out.println("Table ProteinLog filled: total time is " + (System.currentTimeMillis() - StartTime) + " msec");
}
-
- /*
- * fill new table
- */
- public void FillNewTable() {
- final long StartTime = System.currentTimeMillis();
- long erldate = CassandraNativeConnector.getEarliestDateInDB();
- Calendar runnicCal = Calendar.getInstance();
- runnicCal.setTime(new Date(erldate));
- Calendar endcal = Calendar.getInstance();
- long endTime = endcal.getTime().getTime();
- for (Date date = runnicCal.getTime(); date.getTime() < endTime; runnicCal.add(Calendar.DATE, 1), date = runnicCal.getTime()) {
- try {
- ResultSet results = session.execute("SELECT * FROM ProteinData WHERE jobtime = " + date.getTime() + ";");
- session.execute("INSERT INTO JobDateInfo " + "(jobday, Total)" + " VALUES (" + date.getTime() + "," + results.all().size()
- + ");");
- } catch (QueryExecutionException e) {
- e.printStackTrace();
- }
- }
- System.out.println("Table JobDateInfo filled: total time is " + (System.currentTimeMillis() - StartTime) + " msec");
- }
-
/*
* fill a table with the database global parameters
*/
Date gaga = new Date(newearliestday);
System.out.println("New EarliestJobDate is " + gaga.toString());
}
+ public void FillNewTable() {
+ }
}