package treecms.proto.cassandra;

import treecms.proto.api.Browser;
import treecms.proto.api.Node;
import java.util.List;
import java.io.UnsupportedEncodingException;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TFramedTransport;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.TException;
import org.apache.cassandra.service.*;
import org.apache.cassandra.thrift.Cassandra;

public class CassBrowser implements Browser
{
	public static void main(String _args[])
	{
		
	}
	
	private Cassandra.Client m_cassandra;
	private String m_keySpace,m_colFamily;
	
	private CassBrowser(String _host,String _port) throws TTransportException
	{
		TTransport tr = new TFramedTransport(new TSocket(_host,Integer.parseInt(_port)));
		TProtocol proto = new TBinaryProtocol(tr);
		m_cassandra = new Cassandra.Client(proto);
		tr.open();
	}
	
	public CassBrowser createInstance(String _host,String _port)
	{
		CassBrowser browser = null;
		try{
			browser = new CassBrowser(_host,_port);
		}catch(Exception _err){
			_err.printStackTrace();
		}
		return browser;
	}
	
	public void setKeyspace(String _keySpace)
	{
		m_keySpace = _keySpace;
	}
	
	public void setColumnFamily(String _colFamily)
	{
		m_colFamily = _colFamily;
	}

	@Override
	public Node useContents()
	{
		// TODO Auto-generated method stub
		return null;
	}
}