/ /

Transacciones

Overview

En esta guía, puedes aprender a usar el driver de Java para realizar transacciones. Transacciones que te permiten ejecutar una serie de operaciones que no cambian ningún dato hasta que la transacción se confirme. Si alguna operación en la transacción devuelve un error, el controlador cancela la transacción y descarta todos los cambios de datos antes de que lleguen a ser visibles.

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 ejecutar operaciones en una transacción conforme con ACID, es decir, una transacción que cumple con las expectativas de atomicidad, coherencia, aislamiento y durabilidad.

Cuando se utiliza el controlador Java, se puede crear una nueva sesión a partir de una instancia de MongoClient como un tipo de ClientSession. Recomendamos reutilizar el cliente para múltiples sesiones y transacciones en lugar de crear uno nuevo cada vez.

Advertencia

Utiliza un ClientSession solo con el MongoClient (o el MongoDatabase o MongoCollection asociados) que lo creaste. El uso de un ClientSession con un MongoClient diferente resulta en errores de operación.

Importante

Debe incluir el session como parámetro para cualquier operación que desee incluir en una transacción.

Coherencia causal

MongoDB habilita la coherencia causal en ciertas sesiones de clientes. El modelo de coherencia causal garantiza que en un sistema distribuido, las operaciones dentro de una sesión se ejecuten en un orden causal. Los clientes observan resultados que son coherentes con las relaciones causales, o las dependencias entre las operaciones. Por ejemplo, si realizas una serie de operaciones donde una depende lógicamente del resultado de otra, las lecturas subsecuentes reflejarán esa relación de dependencia.

Para garantizar la coherencia causal, las sesiones de los clientes deben cumplir los siguientes requisitos:

Al iniciar una sesión, el driver debe habilitar la opción de coherencia causal. Esta opción está habilitada por defecto.
Las operaciones deben ejecutarse en una sola sesión en un solo hilo. De lo contrario, las sesiones o hilos deben comunicarse entre sí los valores de operation time y tiempo de clúster. Para ver un ejemplo de dos sesiones que comunican estos valores, consulte los Ejemplos de coherencia causal en el manual del servidor de MongoDB.
Debes usar un MAJORITY nivel de consistencia de lectura.
Debe usar un MAJORITY nivel de confirmación de escritura (write concern). Este es el valor predeterminado de nivel de confirmación de escritura (write concern).

La siguiente tabla describe las garantías que ofrecen las sesiones coherentes causales:

garantías	Descripción
Leer las escrituras	Las operaciones de lectura reflejan los resultados de las operaciones de escritura anteriores.
Lecturas monotónicas	Las operaciones de lectura no devuelven resultados que reflejen un estado de datos anterior al de una operación de lectura previa.
Escrituras monotónicas	Si una operación de escritura debe preceder a otras operaciones de escritura, el servidor ejecutará primero esta operación de escritura. Por ejemplo, si llamas a `insertOne()` para insertar un documento y luego llamas a `updateOne()` para modificar el documento insertado, el servidor ejecutará primero la operación de inserción.
Las escrituras siguen a las lecturas	Si una operación de escritura debe seguir a otras operaciones de lectura, el servidor primero ejecuta las operaciones de lectura. Por ejemplo, si llamas a `find()` para recuperar un documento y luego llamas a `deleteOne()` para borrar el documento recuperado, el servidor ejecutará primero la operación find.

Tip

Para aprender más sobre los conceptos mencionados en esta sección, consulta las siguientes entradas del manual del servidor MongoDB:

Métodos

Crea ClientSession utilizando el método startSession() en tu instancia MongoClient. Luego puede modificar el estado de la sesión mediante los métodos proporcionados por el ClientSession. La siguiente tabla describe los métodos que puedes utilizar para gestionar tu transacción:

Método	Descripción
`startTransaction()`	Inicia una nueva transacción para esta sesión con las opciones de transacción predeterminadas. Pase una instancia de `TransactionOptions` como parámetro para iniciar una transacción con las opciones especificadas. No se puede iniciar una transacción si ya hay una transacción activa en ejecución en la sesión. Parámetro: `TransactionOptions transactionOptions`
`abortTransaction()`	Finaliza la transacción activa para esta sesión. Devuelve un error si no hay una transacción activa para la sesión o si la transacción se terminó previamente.
`commitTransaction()`	Comete la transacción activa para esta sesión. Devuelve un error si no hay una transacción activa para la sesión o si la transacción fue finalizada.
`withTransaction()`	Inicia una nueva transacción para esta sesión y ejecuta la función especificada. Este método gestiona los reintentos, la confirmación y la cancelación de transacciones. Pase una instancia de `TransactionBody` como parámetro que define las operaciones que desea ejecutar dentro de la transacción. Parámetro: `TransactionBody<T> transactionBody`

Un ClientSession también tiene métodos para recuperar propiedades de sesión y modificar propiedades de sesión mutables. Consulta la documentación de la API para aprender más sobre estos métodos.

Tip

Tiempo de espera de la transacción

Puedes establecer un límite en la cantidad de tiempo que las operaciones pueden tardar en completarse en tus transacciones. Para obtener más información, consulta la sección Transacciones de la guía "Limitar el tiempo de ejecución del servidor".

Ejemplo

El siguiente ejemplo demuestra cómo puedes crear una sesión, crear una transacción y realizar una operación multi-documento con los siguientes pasos:

Cree una sesión desde el cliente usando el método startSession().
Establece opciones de transacción para configurar el comportamiento de la transacción.
Utiliza el método withTransaction() para iniciar una transacción.
Inserte varios documentos. El método withTransaction() ejecuta, confirma y cancela la transacción. Si alguna operación resulta en errores, withTransaction() gestiona la cancelación de la transacción.

String connectionString = "<connection string>"; // Replace with your connection string
try (MongoClient mongoClient = MongoClients.create(connectionString)) {
    MongoDatabase database = mongoClient.getDatabase("transaction_db");
    MongoCollection<Document> collection = database.getCollection("books");
    // Sets transaction options
    TransactionOptions transactionOptions = TransactionOptions.builder()
            .writeConcern(WriteConcern.MAJORITY)
            .build();
    try (ClientSession session = mongoClient.startSession()) {
        // Uses withTransaction and lambda for transaction operations
        session.withTransaction(() -> {
            collection.insertMany(session, Arrays.asList(
                    new Document("title", "The Bluest Eye").append("author", "Toni Morrison"),
                    new Document("title", "Sula").append("author", "Toni Morrison"),
                    new Document("title", "Song of Solomon").append("author", "Toni Morrison")
            ));
            return null; // Return value as expected by the lambda
        }, transactionOptions);
    }
} catch (Exception e) {
    e.printStackTrace();
}

Si requieres más control sobre tus transacciones, puedes utilizar el método startTransaction(). Puedes usar este método con los métodos commitTransaction() y abortTransaction() descritos en la sección anterior para gestionar manualmente el ciclo de vida de la transacción.

Nota

Operaciones paralelas no admitidas

El controlador de Java no permite ejecutar operaciones en paralelo dentro de una sola transacción.

Información Adicional

Para **aprender** más sobre los conceptos mencionados en esta **guía**, consulta las siguientes páginas en el manual del **servidor**:

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.

Para ver un tutorial que ejecuta transacciones ACID multidocumento en una aplicación de ejemplo, consulta Tutorial: Ejecuta transacciones ACID multidocumento.

Documentación de la API

Para aprender más sobre cualquiera de los tipos o métodos discutidos en esta guía, consulta la siguiente documentación de la API:

Volver

Operaciones compuestas

Tutorial: Transacciones multi-documento