diff options
Diffstat (limited to 'collaboration/GSoC-2011-Eranda/cassandra/src/main/java')
7 files changed, 141 insertions, 0 deletions
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Database.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Database.java new file mode 100644 index 0000000000..02315a6e43 --- /dev/null +++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Database.java @@ -0,0 +1,7 @@ +package org.apache.tuscany.nosqldatastore;
+
+public interface Database {
+ org.apache.tuscany.nosqldatastore.Group createGroup(String groupId);
+ boolean isAvailable(String key);
+ void deleteGroup(String key);
+}
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Group.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Group.java new file mode 100644 index 0000000000..8874494b08 --- /dev/null +++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Group.java @@ -0,0 +1,7 @@ +package org.apache.tuscany.nosqldatastore;
+
+public interface Group {
+ void addEntry(String key, Object value);
+ void updateEntry(String key, Object value);
+ void deleteEntry(String key);
+}
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Session.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Session.java new file mode 100644 index 0000000000..983c487369 --- /dev/null +++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/Session.java @@ -0,0 +1,7 @@ +package org.apache.tuscany.nosqldatastore;
+
+public interface Session {
+ Database createDatabase(String databaseName);
+ Database getDatabase(String databaseName);
+ void deleteDatabase(String databaseName);
+}
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java new file mode 100644 index 0000000000..a2821a58ee --- /dev/null +++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java @@ -0,0 +1,17 @@ +package org.apache.tuscany.nosqldatastore;
+
+import org.apache.tuscany.nosqldatastore.cassandra.CassandraSession;
+
+public class SessionFactory {
+
+ private static org.apache.tuscany.nosqldatastore.Session session;
+
+ private SessionFactory(){
+ }
+
+ public static Session getCassandraSession(){
+ session = new CassandraSession("DataCluster");
+ return session;
+ }
+
+}
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);
+ }
+
+}
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraGroup.java b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraGroup.java new file mode 100644 index 0000000000..36a5bddf7b --- /dev/null +++ b/collaboration/GSoC-2011-Eranda/cassandra/src/main/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraGroup.java @@ -0,0 +1,25 @@ +package org.apache.tuscany.nosqldatastore.cassandra;
+
+import org.apache.tuscany.nosqldatastore.Group;
+
+class CassandraGroup implements Group {
+
+ CassandraGroup(String groupName) {
+ }
+
+ public void addEntry(String key, Object value) {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void deleteEntry(String key) {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void updateEntry(String key, Object value) {
+ // TODO Auto-generated method stub
+
+ }
+
+}
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);
+ }
+
+}
|