Transacciones

Overview

En esta guía, puede aprender a utilizar el controlador C para realizar transacciones. Las transacciones te permiten realizar una serie de operaciones que cambian los datos solo si toda la transacción se completa. Si alguna operación en la transacción no tiene éxito, la librería detiene la transacción y descarta todos los cambios de datos antes de que se hagan visibles. Esta funcionalidad se llama atomicidad.

En MongoDB, las transacciones se ejecutan dentro de sesiones lógicas. Una sesión es un agrupamiento de operaciones de lectura o escritura relacionadas que se pretende ejecutar secuencialmente. Las sesiones permiten la coherencia causal para un grupo de operaciones y te permiten ejecutar operaciones en una transacción compatible con ACID, que es una transacción que cumple con una expectativa de atomicidad, coherencia, aislamiento y durabilidad. MongoDB garantiza que los datos involucrados en las operaciones de tus transacciones permanecen coherentes, incluso si las operaciones encuentran errores inesperados.

Cuando utilizas el driver de C, puedes crear una nueva sesión desde una instancia de mongoc_client_t. Luego, puedes utilizar la instancia resultante de mongoc_client_session_t para realizar transacciones.

APIs de transacciones

En esta sección, puede aprender sobre las APIs de transacciones proporcionadas por el controlador C. Antes de iniciar una transacción, debes crear un mongoc_client_session_t utilizando la función mongoc_client_start_session() en tu instancia mongoc_client_t. Luego, puede utilizar cualquiera de las siguientes API para realizar una transacción:

• Convenient API
• Core API

Ejemplo de transacción

Este ejemplo define una función de retorno que modifica los datos en las colecciones de la base de datos sample_bank para una transacción bancaria. El código realiza las siguientes acciones:

1. Define la función de retorno, que recibe la instancia mongoc_client_session_t como parámetro.

2. Crea mongoc_collection_t instancias para acceder a las colecciones de destino.

3. Especifica el número de cuenta y el monto que se transferirá entre cuentas.

4. Actualiza los saldos del cliente para reflejar la transferencia de dinero.

5. Registra un recibo de la transacción con una marca de tiempo.

6. Imprime un mensaje si la transacción se comprometió correctamente.

bool
transaction_callback(mongoc_client_session_t *session, void *ctx, bson_t **reply,
                      bson_error_t *error)
{
    BSON_UNUSED(ctx);
    BSON_UNUSED(reply);
    mongoc_client_t *client = mongoc_client_session_get_client(session);
    mongoc_collection_t *checking = mongoc_client_get_collection(client, "sample_bank", "checking");
    mongoc_collection_t *savings = mongoc_client_get_collection(client, "sample_bank", "savings");
    mongoc_collection_t *receipts = mongoc_client_get_collection(client, "sample_bank", "receipts");
    const char *account_id = "123456";
    int transfer_amount = 1000;
    bson_t *filter = BCON_NEW("account_id", BCON_UTF8(account_id));
    bson_t *update_decrement = BCON_NEW("$inc", "{", "balance", BCON_INT32(-transfer_amount), "}");
    bson_t *update_increment = BCON_NEW("$inc", "{", "balance", BCON_INT32(transfer_amount), "}");
    bson_t *opts = bson_new();
    BSON_ASSERT(mongoc_client_session_append(session, opts, error));
    if (!mongoc_collection_update_one(checking, filter, update_decrement, opts, NULL, error)) {
        fprintf(stderr, "Failed to update checking account: %s\n", error->message);
        bson_destroy(opts);
        return false;
    }
    if (!mongoc_collection_update_one(savings, filter, update_increment, opts, NULL, error)) {
        fprintf(stderr, "Failed to update savings account: %s\n", error->message);
        bson_destroy(opts);
        return false;
    }
    bson_t *receipt = BCON_NEW("account_id", BCON_UTF8(account_id),
                                "amount", BCON_INT32(transfer_amount),
                                "timestamp", BCON_DATE_TIME(bson_get_monotonic_time()));
    if (!mongoc_collection_insert_one(receipts, receipt, opts, NULL, error)) {
        fprintf(stderr, "Failed to insert receipt: %s\n", error->message);
        bson_destroy(opts);
        return false;
    }
    bson_destroy(opts);
    mongoc_collection_destroy(checking);
    mongoc_collection_destroy(savings);
    mongoc_collection_destroy(receipts);
    bson_destroy(filter);
    bson_destroy(update_decrement);
    bson_destroy(update_increment);
    bson_destroy(receipt);
    printf("Transaction successful!");
    return true;
}

A continuación, ejecuta el siguiente código para realizar la transacción. Este código completa las siguientes acciones:

1. Crea una sesión desde el cliente usando la función mongoc_client_start_session().

2. Llama a la función mongoc_client_session_with_transaction() para gestionar la transacción, pasando como parámetros la sesión y la función de retorno.

mongoc_client_session_t *session = mongoc_client_start_session(client, NULL, NULL);
if (!session) {
    fprintf(stderr, "Failed to start session\n");
    mongoc_client_destroy(client);
    return EXIT_FAILURE;
}
bool result =
    mongoc_client_session_with_transaction(session,
                                            (mongoc_client_session_with_transaction_cb_t) transaction_callback,
                                            NULL, NULL, NULL, &error);
if (!result) {
    fprintf(stderr, "Transaction error: %s\n", error.message);
}
mongoc_client_session_destroy(session);
mongoc_client_destroy(client);
mongoc_cleanup();

Transaction successful!

Información Adicional

Para obtener más información sobre los conceptos mencionados en esta guía, consulta las siguientes páginas del manual de MongoDB Server:

• Transacciones

• Sesiones de servidor

• Leer Aislamiento, Coherencia y Recencia

Para aprender más sobre ACID compliance, consulte el ¿Cuáles son las propiedades ACID en los sistemas de gestión de bases de datos? artículo en el sitio web de MongoDB.