Cassandra 的数据模型及使用

2022-06-27 12:58:05 浏览数 (1)

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 来进行我们的测试:

代码语言:javascript复制
create keyspace Twissandra;

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

代码语言:javascript复制
use Twissandra;

3.2. 创建 Column

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

代码语言:javascript复制
create column family User with comparator = UTF8Type;

3.3. 更新数据对象集合(schema)

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

代码语言:javascript复制
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 的编码类型:

代码语言:javascript复制
assume User keys as utf8;

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

代码语言:javascript复制
set User['jsmith']['first'] = 'John';
set User['jsmith']['last'] = 'Smith';
set User['jsmith']['age'] = '38';

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

3.5. 读取数据

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

代码语言:javascript复制
get User['jsmith'];

也可以进行条件查询:

代码语言:javascript复制
get User where age = '38';

0 人点赞