执行简单的CQL操作

Posted 2020-07-08 学无止境

CQL是Cassandra Query Language的缩写，目前作为Cassandra默认并且主要的交互接口。CQL和SQL比较类似，主要的区别是Cassandra不支持join或子查询，除了支持通过Hive进行批处理分析。要说这个Cassandra以前的接口主要是Thrift API，这个没有用过，不做评价。

一、创建keyspace

作为对照，你可以把keyspace理解成一个SQL数据库实例，当然它们毕竟是不同的：Cassandra的keyspace是用来定义数据是如何在节点间复制的。通常情况下，应该为一个应用程序建立一个keyspace。

CREATE KEYSPACE IF NOT EXISTS pimin_net
WITH REPLICATION = {‘class‘: ‘SimpleStrategy‘,‘replication_factor‘:1};

上面语句的意思是判断是否存在keyspace，如果不存在则建立keyspace；使用的复制参数是简单策略，复制因子是1。暂时先不管里面深层次的东西，我们先按照简单原则实现。

二、创建表

虽然说Cassandra是面向列的分布式数据库，但是它也有表的概念。创建之前先use pimin_net。

USE pimin_net;
 
CREATE TABLE users (
id int,
user_name varchar,
PRIMARY KEY (id) );

 

这样就建立了一张用户表，为了简单起见，就只有两个字段，看起来和oracle、mysql这些是不是很像？

三、对表的CRUD

已经有了一张用户表，我们就向里面插入一些数据，对它进行查询、更新和删除操作。

INSERT INTO users (id,user_name) VALUES (1,‘china‘);
INSERT INTO users (id,user_name) VALUES (2,‘taiwan‘);
SELECT * FROM users;

结果：

cqlsh:pimin_net> SELECT * FROM users;

 id | user_name
----+-----------

(0 rows)
cqlsh:pimin_net> INSERT INTO users (id,user_name) VALUES (1,‘china‘);
cqlsh:pimin_net> INSERT INTO users (id,user_name) VALUES (2,‘taiwan‘);
cqlsh:pimin_net> SELECT * FROM users;

 id | user_name
----+-----------
  1 |     china
  2 |    taiwan

(2 rows)
cqlsh:pimin_net>

 

UPDATE users SET user_name = ‘china2014‘ WHERE id = 1;
SELECT * FROM users;
DELETE FROM users WHERE id = 1;
SELECT * FROM users;

结果：

cqlsh:pimin_net> UPDATE users SET user_name = ‘china2014‘ WHERE id = 1;
cqlsh:pimin_net> SELECT * FROM users;

 id | user_name
----+-----------
  1 | china2014
  2 |    taiwan

(2 rows)
cqlsh:pimin_net> DELETE FROM users WHERE id = 1;
cqlsh:pimin_net> SELECT * FROM users;

 id | user_name
----+-----------
  2 |    taiwan

(1 rows)
cqlsh:pimin_net>

 重要：不同于传统的RDBMS，Cassandra不能使用DELETE FROM users;这样的表达式，必须有WHERE条件！