cassandra数据库入门-2_cassandra cql select

Cassandra的安装：

请参考博客：

本章介绍 Cassandra 查询语言 shell 并解释如何使用其命令。

默认情况下，Cassandra 提供了一个提示 Cassandra 查询语言 shell (cqlsh)，允许用户与其进行通信。 使用此 shell，您可以执行 Cassandra 查询语言 (CQL)。

使用 cqlsh，您可以 定义模式，插入数据，和执行查询。

[hadoop@linux bin]$ cqlsh
Connected to Test Cluster at 127.0.0.1:9042.
[cqlsh 5.0.1 | Cassandra 2.1.2 | CQL spec 3.2.0 | Native protocol v3]
Use HELP for help.
cqlsh>

启动 cqlsh
使用命令 cqlsh 启动 cqlsh，如下所示。 它提供 Cassandra cqlsh 提示符作为输出。

Cqlsh 命令
Cqlsh 有一些允许用户与之交互的命令。 下面列出了这些命令。

记录的 Shell 命令
下面给出的是 Cqlsh 记录的 shell 命令。 这些是用于执行任务的命令，例如显示帮助主题、退出 cqlsh、描述等。

HELP - 显示所有 cqlsh 命令的帮助主题。

CAPTURE - 捕获命令的输出并将其添加到文件中。

CONSISTENCY - 显示当前的一致性级别，或设置新的一致性级别。

COPY - 将数据复制到 Cassandra 或从 Cassandra 复制数据。

DESCRIBE - 描述当前的 Cassandra 集群及其对象。

EXPAND - 垂直扩展查询的输出。

EXIT - 使用此命令，您可以终止 cqlsh。

PAGING - 启用或禁用查询分页。

SHOW - 显示当前 cqlsh 会话的详细信息，例如 Cassandra 版本、主机或数据类型假设。

SOURCE - 执行包含 CQL 语句的文件。

TRACING - 启用或禁用请求跟踪。

CQL 数据定义命令
CREATE KEYSPACE - 在 Cassandra 中创建一个 KeySpace。

USE - 连接到创建的 KeySpace。

ALTER KEYSPACE - 更改 KeySpace 的属性。

DROP KEYSPACE - 删除 KeySpace

CREATE TABLE - 在 KeySpace 中创建一个表。

ALTER TABLE - 修改表的列属性。

DROP TABLE - 删除一个表。

TRUNCATE - 从表中删除所有数据。

CREATE INDEX - 在表的单个列上定义新索引。

DROP INDEX - 删除命名索引。

CQL 数据操作命令
INSERT - 为表格中的一行添加列。

UPDATE - 更新一行的列。

DELETE - 从表中删除数据。

BATCH - 一次执行多个 DML 语句。

CQL条款
SELECT - 此子句从表中读取数据

WHERE - where 子句与 select 一起使用以读取特定数据。

ORDERBY - orderby 子句与 select 一起使用以按特定顺序读取特定数据。

除了 CQL 命令之外，Cassandra 还提供了文档化的 shell 命令。 下面给出的是 Cassandra 记录的 shell 命令。

Help

Capture

此命令捕获命令的输出并将其添加到文件中。 例如，查看以下将输出捕获到名为 Outputfile 的文件的代码。

cqlsh> CAPTURE '/home/hadoop/CassandraProgs/Outputfile'

当我们在终端中键入任何命令时，输出将被给定的文件捕获。 下面给出了使用的命令和输出文件的快照。

cqlsh:tutorialspoint> select * from emp;

 您可以使用以下命令关闭捕获。

cqlsh:tutorialspoint> capture off;

Consistency

此命令显示当前的一致性级别，或设置新的一致性级别。

cqlsh:tutorialspoint> CONSISTENCY
Current consistency level is 1.

Copy

此命令将数据复制到 Cassandra 或从 Cassandra 复制到文件。 下面给出了将名为 emp 的表复制到文件 myfile 的示例。

cqlsh:tutorialspoint> COPY emp (emp_id, emp_city, emp_name, emp_phone,emp_sal) TO ‘myfile’;
4 rows exported in 0.034 seconds.

