与卡桑德拉CQL一起更新

Question

我是卡桑德拉的新手，我正在尝试使用此CQL查询更新表：

UPDATE analytics SET counter = ? WHERE hash = ?;

我使用DataTax PHP驱动程序在PHP中工作，此语句的代码如下：

$statement = $session->prepare("UPDATE analytics SET counter = ? WHERE hash = ?;");
$session->execute($statement, new Cassandra\ExecutionOptions(array('arguments' => array($count, $hash))));

表格：

CREATE TABLE IF NOT EXISTS analytics (domain VARCHAR, page VARCHAR, ip INET, attributes MAP <VARCHAR, VARCHAR>, hash VARCHAR, counter INT, date TIMESTAMP, PRIMARY KEY(hash, domain, date));

当我执行语句时，我得到错误“缺少强制的PRIMARY KEY部分域”，因此我添加了子句ALLOW FILTERING：

UPDATE analytics SET counter = ? WHERE hash = ? ALLOW FILTERING;

但是我得到另一个错误，“第1：48行在'允许'处缺少EOF”。这些查询出了什么问题？

Answer 1

您真的希望更新一个散列的所有计数器值而不考虑日期吗？

无论如何，请注意索引。使用索引时，请确保包含分区键，以便您的查询只命中一个分区。否则，您的集群范围的操作可能会在生产中超时。

如果您的数据模型不支持查询，但您需要它进行分析，那么一个不错的选择是使用 Apache Spark，并将其用于批处理类型作业。

Answer 2

当您想要更新列时，您必须传递所有主键。所以把所有主键放在where子句中。

Answer 3

根据您遇到的错误，我猜您创建了具有复合主键（哈希，域）的表。为了更新cassandra中的记录，您必须提供整个键，即两个值，因此您的查询应如下所示：

更新分析设置计数器=计数器1哪里哈希=？和域=？

如需了解更多信息，请查阅以下网址

它说：在更新和删除语句中，必须限制所有主键列...