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

 

/**

   * author:　ahuaxuan(张荣华)

   * date 2010-2-25

   */

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

在上一篇文章中，我们成功的建立了一个可以cassandra的实例，同时也让它成功的运行起来，下面的工作就是让我们来简单的操作一下这个

号称分布式的号称第二代的数据库系统。

 

本文主要关注两个部分，

1. 怎么写一个最简单cassandra的sample

2. 怎么去分析这个最简单的sample背后隐含的含义

步骤一：
首先我们创建一个工程，然后将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));
    }
}

 

 

好了，代码写到这里，例子里流程非常简单，而且ahuaxuan在例子中也加入了很多注释，估计童鞋们也大概了解了这个cassandra是怎么做insert和get的了

现在可以执行这段代码了，不出意外的话，你们会得到如下结果：

read row row007

column nameahuaxuan

column value: first cassandra sample of ahuaxuan

column timestamp:1

上面说到例子的流程很简单，代码也很少，但是ahuaxuan写这个例子并不只是闲得发慌，也不是无聊得没事可做，真正的目的在于理解这个例子背后的一些模型。

从刚才的这段代码里，估计给大家留下最多烦恼的就是keyspace, row, column, timestamp和consistency_level, 

前面四个概念（keyspace, row, column, timestamp）和数据的存储相关，熟悉的同学估计都知道，这个是来源于bigtable的概念。

而consistency_level则是控制数据分布策略的。由于我们现在的例子只是最简单的而且没有在集群环境下的一个例子，所以consistency_level这个东西我们放在后面，我们先来讲讲

keyspace, row, column, timestamp这四个东西是个什么东西。

1. 首先我们来说说keyspace是个什么玩意

打开storage-conf.xml，找到<Keyspaces>这个xml节点，我们可以看到一段对keyspace的说明， 如下：

ColumnFamily在cassandra中概念最接近关系型数据库中的表。而keyspace则是一堆ColumnFamily的集合。如果说ColumnFamily是表，那么我们可以将keyspace称之库

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

 

<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.

在回头看一下我们的代码是如何使用ColumnFamily的呢？

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

 

这行代码指定了我们要数据存放到哪个ColumnFamily中去, 这里的Standard1就是Keyspace1中的第一个ColumnFamily.

但是我们还有一个问题:

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

 

这行代码中第三个参数才是ColumnPath, 第一个参数是keyspace, 两者之间还夹着一个row, 那么row是一个什么样的角色呢？

to be continued.

 

评论

8 楼 ahuaxuan 2010-06-12  

lqw8668 写道

楼主用的哪个版本啊？我用0.6.2好像有问题

0.5, cassandra版本升级的时候, api改动较大

7 楼 lqw8668 2010-06-12  

楼主用的哪个版本啊？我用0.6.2好像有问题

6 楼 ahuaxuan 2010-05-09  

cmzx3444 写道

Keyspaces相当于数据库吧，ColumnFamily才像个表

是的, 它的配置文件中是这样描述的. cf是一个多层的hash结构,并不是二维的,这个和bigtable不太一样,所以开始我把cf也看作表了.其实它如果硬要和db比较的话还不太好比

5 楼 cmzx3444 2010-05-08  

Keyspaces相当于数据库吧，ColumnFamily才像个表

4 楼 waterdh 2010-03-17  

waterdh 写道

那个hector客户端太烂了，从连接池borrow一个连接和release一个连接都要4s多，难道是我没用好？

作者已经修复这一bug，不过还没发布新版本jar。
貌似是CassandraClientPoolImpl中这行turl = address.getHostName(); 引起的问题。

3 楼 waterdh 2010-03-16  

那个hector客户端太烂了，从连接池borrow一个连接和release一个连接都要4s多，难道是我没用好？

2 楼 zhangcheng 2010-03-05  

yangfuchao418 写道

呵呵 ，楼主联系方式是多少，我也正在测试cassandra和hbase

yangfuchao418 写道

呵呵 ，楼主联系方式是多少，我也正在测试cassandra和hbase

我最近也在做cassandra，你测试得如何啊？

HBase倒是没看太多~cassandra做了几个例子

1 楼 yangfuchao418 2010-02-26  

呵呵 ，楼主联系方式是多少，我也正在测试cassandra和hbase