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);
	}

}