深入浅出cassandra 2 第一个可以运行的例子

     步骤一：

     首先我们创建一个工程，然后将cassandra/lib目录下的包，导入到我们的工程中。

/**
 * @author: ahuaxuan(张荣华)
 * @date: 2010-2-8 10:28:02
 * @version: $$id$$
 */
public class SampleOne {
    static Cassandra.Client cassandraClient;


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

        /* 首先指定cassandra server的地址 */
        TTransport 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 TException, TimedOutException, InvalidRequestException, UnavailableException, NotFoundException {
        /* 初始化连接 */
        init();


        /* 选择需要操作的Keyspaces， 可以理解成数据库的表 */
        String keyspace= "Keyspace1";
        String row = "row007";


        /* 创建一个column path */
        ColumnPath col = new ColumnPath("Standard1", null, "ahuaxuan".getBytes());


        /* 执行插入操作，指定keysapce, row, col, 和数据内容， 后面两个参数一个是timestamp， 另外一个是consistency_level
          * timestamp是用来做数据一致性保证的， 而consistency_level是用来控制数据分布的策略，前者的理论依据是bigtable, 后者的理论依据是dynamo
          */
        cassandraClient.insert(keyspace, row, col, "val1".getBytes(), 1, 1);

        /* 取出刚刚塞进去的值，取值的流程和插入的流程类似，也需要指定keyspace, row, col, 最后一个参数是consistency_level */
        Column column = cassandraClient.get(keyspace, row, col, 1).column;

        System.out.println("read row " + row);
        System.out.println("column name" + new String(column.name));
        System.out.println("column value" + ":" + new String(column.value));
        System.out.println("column timestamp" + ":" + (column.timestamp));
    }
}

    我们来看一段简单的配置。

<Keyspaces>   
    <Keyspace Name="Keyspace1">   
      <ColumnFamily CompareWith="BytesType" Name="Standard1"/>   
      <ColumnFamily CompareWith="UTF8Type" Name="Standard2"/>   
      <ColumnFamily CompareWith="TimeUUIDType" Name="StandardByUUID1"/>   
      <ColumnFamily ColumnType="Super"  
                    CompareWith="UTF8Type"  
                    CompareSubcolumnsWith="UTF8Type"  
                    Name="Super1"  
                    Comment="A column family with supercolumns, whose column and subcolumn names are UTF8 strings"/>   
    </Keyspace>   
    <Keyspace Name="ahuaxuan">   
      <ColumnFamily CompareWith="BytesType" Name="test1"/>   
      <ColumnFamily CompareWith="UTF8Type" Name="test2"/>   
      <ColumnFamily ColumnType="Super"  
                    CompareWith="UTF8Type"  
                    CompareSubcolumnsWith="UTF8Type"  
                    Name="Super1"  
                    Comment="A column family with supercolumns, whose column and subcolumn names are UTF8 strings"/>   
    </Keyspace>   
  </Keyspaces>  
     这段配置表示我们的cassandra中有多个keyspace, 而每个keyspace下又有多个ColumnFamily.

 /* 创建一个column path */
        ColumnPath col = new ColumnPath("Standard1", null, "ahuaxuan".getBytes());

cassandraClient.insert(keyspace, row, col, "val1".getBytes(), 1, 1);

建议继续学习：

1. Cassandra和HBase主要设计思路对比    (阅读：4075)
2. Cassandra存储机制    (阅读：3779)
3. 转载：cassandra读写性能原理分析    (阅读：3494)
4. Twitter停用Cassandra原因分析    (阅读：3014)
5. Cassandra之Token    (阅读：2910)
6. Cassandra运维之道    (阅读：2764)
7. 深入浅出cassandra 4 数据一致性问题概述    (阅读：2711)
8. Cassandra数据模型    (阅读：2702)
9. Cassandra运维之道 v0.2    (阅读：2169)
10. 深入浅出cassandra 1 安装    (阅读：2048)