X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=datadb%2Fcompbio%2Fcassandra%2FCassandraNativeConnector.java;h=9d8d01d6f01baa73b7f3f937bab5edf245cf516e;hb=006363dc999cef4e9c49dd6a38ea0d78cbb62472;hp=5e5cf5a4379a7003fe91ae33861534aed25d2eda;hpb=6823d2f36ff55b7ab11d674e3fe4d04dc57d6bbf;p=proteocache.git

diff --git a/datadb/compbio/cassandra/CassandraNativeConnector.java b/datadb/compbio/cassandra/CassandraNativeConnector.java
index 5e5cf5a..9d8d01d 100644
--- a/datadb/compbio/cassandra/CassandraNativeConnector.java
+++ b/datadb/compbio/cassandra/CassandraNativeConnector.java
@@ -33,7 +33,7 @@ public class CassandraNativeConnector {
 
 	public static String CASSANDRA_HOSTNAME = "localhost";
 
-	public static Session getSession () {
+	public static Session getSession() {
 		return session;
 	}
 
@@ -49,7 +49,7 @@ public class CassandraNativeConnector {
 
 		Cluster.Builder builder = Cluster.builder();
 		builder.addContactPoint(CASSANDRA_HOSTNAME);
-		//PrintClusterConfiguration( builder.getConfiguration());
+		// PrintClusterConfiguration( builder.getConfiguration());
 		cluster = builder.build();
 
 		Metadata metadata = cluster.getMetadata();
@@ -66,9 +66,8 @@ public class CassandraNativeConnector {
 		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));");
 
@@ -81,7 +80,7 @@ public class CassandraNativeConnector {
 
 		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));");
@@ -91,8 +90,7 @@ public class CassandraNativeConnector {
 
 		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) {
@@ -112,8 +110,8 @@ public class CassandraNativeConnector {
 		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();
@@ -136,14 +134,14 @@ public class CassandraNativeConnector {
 		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());