我有一个Cassandra的批处理语句,其中包含相同分区键的删除和插入语句,其中删除是第一条语句,插入是第二条语句。批处理语句如何执行这些语句?它们执行的顺序是我们添加语句的顺序吗?
CREATE TABLE purchases (user text PRIMARY KEY, balance bigint);
接下来,我将执行一个包含INSERT和DELETE操作的批处理。我会先执行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(按照这个顺序),那么查询将没有返回结果。