1 files changed, 36 insertions, 0 deletions
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraSession.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraSession.java
new file mode 100644
index 0000000000..f9cd7a62c5
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraSession.java
@@ -0,0 +1,36 @@
+package org.apache.tuscany.nosqldatastore.cassandra;
+
+import me.prettyprint.cassandra.service.CassandraHostConfigurator;
+import me.prettyprint.cassandra.service.ThriftCluster;
+import me.prettyprint.cassandra.service.ThriftKsDef;
+import me.prettyprint.hector.api.ddl.KeyspaceDefinition;
+import org.apache.tuscany.nosqldatastore.Database;
+import org.apache.tuscany.nosqldatastore.Session;
+
+public class CassandraSession implements Session {
+	
+	private CassandraHostConfigurator cassandraHostConfigurator;
+	private ThriftCluster cluster;
+	
+	public CassandraSession(String clusterName) {
+		cassandraHostConfigurator = new CassandraHostConfigurator("localhost:9160");
+		cluster = new ThriftCluster(clusterName, cassandraHostConfigurator);
+	}
+
+	public Database createDatabase(String keyspaceName) {
+		KeyspaceDefinition ksDef = new ThriftKsDef(keyspaceName, "org.apache.cassandra.locator.SimpleStrategy", 1, null);
+		cluster.addKeyspace(ksDef);
+		Database database = new CassandraDatabase(keyspaceName, cluster);
+		return database;
+	}
+
+	public Database getDatabase(String keyspaceName) {
+		Database database = new CassandraDatabase(keyspaceName, cluster);
+		return database;
+	}
+
+	public void deleteDatabase(String keyspaceName) {
+		cluster.dropKeyspace(keyspaceName);
+	}
+
+}