具有轻量级事务的 Cassandra Datastax BatchStatement

Question

我在使用 Datastax java 驱动程序结合 BatchStatement 和轻量级事务时遇到了困难。

考虑以下几点：

String batch = 
"BEGIN BATCH " 
+ "Update mykeyspace.mytable set record_version = 102 where id = '" + id + "' if record_version = 101; 
" <additional batched statements>
+ "APPLY BATCH";

Row row = session.execute(batch).one();
if (! row.getBool("[applied]")) {
    throw new RuntimeException("Optimistic Lock Failure!");
}

这按预期运行，并指示我的轻量级事务是否成功并且我的批处理是否已应用。一切都很好。但是，如果我使用 BatchStatement 尝试相同的事情，我会遇到几个问题：

-- 我的轻量级事务“if”子句被忽略，并且始终应用更新

-- "Row" 结果为空，无法执行最后的 row.getBool("[applied]") 检查。

String update = "Update mykeyspace.mytable set record_version = ? where id = ? if record_version = ?";
PreparedStatement pStmt = getSession().prepare(update);
BatchStatement batch = new BatchStatement();
batch.add(new BoundStatement(pStmt).bind(newVersion, id, oldVersion));

Row row = session.execute(batch).one();                     <------ Row is null!
if (! row.getBool("[applied]")) {
    throw new RuntimeException("Optimistic Lock Failure!");
}

我做错了吗？或者这是 datastax BatchStatement 的限制？

Answer 1

第二个代码 sn-p 在我看来不正确（没有构造函数采用字符串，或者您错过了准备好的语句）。

您可以尝试以下方法吗：

String update = "Update mykeyspace.mytable set record_version = ? where id = ? if record_version = ?";
PreparedStatement pStmt = session.prepare(update);
BatchStatement batch = new BatchStatement();
batch.add(pStmt.bind(newVersion, id, recordVersion));

Row row = session.execute(batch).one();
if (! row.getBool("[applied]")) {
    throw new RuntimeException("Optimistic Lock Failure!");
}

Answer 2

我遇到了同样的问题。我昨天开了一张 DataStax 支持的票，得到了以下答案：

目前不支持将轻量级事务作为 BATCH 中的 PreparedStatements。这就是您遇到此问题的原因。

在 Cassandra 中包含此功能的近期路线图中没有任何内容。

这表明消除 PreparedStatement 将解决该问题。我打算自己尝试一下，但还没有。

[更新]

我一直在尝试解决这个问题。根据之前的反馈，我假设限制是使用 PreparedStatement 进行条件更新。

我尝试将我的代码更改为不使用 PreparedStatement，但在使用包含 RegularStatement 而不是 PreparedStatement 的 BatchStatement 时仍然无法正常工作。

BatchStatement batchStatement = new BatchStatement(); 
batchStatement.add(conditionalRegularStatement); 
session.executeQuery(batchStatement);

他们唯一可行的方法是使用包含批处理的原始查询字符串执行 executeQuery。

session.executeQuery("BEGIN BATCH " + conditionalRegularStatement.getQueryString() + " APPLY BATCH"); 

Answer 3

更新：

此问题已在 CASSANDRA-7337 中解决，该问题已在 C* 2.0.9 中修复。

最新的 DataStax Enterprise 现在是 2.0.11。如果您看到此问题 ==> 升级！