关于cassandra0.7.5的操作



import java.nio.ByteBuffer;

import org.apache.cassandra.thrift.Cassandra;
import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnPath;
import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.thrift.InvalidRequestException;
import org.apache.cassandra.thrift.NotFoundException;
import org.apache.cassandra.thrift.TimedOutException;
import org.apache.cassandra.thrift.UnavailableException;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;


public class SampleOne {
static Cassandra.Client cassandraClient;
static TTransport socket;


private static void init() throws TTransportException {
// String server = "192.168.1.129";
String server = "localhost";
int port = 9160;

/* 首先指定cassandra server的地址 */
socket = new TSocket(server, port);
System.out.println(" connected to " + server + ":" + port + ".");


/* 指定通信协议为二进制流协议 */
TBinaryProtocol binaryProtocol = new TBinaryProtocol(socket, false, false);
cassandraClient = new Cassandra.Client(binaryProtocol);


/* 建立通信连接 */
socket.open();
}


public static void main(String[] args) throws Exception {
/* 初始化连接 */
init();


/* 选择需要操作的Keyspaces， 可以理解成数据库的表 */

String keyspace= "test";
String row = "hh";

/* 创建一个Table Name */
String tableName = "table1";

/* 插入一条记录 */
// insertOrUpdate(keyspace,tableName,row,"name","happy birthday!",System.currentTimeMillis());
/* 删除一条记录 */
//delete(keyspace,tableName,row,"name",System.currentTimeMillis());
/* 获取一条记录 (由于插入和删除是同一条记录,有可能会检索不到哦!请大家主意!*/
Column column = getByColumn(keyspace,tableName,row,"name", System.currentTimeMillis());
System.out.println("read row " + row);
System.out.println("column name " + ":" +column.name);
System.out.println("column value" + ":" + column.value);
System.out.println("column timestamp" + ":" + (column.timestamp));

close();
}

/**
* 获取数据
*/
public static Column getByColumn(String tableSpace,String tableName, String rowParam,String ColumnName,long timeStamp)
throws TException, TimedOutException, InvalidRequestException, UnavailableException, NotFoundException{
/* 选择需要操作的Keyspaces， 存放数据表所在的空间位置 */
String keyspace= tableSpace;
/* 数据所在的行标 */
String row = rowParam;

/* 创建一个column path */
ColumnPath col = new ColumnPath(tableName);
col.setColumn(ColumnName.getBytes());

/* 执行查询操作，指定keysapce, row, col， timestamp
* timestamp是用来做数据一致性保证的， 而consistency_level是用来控制数据分布的策略，前者的理论依据是bigtable, 后者的理论依据是dynamo

*/
return cassandraClient.get(ByteBuffer.wrap(col.getColumn()),col, ConsistencyLevel.ONE).getColumn();
}


/**
* 关闭当前的远程访问连接
*/
public static void close() {
socket.close();
}
}


出现异常

Exception in thread "Main Thread" org.apache.thrift.transport.TTransportException
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
at org.apache.cassandra.thrift.Cassandra$Client.recv_get(Cassandra.java:479)
at org.apache.cassandra.thrift.Cassandra$Client.get(Cassandra.java:462)
at SampleOne.getByColumn(SampleOne.java:129)
at SampleOne.main(SampleOne.java:63)

[解决办法]
这个不会啊，呵呵