public static String CASSANDRA_HOSTNAME = "localhost";
- public static Session getSession () {
+ public static Session getSession() {
return session;
}
Cluster.Builder builder = Cluster.builder();
builder.addContactPoint(CASSANDRA_HOSTNAME);
- //PrintClusterConfiguration( builder.getConfiguration());
+ // PrintClusterConfiguration( builder.getConfiguration());
cluster = builder.build();
Metadata metadata = cluster.getMetadata();
session.execute("CREATE KEYSPACE IF NOT EXISTS ProteinKeyspace WITH replication = {'class':'SimpleStrategy', 'replication_factor':3};");
session.execute("USE ProteinKeyspace");
- session.execute("CREATE TABLE IF NOT EXISTS MainParameters "
- + "(Name ascii, Value ascii, PRIMARY KEY(Name));");
-
+ session.execute("CREATE TABLE IF NOT EXISTS MainParameters " + "(Name ascii, Value ascii, PRIMARY KEY(Name));");
+
session.execute("CREATE TABLE IF NOT EXISTS ProteinRow "
+ "(Protein ascii, JobID ascii, Predictions map<ascii,ascii>, PRIMARY KEY(JobID));");
session.execute("CREATE TABLE IF NOT EXISTS FailLog "
+ "(jobtime bigint, JobID ascii, ExecTime int, ip ascii, FinalStatus ascii, PRIMARY KEY(jobtime, JobID));");
-
+
session.execute("CREATE TABLE IF NOT EXISTS JpredArchive "
+ "(JobID ascii, Protein varchar, IP ascii, StartTime bigint, ExecTime int, FinalStatus ascii, ExecutionStatus ascii, alignment map<ascii,ascii>, "
+ "predictions map<ascii,ascii>, ArchiveLink varchar, LOG varchar, PRIMARY KEY(JobID));");
String com = "CREATE TABLE IF NOT EXISTS Users "
+ "(name varchar, id bigint, email varchar, password varchar, organisation varchar, position varchar, signedtolist boolean, registrationdate bigint, PRIMARY KEY(id));";
-
-
+
try {
session.execute(com);
} catch (QueryExecutionException e) {
session.execute("CREATE INDEX IF NOT EXISTS ON ProteinLog (ExecutionStatus);");
session.execute("CREATE INDEX IF NOT EXISTS ON FailLog (FinalStatus);");
session.execute("CREATE INDEX IF NOT EXISTS ON Users (email);");
- // session.execute("CREATE INDEX IF NOT EXISTS JobDateStamp ON ProteinData (jobtime);");
- }
+ // session.execute("CREATE INDEX IF NOT EXISTS JobDateStamp ON ProteinData (jobtime);");
+ }
public void Closing() {
session.shutdown();
Calendar cal = Calendar.getInstance();
return cal.getTimeInMillis();
}
-
+
private void PrintClusterConfiguration(Configuration cc) {
Policies policies = cc.getPolicies();
SocketOptions sopt = cc.getSocketOptions();
ProtocolOptions propt = cc.getProtocolOptions();
PoolingOptions plopt = cc.getPoolingOptions();
MetricsOptions mopt = cc.getMetricsOptions();
- QueryOptions qopt = cc.getQueryOptions();
+ QueryOptions qopt = cc.getQueryOptions();
System.out.println("Cluster configuration:");
System.out.println(" Policies = " + policies.toString());
System.out.println(" Socket Options = " + sopt.toString());