Describe

此命令描述了当前的 Cassandra 集群及其对象。 下面解释了此命令的变体。

Describe cluster - 此命令提供有关集群的信息。

cqlsh:tutorialspoint> describe cluster;
 
Cluster: Test Cluster
Partitioner: Murmur3Partitioner
 
Range ownership:
                  -658380912249644557 [127.0.0.1]
                  -2833890865268921414 [127.0.0.1]
                  -6792159006375935836 [127.0.0.1] 

Describe Keyspaces −此命令列出集群中的所有键空间。 下面给出了这个命令的用法。

cqlsh:tutorialspoint> describe keyspaces;

system_traces system tp tutorialspoint

Describe tables −此命令列出键空间中的所有表。 下面给出了这个命令的用法。

cqlsh:tutorialspoint> describe tables;
emp

Describe table − 此命令提供表的描述。 下面给出了这个命令的用法。

cqlsh:tutorialspoint> describe table emp;
 
CREATE TABLE tutorialspoint.emp (
   emp_id int PRIMARY KEY,
   emp_city text,
   emp_name text,
   emp_phone varint,
   emp_sal varint
) WITH bloom_filter_fp_chance = 0.01
   AND caching = '{"keys":"ALL", "rows_per_partition":"NONE"}'
   AND comment = ''
   AND compaction = {'min_threshold': '4', 'class':
   'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy',
   'max_threshold': '32'}
	
   AND compression = {'sstable_compression':
   'org.apache.cassandra.io.compress.LZ4Compressor'}
	
   AND dclocal_read_repair_chance = 0.1
   AND default_time_to_live = 0
   AND gc_grace_seconds = 864000
   AND max_index_interval = 2048
   AND memtable_flush_period_in_ms = 0
   AND min_index_interval = 128
   AND read_repair_chance = 0.0
   AND speculative_retry = '99.0PERCENTILE';
CREATE INDEX emp_emp_sal_idx ON tutorialspoint.emp (emp_sal);

Describe Type

此命令用于描述用户定义的数据类型。 下面给出了这个命令的用法。

cqlsh:tutorialspoint> describe type card_details;
 
CREATE TYPE tutorialspoint.card_details (
   num int,
   pin int,
   name text,
   cvv int,
   phone set<int>,
   mail text
);

Describe Types

此命令列出所有用户定义的数据类型。 下面给出了这个命令的用法。 假设有两种用户定义的数据类型：card 和 card_details。

cqlsh:tutorialspoint> DESCRIBE TYPES;

card_details card

Expand

该命令用于扩展输出。 在使用此命令之前，您必须打开扩展命令。 下面给出了这个命令的用法。

cqlsh:tutorialspoint> expand on;
cqlsh:tutorialspoint> select * from emp;
 
@ Row 1
-----------+------------
    emp_id | 1
  emp_city | Hyderabad
  emp_name | ram
 emp_phone | 9848022338
   emp_sal | 50000
  
@ Row 2
-----------+------------
    emp_id | 2
  emp_city | Delhi
  emp_name | robin
 emp_phone | 9848022339
   emp_sal | 50000
  
@ Row 3
-----------+------------
    emp_id | 4
  emp_city | Pune
  emp_name | rajeev
 emp_phone | 9848022331
   emp_sal | 30000
  
@ Row 4
-----------+------------
    emp_id | 3
  emp_city | Chennai
  emp_name | rahman
 emp_phone | 9848022330
   emp_sal | 50000
(4 rows)

注意 - 您可以使用以下命令关闭扩展选项。

cqlsh:tutorialspoint> expand off;
Disabled Expanded output.

Exit

此命令用于终止 cql shell。

Show

此命令显示当前 cqlsh 会话的详细信息，例如 Cassandra 版本、主机或数据类型假设。 下面给出了这个命令的用法。

cqlsh:tutorialspoint> show host;
Connected to Test Cluster at 127.0.0.1:9042.

