Cassandra批处理语句 - 执行顺序

Question

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

Answer 1

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

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

是.我将结合上面链接中的示例和DELETE文档来演示,并从创建一个名为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(按此顺序),则查询将不返回任何内容.