所用版本 Cassandra 1.0
简单的增删改java测试代码:
import java.nio.ByteBuffer;
import org.apache.cassandra.thrift.*;
import org.apache.cassandra.thrift.TBinaryProtocol;
import org.apache.thrift.protocol.*;
import org.apache.thrift.transport.*;
public class Test {
public static void main(String[] args) throws Exception {
// insertOrUpdateData(); //增加或者修改
getData(); //查询
// delete(); //删除
}
public static void insertOrUpdateData() throws Exception{
TTransport transport = new TFramedTransport(new TSocket("127.0.0.1",9160));
TProtocol protocol = new TBinaryProtocol(transport);
Cassandra.Client client = new Cassandra.Client(protocol);
transport.open();
client.set_keyspace("ksTest1");
ColumnParent parent = new ColumnParent("User1");
ByteBuffer rowid = ByteBuffer.wrap("100".getBytes());
Column column = new Column();
column.setName("description2".getBytes());
column.setValue("some value here222...".getBytes());
column.setTimestamp(System.currentTimeMillis());
client.insert(rowid, parent, column, ConsistencyLevel.ONE);
transport.flush();
transport.close();
}
public static void getData() throws Exception{
TTransport transport = new TFramedTransport(new TSocket("127.0.0.1",9160));
TProtocol protocol = new TBinaryProtocol(transport);
Cassandra.Client client = new Cassandra.Client(protocol);
transport.open();
client.set_keyspace("ksTest1");
ColumnParent parent = new ColumnParent("User1");
ByteBuffer rowid = ByteBuffer.wrap("100".getBytes());
Column column = new Column();
column.setName("description".getBytes());
ColumnPath path = new ColumnPath();
path.column_family = "User1";
path.column = ByteBuffer.wrap("description".getBytes());
ColumnOrSuperColumn c1 = client.get(rowid, path, ConsistencyLevel.ONE) ;
String res = new String(c1.getColumn().getValue(),"UTF-8");
System.out.println(res);
transport.flush();
transport.close();
}
public static void delete() throws Exception{
// open connection to Cassandra server
TTransport transport = new TFramedTransport(new TSocket("127.0.0.1",9160));
TProtocol protocol = new TBinaryProtocol(transport);
Cassandra.Client client = new Cassandra.Client(protocol);
transport.open();
// specify keyspace
client.set_keyspace("ksTest1");
// specify row id
ByteBuffer rowid = ByteBuffer.wrap("100".getBytes());
// specify column path
ColumnPath path = new ColumnPath();
path.column_family = "User1";
path.column = ByteBuffer.wrap("description2".getBytes());
// specify timestamp value of data to be removed
long timestamp = 1301874610643000L;
// set consistency level to one
ConsistencyLevel consistency = ConsistencyLevel.ONE;
// remove the description column from the specified row
// in the User column family
client.remove(rowid, path, timestamp, consistency);
// release resources
transport.flush();
transport.close();
}
}
分享到:
相关推荐
Cassandra个人学习笔记总结,引用请注明出处。
一、了解token token是cassandra里相当重要的一个概念,它是cassandra用来平衡...1.数据将存储到拥有最近的比key的hash值大的token的节点上; 2.若key的hash值比最大的token大,那将被存储到具有最小token的节点上。
cassandra 学习
Cassandra是一个混合型的非关系的数据库,类似于Google的BigTable。其主要功能比Dynomite(分布式的Key-Value存储系统)更丰富,但支持度却不如文档存储MongoDB(介于关系数据库和非关系数据库之间的开源产品,是非...
cassandra学习资料
cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战cassandra 实战...
cassandra.part1.rar cassandra 3.0 for win
Cassandra 2.1.2 源代码 part1 编译过
Cassandra 权威指南 大数据学习必备。 本书是一本广受好评的Cassandra图书。与传统的关系型数据库不同,Cassandra是一种开源的分布式存储系统。书中介绍了它无中心架构、高可用、无缝扩展等引人注目的特点,讲述了...
The rising popularity of Apache Cassandra rests on its ability to handle very large data sets that include hundreds of terabytes -- and that's why this distributed database has been chosen by ...
DevCenter cassandra客户端 DevCenter cassandra客户端 DevCenter cassandra客户端
Cassandra(apache-cassandra-4.0.1-bin.tar.gz)是一套开源分布式NoSQL数据库系统。它最初由Facebook开发,用于储存收件箱等简单格式数据,集GoogleBigTable的数据模型与Amazon Dynamo的完全分布式的架构于一身...
Cassandra(apache-cassandra-3.11.11-bin.tar.gz)是一套开源分布式NoSQL数据库系统。它最初由Facebook开发,用于储存收件箱等简单格式数据,集GoogleBigTable的数据模型与Amazon Dynamo的完全分布式的架构于一身...
1、cassandra的安装、维护使用 2、java操作cassandra实例 3、cql使用详解
Cassandra 入门学习 Clauster 实例 Cassandra Log4j 下应用
Cassandra的主要特点就是它不是一个数据库,而是由一堆数据库节点共同构成的一个分布式网络服务,对Cassandra 的一个写操作,会被复制到其他节点上去,对Cassandra的读操作,也会被路由到某个节点上面去读取。...
Cassandra文档
cassandra介绍