cqlsh:tutorialspoint> show version;
[cqlsh 5.0.1 | Cassandra 2.1.2 | CQL spec 3.2.0 | Native protocol v3]

Source

使用此命令，您可以执行文件中的命令。 假设我们的输入文件如下 −

您可以执行包含命令的文件，如下所示。

cqlsh:tutorialspoint> source '/home/hadoop/CassandraProgs/inputfile';
 
 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad |   ram    | 9848022338 | 50000
      2 | Delhi     |   robin  | 9848022339 | 50000
      3 | Pune      |   rajeev | 9848022331 | 30000
      4 | Chennai   |   rahman | 9848022330 | 50000
(4 rows)

使用 Cqlsh 创建Keyspace

Cassandra 中的键空间是定义节点上数据复制的名称空间。 一个集群的每个节点包含一个键空间。 下面给出了使用 CREATE KEYSPACE 语句创建键空间的语法。

句法

CREATE KEYSPACE <identifier> WITH <properties>

CREATE KEYSPACE “KeySpace Name”
WITH replication = {'class': ‘Strategy name’, 'replication_factor' : ‘No.Of   replicas’};
 
CREATE KEYSPACE “KeySpace Name”
WITH replication = {'class': ‘Strategy name’, 'replication_factor' : ‘No.Of  replicas’}
 
AND durable_writes = ‘Boolean value’;

CREATE KEYSPACE 语句有两个属性：replication 和 durable_writes。

复制

复制选项用于指定副本放置策略和所需的副本数。 下表列出了所有副本放置策略。

使用此选项，您可以指示 Cassandra 是否使用 commitlog 更新当前 KeySpace。 此选项不是强制性的，默认情况下，它设置为 true。

例子
下面给出了创建 KeySpace 的示例。

在这里，我们创建了一个名为 TutorialsPoint 的 KeySpace。

我们正在使用第一个副本放置策略，即 Simple Strategy。

我们选择复制因子为 1 个副本。

cqlsh.> CREATE KEYSPACE tutorialspoint
WITH replication = {'class':'SimpleStrategy', 'replication_factor' : 3};

确认
您可以使用 Describe 命令验证表是否已创建。 如果您在键空间上使用此命令，它将显示创建的所有键空间，如下所示。

cqlsh> DESCRIBE keyspaces;

tutorialspoint system system_traces 

持久写入
默认情况下，表的 durable_writes 属性设置为 true，但也可以设置为 false。 您不能将此属性设置为单纯形策略。

例子
下面给出的示例演示了持久写入属性的用法。

cqlsh> CREATE KEYSPACE test
 WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy', 'datacenter1' : 3 }
 AND DURABLE_WRITES = false;

确认
您可以通过查询 System Keyspace 来验证测试 KeySpace 的 durable_writes 属性是否设置为 false。 此查询为您提供所有 KeySpaces 及其属性。

cqlsh> SELECT * FROM system_schema.keyspaces;
 
  keyspace_name | durable_writes |                                       strategy_class | strategy_options
----------------+----------------+------------------------------------------------------+----------------------------
 
           test |          False | org.apache.cassandra.locator.NetworkTopologyStrategy | {"datacenter1" : "3"}
 
 tutorialspoint |           True |          org.apache.cassandra.locator.SimpleStrategy | {"replication_factor" : "4"}
 
         system |           True |           org.apache.cassandra.locator.LocalStrategy | { }
 
  system_traces |           True |          org.apache.cassandra.locator.SimpleStrategy | {"replication_factor" : "2"}
 
(4 rows)

在这里您可以观察到测试 KeySpace 的 durable_writes 属性被设置为 false。

使用键空间
您可以使用关键字 USE 使用创建的 KeySpace。 其语法如下 -

Syntax:USE <identifier>

例子
在以下示例中，我们使用 KeySpace  tutorialspoint。

cqlsh> USE tutorialspoint;
cqlsh:tutorialspoint>

使用Java API完成keyspace的创建

您可以使用 Session 类的 execute() 方法创建一个 Keyspace。 按照下面给出的步骤使用 Java API 创建密钥空间。

