1 files changed, 42 insertions, 0 deletions
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraDatabase.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraDatabase.java
new file mode 100644
index 0000000000..9572476941
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraDatabase.java
@@ -0,0 +1,42 @@
+package org.apache.tuscany.nosqldatastore.cassandra;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import me.prettyprint.cassandra.service.ThriftCluster;
+import me.prettyprint.cassandra.service.ThriftKsDef;
+import me.prettyprint.hector.api.ddl.ColumnFamilyDefinition;
+import me.prettyprint.hector.api.ddl.KeyspaceDefinition;
+import me.prettyprint.hector.api.factory.HFactory;
+import org.apache.tuscany.nosqldatastore.Database;
+import org.apache.tuscany.nosqldatastore.Group;
+
+class CassandraDatabase implements Database {
+	
+	private String keyspace;
+	private ThriftCluster cluster;
+	private List<ColumnFamilyDefinition> cfDefList;
+	
+	CassandraDatabase(String databaseName, ThriftCluster cluster) {
+		this.keyspace = databaseName;
+		this.cluster = cluster;
+		KeyspaceDefinition ksDef = cluster.describeKeyspace(keyspace);
+		cfDefList = ksDef.getCfDefs();
+	}
+
+	public Group createGroup(String groupId) {
+		ColumnFamilyDefinition cfDef = HFactory.createColumnFamilyDefinition(keyspace, groupId);
+		cluster.addColumnFamily(cfDef);
+		CassandraGroup group = new CassandraGroup(groupId);
+		return group;
+	}
+
+	public boolean isAvailable(String key) {
+		return false;
+	}
+
+	public void deleteGroup(String key) {
+		cluster.dropColumnFamily(keyspace, key);	
+	}
+
+}