blob: 97bd42caf13a7ad080a4776c1e55791610b98fe0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
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.Cluster;
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.Session;
public class CassandraSession implements Session {
private CassandraHostConfigurator cassandraHostConfigurator;
private Cluster cluster;
public CassandraSession(String clusterName) {
cluster = HFactory.getOrCreateCluster("Test Cluster", "127.0.0.1:9160");
}
public Database createDatabase(String keyspaceName) {
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);
}
}
|