Amazon Keyspaces 中的 DML 语句（数据操作语言）

Name — Name(DML) 是一组 Cassandra 查询语言 (CQL) 语句，用于管理亚马逊密钥空间（适用于 Apache Cassandra）表上。可以使用 DML 语句在表中添加、修改或删除数据。

还可以使用 DML 语句查询表中的数据。（请注意，CQL 不支持联接或子查询。）

主题

SELECT
INSERT
更新
删除

SELECT

使用 SELECT 语句可查询数据。

语法


select_statement ::=  SELECT  [ JSON ] ( select_clause | '*' )
                      FROM table_name
                      [ WHERE 'where_clause' ]
                      [ ORDER BY 'ordering_clause' ]
                      [ LIMIT (integer | bind_marker) ]
                      [ ALLOW FILTERING ]
select_clause    ::=  selector [ AS identifier ] ( ',' selector [ AS identifier ] )
selector         ::=  column_name
                      | term
                      | CAST '(' selector AS cql_type ')'
                      | function_name '(' [ selector ( ',' selector )* ] ')'
where_clause     ::=  relation ( AND relation )*
relation         ::=  column_name operator term
                      TOKEN
operator         ::=  '=' | '<' | '>' | '<=' | '>=' | IN | CONTAINS | CONTAINS KEY
ordering_clause  ::=  column_name [ ASC | DESC ] ( ',' column_name [ ASC | DESC ] )*

示例


SELECT name, id, manager_id FROM "myGSGKeyspace".employees_tbl ;

SELECT JSON name, id, manager_id FROM "myGSGKeyspace".employees_tbl ;

有关将 JSON 编码的数据类型映射到 Amazon Keyspaces 数据类型的表，请参阅Amazon Keyspaces 数据类型的 JSON 编码。

使用IN关键字

的IN关键字指定一个或多个值的相等性。它可以应用于分区键和聚类列。结果按密钥的显示顺序返回SELECT声明。

示例


SELECT * from mykeyspace.mytable WHERE primary.key1 IN (1,2) and clustering.key1 = 2;
SELECT * from mykeyspace.mytable WHERE primary.key1 IN (1,2) and clustering.key1 <= 2;
SELECT * from mykeyspace.mytable WHERE primary.key1 = 1 and clustering.key1 IN (1, 2);
SELECT * from mykeyspace.mytable WHERE primary.key1 <= 2 and clustering.key1 IN (1, 2) ALLOW FILTERING;

有关该的更多信息IN关键词以及 Amazon Keyspaces 如何处理声明，请参阅在亚马逊密钥空间中使用SELECT语句IN运算符。

对结果进行排序

的ORDER BY子句指定返回结果的排序顺序。它将列名列表以及每列的排序顺序作为参数。您只能在排序子句中指定聚类列。不允许使用非聚类列。排序顺序选项是ASC用于上升和DESC用于降序排序。如果省略排序顺序，则使用聚类列的默认顺序。有关可能的排序顺序，请参阅在亚马逊密钥空间中对结果进行排序。

示例


SELECT name, id, division, manager_id FROM "myGSGKeyspace".employees_tbl WHERE id = '012-34-5678' ORDER BY division;

使用时ORDER BY与IN关键字，结果按页面排序。不支持在禁用分页的情况下进行完全重新排序。

代币

您可以应用它TOKEN函数到PARTITION KEY专栏应用它SELECT和WHERE条款。随着TOKEN函数，Amazon Keyspaces 根据映射的令牌值返回行PARTITION_KEY而不是看价值PARTITION KEY。

TOKEN不支持关系IN关键字。

示例


SELECT TOKEN(id) from my_table; 

SELECT TOKEN(id) from my_table WHERE TOKEN(id) > 100 and TOKEN(id) < 10000;

TTL

您可以使用TTL使用函数SELECT语句用于检索为列存储的过期时间（以秒为单位）。如果没有TTL值设置完毕，函数返回null。

示例


SELECT TTL(my_column) from my_table;

的TTL函数不能用于集合等多单元格列。

WRITETIME功能

您可以使用WRITETIME使用函数SELECT语句用于检索作为列值元数据存储的时间戳，该时间戳仅在表使用客户端时间戳时才会被存储为列值的元数据。有关更多信息，请参阅在 Amazon Keyspaces 中使用客户端时间戳：


SELECT WRITETIME(my_column) from my_table;

的WRITETIME函数不能用于集合等多单元格列。

注意

为了与既定的 Cassandra 驱动程序行为兼容，当您通过 Cassandra 驱动程序和开发者工具使用 Cassandra 查询语言 (CQL) API 调用对系统表执行操作时，不会强制执行基于标签的授权策略。有关更多信息，请参阅基于标签的亚马逊密钥空间资源访问权限：

INSERT

使用 INSERT 语句可向表添加行。

语法


insert_statement ::=  INSERT INTO table_name ( names_values | json_clause )
                      [ IF NOT EXISTS ]
                      [ USING update_parameter ( AND update_parameter )* ]
names_values     ::=  names VALUES tuple_literal
json_clause      ::=  JSON string [ DEFAULT ( NULL | UNSET ) ]                
names            ::=  '(' column_name ( ',' column_name )* ')'

示例


