Cassandra 的数据模型及使用

1. 概述

Cassandra 是一套优秀的开源的分布式 NoSQL 数据库系统，采用了 Google 提出的 BigTable 数据模型和 Amazon 提出的 Dynamo 分布式架构，保证了很强的扩展性而避免了单点故障。

2. Cassandra 的数据模型

2.1. key — 键

在 Cassandra 中，数据是以 key/value 形式存储的，key 是唯一标识。

2.2. column — 列

Cassandra 中每个 key/value 对中的 value 被称为 column。 是一个三元组：name，value 和 timestamp。 其中，name 必须是唯一的。

2.3. super column — 多子列

Cassandra 允许 key/value 中的 value 是一个 map，即 column 有多个子列。

2.4. Standard Column Family — 表

每个 CF 由一系列 row 组成，每个 row 包含一个 key 以及其对应的若干个 column。

3. Cassandra 的使用

输入 ? 命令，可以查看 Cassandra 的帮助信息，帮助信息较为详细，结合上面列出的 Cassandra 数据模型，相信很快可以掌握全部操作。

3.1. 创建 keyspace

我们首先需要创建一个 keyspace 来进行我们的测试：

create keyspace Twissandra;

然后，我们需要选择这个 keyspace 以便在其中进行操作。

use Twissandra;

3.2. 创建 Column

虽然直接使用 create column 命令就可以创建 column，但是我们最好还是加上默认的编码类型：

create column family User with comparator = UTF8Type;

3.3. 更新数据对象集合（schema）

然后哦我们必须更新数据模型，设定 column_name。

update column family User with column_metadata =
    [
        {column_name: first, validation_class: UTF8Type},
        {column_name: last, validation_class: UTF8Type},
        {column_name: age, validation_class: UTF8Type, index_type: KEYS}
    ];

3.4. 添加数据

在添加数据前，我们首先需要生命 key 的编码类型：

assume User keys as utf8;

接下来我们可以去添加数据了：

set User['jsmith']['first'] = 'John';
set User['jsmith']['last'] = 'Smith';
set User['jsmith']['age'] = '38';

当然了，如果数据已经存在，那么就是执行更新操作。

3.5. 读取数据

执行 get 操作即可获取数据。

get User['jsmith'];

也可以进行条件查询：

get User where age = '38';