第一步：创建集群对象
首先，创建 com.datastax.driver.core 包的 Cluster.builder 类实例，如下所示。

//Creating Cluster.Builder object

Cluster.Builder builder1 = Cluster.builder();

使用 Cluster.Builder 对象的 addContactPoint() 方法添加一个联系点（节点的 IP 地址）。 此方法返回 Cluster.Builder。

//Adding contact point to the Cluster.Builder object

Cluster.Builder builder2 = build.addContactPoint( "127.0.0.1" );

使用新的构建器对象，创建一个集群对象。 为此，您在 Cluster.Builder 类中有一个名为 build() 的方法。 以下代码显示了如何创建集群对象。

//Building a cluster
Cluster cluster = builder.build();

您可以在一行代码中构建一个集群对象，如下所示。

Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();

第 2 步：创建会话对象
使用 Cluster 类的 connect() 方法创建 Session 对象的实例，如下所示。

Session session = cluster.connect( );

此方法创建一个新会话并对其进行初始化。 如果您已经有一个键空间，则可以通过将字符串格式的键空间名称传递给此方法来将其设置为现有键空间，如下所示。

Session session = cluster.connect(“ Your keyspace name ” );

第 3 步：执行查询
您可以使用 Session 类的 execute() 方法执行 CQL 查询。 将查询以字符串格式或作为 Statement 类对象传递给 execute() 方法。 无论您以字符串格式传递给此方法，都将在 cqlsh 上执行。

在此示例中，我们正在创建一个名为 tp 的 KeySpace。 我们使用第一个副本放置策略，即简单策略，我们选择复制因子为 1 个副本。

您必须将查询存储在字符串变量中并将其传递给 execute() 方法，如下所示。

String query = "CREATE KEYSPACE tp WITH replication "
   + "= {'class':'SimpleStrategy', 'replication_factor':1}; ";
session.execute(query);

第四步：使用KeySpace
您可以使用 execute() 方法使用创建的 KeySpace，如下所示。

execute(“ USE tp ” );

下面给出了使用 Java API 在 Cassandra 中创建和使用密钥空间的完整程序。

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
 
public class Create_KeySpace {
 
   public static void main(String args[]){
 
      //Query
      String query = "CREATE KEYSPACE tp WITH replication "
         + "= {'class':'SimpleStrategy', 'replication_factor':1};";
                    
      //creating Cluster object
      Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
    
      //Creating Session object
      Session session = cluster.connect();
     
      //Executing the query
      session.execute(query);
     
      //using the KeySpace
      session.execute("USE tp");
      System.out.println("Keyspace created"); 
   }
}

更改KeySpace
ALTER KEYSPACE 可用于更改属性，例如副本数和 KeySpace 的 durable_writes。 下面给出了此命令的语法。

ALTER KEYSPACE <identifier> WITH <properties>

例子
ALTER KEYSPACE “KeySpace Name”
WITH replication = {'class': ‘Strategy name’, 'replication_factor' : ‘No.Of  replicas’};

ALTER KEYSPACE 的属性与 CREATE KEYSPACE 相同。 它有两个属性：replication 和 durable_writes。

Replication
复制选项指定副本放置策略和所需的副本数。

Durable_writes
使用此选项，您可以指示 Cassandra 是否使用 commitlog 更新当前 KeySpace。 此选项不是强制性的，默认情况下，它设置为 true。

例子
下面给出的是更改 KeySpace 的示例。

在这里，我们正在更改一个名为 TutorialsPoint 的 KeySpace。

我们正在将复制因子从 1 更改为 3。

cqlsh.> ALTER KEYSPACE tutorialspoint
WITH replication = {'class':'NetworkTopologyStrategy', 'replication_factor' : 3};

修改 Durable_writes

您还可以更改 KeySpace 的 durable_writes 属性。 下面给出的是测试 KeySpace 的 durable_writes 属性。

SELECT * FROM system.schema_keyspaces;
 
  keyspace_name | durable_writes |                                       strategy_class | strategy_options
