如何在Cassandra中执行具有多个操作的事务

How to perform a transaction with multiple operations in Cassandra

本文关键字：操作 事务 Cassandra 执行      更新时间：2023-10-16

我想在Cassandra中执行一个具有多个写入操作（对不同表进行5次插入/更新）的事务，但如果其中任何一个操作失败，则不应写入其余操作（回滚每个操作或使整个事务失败）。

请让我知道在Cassandra中执行此操作的正确方法是什么以及如何执行（欢迎举一个例子）。

是的，您可以使用记录的批处理功能来原子化地实现这一点。请注意，您确实会对性能产生影响。请参阅C++驱动程序的BATCH语句文档部分。

下面是一个如何在C++中实现这一点的示例，取自上面的文档链接。它演示了如何将INSERT、UPDATE和DELETE一起批处理：

/* This logged batch will makes sure that all the mutations eventually succeed */
CassBatch* batch = cass_batch_new(CASS_BATCH_TYPE_LOGGED);
/* Statements can be immediately freed after being added to the batch */
{
   CassStatement* statement
      = cass_statement_new(cass_string_init("INSERT INTO example1(key, value) VALUES ('a', '1')"), 0);
   cass_batch_add_statement(batch, statement);
   cass_statement_free(statement);
}
{
   CassStatement* statement
      = cass_statement_new(cass_string_init("UPDATE example2 set value = '2' WHERE key = 'b'"), 0);
   cass_batch_add_statement(batch, statement);
   cass_statement_free(statement);
}
{
   CassStatement* statement
      = cass_statement_new(cass_string_init("DELETE FROM example3 WHERE key = 'c'"), 0);
   cass_batch_add_statement(batch, statement);
   cass_statement_free(statement);
}
CassFuture* batch_future = cass_session_execute_batch(session, batch);
/* Batch objects can be freed immediately after being executed */
cass_batch_free(batch);
/* This will block until the query has finished */
CassError rc = cass_future_error_code(batch_future);
printf("Batch result: %sn", cass_error_desc(rc));
cass_future_free(batch_future);
相关文章：