Как выполнить транзакцию с несколькими операциями в Cassandra

Question

Я хочу выполнить транзакцию с несколькими операциями записи (~ 5 вставок/обновлений в разные таблицы) в Cassandra, но если какой-либо из них не работает, то остальные не должны записываться (либо откат каждой операции, либо отказ всей транзакции).

Пожалуйста, сообщите мне, что подходит для выполнения этого в Кассандре и как это сделать (пример будет приветствоваться).

Answer 1

Да, вы можете использовать зарегистрированную функциональность партии для выполнения этого атомарно. Обратите внимание, что вы получаете удар по производительности. См. Раздел документации BATCH Statements драйвера C++.

Вот пример того, как это сделать на 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: %s\n", cass_error_desc(rc)); 

cass_future_free(batch_future);