----------------+----------------+------------------------------------------------------+----------------------------
           test |          False | org.apache.cassandra.locator.NetworkTopologyStrategy | {"datacenter1":"3"}
 
 tutorialspoint |           True |          org.apache.cassandra.locator.SimpleStrategy | {"replication_factor":"4"}
 
         system |           True |           org.apache.cassandra.locator.LocalStrategy | { }
 
  system_traces |           True |          org.apache.cassandra.locator.SimpleStrategy | {"replication_factor":"2"}
(4 rows)

ALTER KEYSPACE test
WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'datacenter1' : 3}
AND DURABLE_WRITES = true;

再一次，如果您验证 KeySpaces 的属性，它将产生以下输出。

SELECT * FROM system.schema_keyspaces;
  keyspace_name | durable_writes |                                       strategy_class | strategy_options
----------------+----------------+------------------------------------------------------+----------------------------
           test |           True | org.apache.cassandra.locator.NetworkTopologyStrategy | {"datacenter1":"3"}
 
 tutorialspoint |           True |          org.apache.cassandra.locator.SimpleStrategy | {"replication_factor":"4"}
 
         system |           True |           org.apache.cassandra.locator.LocalStrategy | { }
 
  system_traces |           True |          org.apache.cassandra.locator.SimpleStrategy | {"replication_factor":"2"}
 
(4 rows)

使用Java修改 Keyspace 

您可以使用 Session 类的 execute() 方法更改键空间。 按照下面给出的步骤使用 Java API 更改密钥空间

您可以使用 Session 类的 execute() 方法执行 CQL 查询。 将查询以字符串格式或作为 Statement 类对象传递给 execute() 方法。 无论您以字符串格式传递给此方法，都将在 cqlsh 上执行。

在这个例子中，

我们正在改变一个名为 tp 的键空间。 我们正在将复制选项从简单策略更改为网络拓扑策略。

我们正在将 durable_writes 更改为 false

您必须将查询存储在字符串变量中并将其传递给 execute() 方法，如下所示。

//Query
String query = "ALTER KEYSPACE tp WITH replication " + "=   {'class':'NetworkTopologyStrategy', 'datacenter1':3}" +" AND DURABLE_WRITES = false;";
session.execute(query);

下面给出了使用 Java API 在 Cassandra 中创建和使用密钥空间的完整程序。

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
 
public class Alter_KeySpace {
   public static void main(String args[]){
 
      //Query
      String query = "ALTER KEYSPACE tp WITH replication " + "= {'class':'NetworkTopologyStrategy', 'datacenter1':3}"
         + "AND DURABLE_WRITES = false;";
 
      //Creating Cluster object
      Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
   
      //Creating Session object
      Session session = cluster.connect();
 
      //Executing the query
      session.execute(query);
 
      System.out.println("Keyspace altered");
   }
}

删除键空间
您可以使用命令 DROP KEYSPACE 删除 KeySpace。 下面给出了删除 KeySpace 的语法。

句法

DROP KEYSPACE <identifier>

DROP KEYSPACE “KeySpace name”

使用 Java API 删除键空间

您可以使用 Session 类的 execute() 方法创建键空间。 按照下面给出的步骤使用 Java API 删除密钥空间。

您可以使用 Session 类的 execute() 方法执行 CQL 查询。 将查询以字符串格式或作为 Statement 类对象传递给 execute() 方法。 无论您以字符串格式传递给此方法，都将在 cqlsh 上执行。

在以下示例中，我们将删除名为 tp 的键空间。 您必须将查询存储在字符串变量中并将其传递给 execute() 方法，如下所示。

String query = "DROP KEYSPACE tp; ";

session.execute(query);

下面给出了使用 Java API 在 Cassandra 中创建和使用密钥空间的完整程序。

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
 
public class Drop_KeySpace {
 
   public static void main(String args[]){
 
      //Query
      String query = "Drop KEYSPACE tp";
 
      //creating Cluster object
      Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
    
      //Creating Session object
      Session session = cluster.connect();
    
      //Executing the query
      session.execute(query);
      System.out.println("Keyspace deleted");
   }
}