如何同步和更新非规范化的 cassandra 表

Question

我在使用 cassandra 开发 Spring 应用程序时偶然发现了一个问题。 通过实践，Cassandra 在设计数据模型时鼓励设计查询，而一个一直困扰我的阻止程序是当其中一个表更新它的值并且恰好发生特定值是另一个表上的主键时会发生什么？

见下图 Photo

在照片中，如果我们将用户电子邮件更新为另一个值，我通常会在 Spring cassandra 中进行保存，但是在执行批处理操作时，由于新的分区键，它会在 user_by_email 表中添加一个新条目。

您对此类问题的典型解决方案是什么？我考虑过先查询旧电子邮件，然后对 user_by_email 表进行删除，但这对我来说效率低下。

Answer 1

要使非规范化表保持同步，您需要使用 CQL BATCH 语句。它将插入、更新和删除分组到一个原子事务中。看看这篇文章，我已经更详细地解释了它——https://community.datastax.com/articles/2744/。

例如，如果您要维护这些表：

• movies
• movies_by_actor
• movies_by_genre

然后您将在 CQL BATCH 中对更新进行分组，如下所示：

BEGIN BATCH
  INSERT INTO movies (...) VALUES (...);
  INSERT INTO movies_by_actor (...) VALUES (...);
  INSERT INTO movies_by_genre (...) VALUES (...);
APPLY BATCH;

请注意，还可以执行 UPDATE 和 DELETE 语句以及批量条件写入。

上面的例子只是在cqlsh中说明而已，实际并没有用到。这是一个使用 Java 驱动程序的示例BatchStatement：

SimpleStatement insertMovies =
  SimpleStatement.newInstance(
    "INSERT INTO movies (...) VALUES (?, ...)", <some_values>);

SimpleStatement insertMoviesByActor =
  SimpleStatement.newInstance(
    "INSERT INTO movies_by_actor (...) VALUES (?, ...)", <some_values>);

SimpleStatement insertMoviesByGenre =
  SimpleStatement.newInstance(
    "INSERT INTO movies_by_genre (...) VALUES (?, ...)", <some_values>);

BatchStatement batch =
  BatchStatement.builder(DefaultBatchType.LOGGED)
    .addStatement(insertMovies)
    .addStatement(insertMoviesByActor)
    .addStatement(insertMoviesByGenre)
    .build();

详情请见Java driver Batch statements。干杯！