Cassandra - 按主键更新所有记录，输入不匹配错误

Question

我最近开始使用 Cassandra，我了解 Cassandra 会阻止用户通过主键删除表中的所有记录。 因为您还需要提供所有集群密钥。

我尝试使用标准 sql，例如：

UPDATE my_table SET is_deleted = 'true' WHERE COUNTRY = 'XXX' AND user_id IN (SELECT user_id FROM my_table WHERE COUNTRY = 'XXX');

我得到的错误是：

SyntaxException: line 1:113 mismatched input 'SELECT' expecting ')' (... 1 AND user_id IN ([SELECT]...)

请指教。

Answer 1

您不能在 cassandra 中使用嵌套查询。

您必须使用两个单独的查询。

首先从mytable中选择所有user_id

SELECT user_id FROM mytable WHERE COUNTRY = 'XXX'

Second 对于前面步骤中找到的每个 user_id

UPDATE my_table SET is_deleted = 'true' WHERE COUNTRY = 'XXX' AND user_id = 'XXX'

您可以使用executeAsync 执行第二个查询。

如果user_id是分区键，你也可以在查询中使用更新，但建议使用小尺寸user_id列表

 UPDATE my_table SET is_deleted = 'true' WHERE COUNTRY = 'XXX' AND user_id in ('XXX', 'XXY', 'XXZ')