安装完Cassandra后我们就开始体验一下这个数据库的查询吧,传统的关系数据库使用的sql进行查询,而Cassandra使用的cql.

cql语法还是很多的,这里不一一详细阐述了,也没这个必要,具体的文档数不胜数,这里只是把最最常用的查询功能列举出来.

首先打开命令行(或是powershell)进入Cassandra安装目录下的bin文件夹,执行cqlsh.bat(powershell下执行cqlsh也ok).这里我进入的是powershell.

//进入cql客户端,powershell中直接用cqlsh登陆即可,cmd和命令行下需要使用cqlsh.bat进入 PS D:\apache-cassandra-2.1.7\bin> .\cqlshConnected to Test Cluster at 127.0.0.1:9042.[cqlsh 5.0.1 | Cassandra 2.1.7 | CQL spec 3.2.0 | Native protocol v3]Use HELP for help.WARNING: pyreadline dependency missing.  Install to enable tab completion.cqlsh>

先介绍一下keyspace,中文直译为键值空间,实际是一种命名空间的概念,这个和关系数据库中的数据库的地位类似.然后我们查询一下有哪些keyspace:

//显示keyspace cqlsh> describe keyspaces;mykeyspace  simplex  system_traces  system

结果显示查询到4个keyspace,红字表示部分.然后我们手动自己创建一个keyspace:

//创建keyspace cqlsh> CREATE KEYSPACE IF NOT EXISTS myCas WITH REPLICATION = {'class': 'SimpleStrategy','replication_factor':1};cqlsh> describe keyspaces;mycas  mykeyspace  simplex  system_traces  system

可以看到已经成功创建名字为mycas的keyspace.我们使用刚创建的keyspace:

//选择keyspace cqlsh> use mycas;cqlsh:mycas>

我们在当前keyspace下创建一个表user,并显示当前keyspace下的所有表:

//创建表 cqlsh:mycas> CREATE TABLE user (                       id int,                       user_name varchar,                       PRIMARY KEY (id) );cqlsh:mycas> describe tables;user

结果所示,当前keyspace下只有我们刚刚创建的user表.向表中插入一条数据:

//向表中添加数据 cqlsh> use mycas;cqlsh:mycas> INSERT INTO users (id,user_name) VALUES (1,'zhangsan');cqlsh:mycas> select * from users; id | user_name----+-----------  1 |  zhangsan

然后我们进行一下简单的条件查询:

//从表中查询数据 cqlsh:mycas> select * from users where id=1; id | user_name----+-----------  1 |  zhangsan(1 rows)cqlsh:mycas> select * from users where user_name='zhangsan';InvalidRequest: code=2200 [Invalid query] message="No secondary indexes on the restricted columns support the provided operators: "

可以看出查询主键可以,但是查询没有索引的user_name却无法查询.

我们创建一个索引后再次尝试:

//创建索引 cqlsh:mycas> create index on users(user_name);cqlsh:mycas> select * from users where user_name='zhangsan'; id | user_name----+-----------  1 |  zhangsan

试一下更新:

//更新表中数据 cqlsh:mycas> update users set user_name='lisi';SyntaxException: 
     
      cqlsh:mycas> update users set user_name='lisi' where id=1;cqlsh:mycas> select * from users; id | user_name----+-----------  1 |      lisi
     

可以看出只能按照条件进行更新.

试一下删除:

//删除表中数据 SyntaxException: 
     
      cqlsh:mycas> delete from users where id=1;cqlsh:mycas> select * from users; id | user_name----+-----------(0 rows)
     

可以看出删除也只能按照条件进行删除.

更多具体的命令可以参看Cassandra的官方cql文档,非常全面.