Cassandra批处理语句 - 执行顺序

提问于 2024-04-24T10:07:02+08:00

浏览次

4

我有一个Cassandra的批处理语句，它包含一个删除和相同分区键的insert语句，其中delete是第一个语句，insert是第二个 . 批处理语句如何执行这些语句？是否按照相同的顺序，我们添加了语句？

1 回答

7
不，它不按指定的顺序执行它们 . 要强制执行特定的执行顺序，可以添加 USING TIMESTAMP 子句 . 查看文档以获取更多信息：http://docs.datastax.com/en/cql/3.1/cql/cql_reference/batch_r.html

使用时间戳如何维护执行顺序 . 例如，如果上面的例子（删除并插入相同的分区键），最终结果应该是插入的记录 . 这可能通过添加时间戳？

是 . 我将结合上面链接和DELETE documentation中的示例进行演示，并首先创建一个名为 purchases 的简单表，其中包含两个字段：
```
CREATE TABLE purchases (user text PRIMARY KEY, balance bigint);
```
接下来，我将使用INSERT和DELETE执行批处理 . 我最后会做DELETE，但是比INSERT更早的时间戳：
```
BEGIN BATCH
  INSERT INTO purchases (user, balance) VALUES ('user1', -8) USING TIMESTAMP 1432043350384;
  DELETE FROM purchases USING TIMESTAMP 1432043345243 WHERE user='user1';
APPLY BATCH;
```
当我查询 userid 时：
```
aploetz@cqlsh:stackoverflow2> SELECT user, balance, writetime(balance) FROM purchases WHERE user='user1';

 user  | balance | writetime(balance)
-------+---------+--------------------
 user1 |      -8 |      1432043350384

(1 rows)
```
如您所见，INSERT持续存在，因为它具有最新的时间戳 . 如果我只是从cqlsh提示符中运行INSERT和DELETE（按此顺序），则查询将不返回任何内容 .
回复于 2024-04-24T10:07:02+08:00

相关问题