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 {
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 {
+ try {
String com = "SELECT JobID, Protein FROM ProteinData WHERE jobtime = " + date.getTime() + ";";
System.out.println(com);
ResultSet results = session.execute(com);
continue;
List<Row> rows = results.all();
System.out.println(rows.size());
- int k=0;
for (Row r : rows) {
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") + "';");
+ + r.getString("JobID") + "';");
}
} catch (QueryExecutionException e) {
e.printStackTrace();