INSERT INTO "myGSGKeyspace".employees_tbl (id, name, project, region, division, role, pay_scale, vacation_hrs, manager_id)
VALUES ('012-34-5678','Russ','NightFlight','US','Engineering','IC',3,12.5, '234-56-7890') ;

更新参数

INSERT支持以下值update_parameter:

TTL— 以秒为单位的时间值。最大可配置值为 630720000 秒，相当于 20 年。
TIMESTAMP— Abigint表示自标准基准时间以来的微秒数的值，称为epoch: 格林尼治标准时间 1970 年 1 月 1 日 00:00:00。Amazon Keyspaces 中的时间戳必须介于过去 2 天和未来 5 分钟之间。

示例


INSERT INTO my_table (userid, time, subject, body, user)
        VALUES (B79CB3BA-745E-5D9A-8903-4A02327A7E09, 96a29100-5e25-11ec-90d7-b5d91eceda0a, 'Message', 'Hello','205.212.123.123')
        USING TTL 259200;

JSON

有关将 JSON 编码的数据类型映射到 Amazon Keyspaces 数据类型的表，请参阅Amazon Keyspaces 数据类型的 JSON 编码。

您可以使用JSON要插入 a 的关键字JSON-将地图编码为单行。对于表中存在但在 JSON 插入语句中省略的列，请使用DEFAULT UNSET以保留现有值。使用DEFAULT NULL在省略列的每一行中写入一个 NULL 值并覆盖现有值（收取标准写入费用）。DEFAULT NULL是默认选项。

示例


INSERT INTO "myGSGKeyspace".employees_tbl JSON '{"id":"012-34-5678",
                                                 "name": "Russ",
                                                 "project": "NightFlight",
                                                 "region": "US",
                                                 "division": "Engineering",
                                                 "role": "IC",
                                                 "pay_scale": 3,
                                                 "vacation_hrs": 12.5,
                                                 "manager_id": "234-56-7890"}';

如果 JSON 数据包含重复的密钥，则 Amazon Keyspaces 会存储密钥的最后一个值（类似于 Apache Cassandra）。在以下示例中，重复的密钥是id，值234-56-7890被使用。

示例


INSERT INTO "myGSGKeyspace".employees_tbl JSON '{"id":"012-34-5678",
                                                 "name": "Russ",
                                                 "project": "NightFlight",
                                                 "region": "US",
                                                 "division": "Engineering",
                                                 "role": "IC",
                                                 "pay_scale": 3,
                                                 "vacation_hrs": 12.5,
                                                 "id": "234-56-7890"}';

更新

使用 UPDATE 语句可修改表中的行。

语法


update_statement ::=  UPDATE table_name
                      [ USING update_parameter ( AND update_parameter )* ]
                      SET assignment ( ',' assignment )*
                      WHERE where_clause
                      [ IF ( EXISTS | condition ( AND condition )*) ]
update_parameter ::=  ( integer | bind_marker )
assignment       ::=  simple_selection '=' term
                     | column_name '=' column_name ( '+' | '-' ) term
                     | column_name '=' list_literal '+' column_name
simple_selection ::=  column_name
                     | column_name '[' term ']'
                     | column_name '.' `field_name
condition        ::=  simple_selection operator term

示例


UPDATE "myGSGKeyspace".employees_tbl SET pay_scale = 5 WHERE id = '567-89-0123' AND division = 'Marketing' ;

要递增 counter，请使用以下语法。有关更多信息，请参阅计数器：


UPDATE ActiveUsers SET counter = counter + 1  WHERE user = A70FE1C0-5408-4AE3-BE34-8733E5K09F14 AND action = 'click';

更新参数

UPDATE支持以下值update_parameter:

TTL— 以秒为单位的时间值。最大可配置值为 630720000 秒，相当于 20 年。
TIMESTAMP— Abigint表示自标准基准时间以来的微秒数的值，称为epoch: 格林尼治标准时间 1970 年 1 月 1 日 00:00:00。Amazon Keyspaces 中的时间戳必须介于过去 2 天和未来 5 分钟之间。

示例


UPDATE my_table (userid, time, subject, body, user)
        VALUES (B79CB3BA-745E-5D9A-8903-4A02327A7E09, 96a29100-5e25-11ec-90d7-b5d91eceda0a, 'Message', 'Hello again','205.212.123.123')
        USING TIMESTAMP '2022-11-03 13:30:54+0400';

删除

使用 DELETE 语句可从表中删除行。

语法


delete_statement ::=  DELETE [ simple_selection ( ',' simple_selection ) ]
                      FROM table_name
                      [ USING update_parameter ( AND update_parameter )* ]
                      WHERE where_clause
                      [ IF ( EXISTS | condition ( AND condition )*) ]

simple_selection ::=  column_name
                     | column_name '[' term ']'
                     | column_name '.' `field_name

condition        ::=  simple_selection operator term

其中：

table_name 是包含要删除的行的表。

示例


DELETE manager_id FROM "myGSGKeyspace".employees_tbl WHERE id='789-01-2345' AND division='Executive' ;

DELETE支持以下值为update_parameter:

TIMESTAMP— Abigint表示自标准基准时间以来的微秒数的值，称为epoch: 格林尼治标准时间 1970 年 1 月 1 日 00:00:00。

Javascript 在您的浏览器中被禁用或不可用。

要使用 Amazon Web Services 文档，必须启用 Javascript。请参阅浏览器的帮助页面以了解相关说明。

DDL 语句

内置函数