Transacciones

Overview

En esta guía, aprenderá a usar el controlador de C para realizar transacciones. Las transacciones permiten realizar una serie de operaciones que modifican los datos solo si se confirma la transacción completa. Si alguna operación de la transacción no se realiza correctamente, la biblioteca la detiene y descarta todos los cambios en los datos antes de que sean visibles. Esta característica se denomina atomicidad.

En MongoDB, las transacciones se ejecutan dentro de sesiones lógicas. Una sesión es una agrupación de operaciones de lectura o escritura relacionadas que se ejecutan secuencialmente. Las sesiones permiten la consistencia causal de un grupo de operaciones y ejecutarlas en una transacción compatible con ACID, que cumple con los requisitos de atomicidad, consistencia, aislamiento y durabilidad. MongoDB garantiza que los datos involucrados en las transacciones se mantengan consistentes, incluso si se producen errores inesperados.

Al utilizar el controlador C, puede crear una nueva sesión desde un mongoc_client_t instancia. Luego, puede usar la instancia mongoc_client_session_t resultante para realizar transacciones.

API de transacciones

En esta sección, aprenderá sobre las API de transacciones que ofrece el controlador C. Antes de iniciar una transacción, debe crear un mongoc_client_session_t mediante la función mongoc_client_start_session() en su instancia mongoc_client_t. A continuación, puede usar 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 devolución de llamada que modifica los datos de 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 devolución de llamada, 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 realizó 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), "}");
    
    if (!mongoc_collection_update_one(checking, filter, update_decrement, NULL, NULL, &error)) {
        fprintf(stderr, "Failed to update checking account: %s\n", error.message);
        return false;
    }
    if (!mongoc_collection_update_one(savings, filter, update_increment, NULL, NULL, &error)) {
        fprintf(stderr, "Failed to update savings account: %s\n", error.message);
        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, NULL, NULL, &error)) {
        fprintf(stderr, "Failed to insert receipt: %s\n", error.message);
        return false;
    }
    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;
}

Luego, ejecute el siguiente código para realizar la transacción. Este código realiza las siguientes acciones:

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

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

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, consulte las siguientes páginas del manual de MongoDB Server:

• Transacciones

• Sesiones de servidor

• Leer Aislamiento, Coherencia y Recencia

Para obtener más información sobre el cumplimiento de ACID, consulte el artículo ¿Qué son las propiedades ACID en los sistemas de administración de bases de datos? en el sitio web de MongoDB.