使用 Scala 更新 Cassandra DB 中的字符串列表列

Question

我是 Cassandra 和 Scala 的新手，我正在研究一个 Kafka 消费者（用 Scala 编写），它必须根据接收到的数据更新 Cassandra 上的一行字段。 到目前为止没有问题。

在这一行中，一个字段是一个字符串列表，当我进行更新时，这个字段没有改变，所以我必须给它自己分配相同的字符串列表。

UPDATE keyspaceName.tableName
SET fieldToChange = newValue
WHERE id = idValue
AND fieldA = '${currentRow.getString("fieldA")}'
AND fieldB = ${currentRow.getInt("fieldB")}
...
AND fieldX =  ${currentRow.getList("fieldX", classOf[String]).toString}
...

但我什至收到异常：

com.datastax.driver.core.exceptions.SyntaxError: line 19:49 no viable alternative at input ']' (... 482                   AND fieldX =  [[listStringItem1]]...)

我目前还没有找到任何可以帮助我通过网络的东西

Answer 1

问题在于 Scala 的列表字符串表示与 Cassandra's representation of the list 不匹配，因此会产生错误。

与其直接在代码中构造 CQL 语句，不如使用PreparedStatement 并将变量绑定到它：

1. 首先，它将加快执行速度，因为 Cassandra 不会单独解析每个语句；
2. 绑定变量会更容易，因为您不需要关心相应的字符串表示

但是使用 Scala 时要非常小心 - Java 驱动程序需要 Java 的列表、集合、映射和基本类型，如整数等。您可以查看 java-driver-scala-extras package，但您需要自己编译它，因为它在 Maven Central 上不可用。