Transacciones

Overview

En esta guía, puedes aprender cómo usar el driver Java Reactive Streams para realizar transacciones. Las transacciones te permiten ejecutar una serie de operaciones que no se aplican hasta que se completen correctamente todos los cambios de datos. Si alguna operación en la transacción falla, el driver cancela la transacción y descarta todos los cambios en los datos antes de que sean 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. Con las sesiones, puedes activar Consistencia causal para un grupo de operaciones y ejecución de transacciones ACID. MongoDB garantiza la consistencia de los datos involucrados en sus transacciones, incluso si se producen errores inesperados.

Cuando uses el driver de flujos reactivos Java puedes crear una nueva sesión a partir de un MongoClient instancia como un tipo ClientSession. Recomendamos reutilizar su cliente para múltiples sesiones y transacciones en lugar de crear una nueva instancia de cliente cada vez.

Métodos de transacciones

Cree una instancia ClientSession con el método startSession() en su instancia MongoClient. A continuación, puede modificar el estado de la sesión con los métodos proporcionados por ClientSession. La siguiente tabla detalla los métodos que puede usar para administrar su transacción:

Ejemplo de transacción

El siguiente ejemplo muestra cómo crear una sesión, crear una transacción e insertar documentos en varias colecciones en una sola transacción. El código ejecuta los siguientes pasos:

1. Crea una sesión desde el cliente usando el método startSession()

2. Inicia una transacción utilizando el método startTransaction()

3. Inserta documentos en las colecciones restaurants y movies

4. Confirma la transacción utilizando el método commitTransaction()

MongoClient mongoClient = MongoClients.create(settings);
MongoDatabase restaurantsDatabase = mongoClient.getDatabase("sample_restaurants");
MongoCollection<Document> restaurants = restaurantsDatabase.getCollection("restaurants");
MongoDatabase moviesDatabase = mongoClient.getDatabase("sample_mflix");
MongoCollection<Document> movies = moviesDatabase.getCollection("movies");
Mono.from(mongoClient.startSession())
        .flatMap(session -> {
            // Begins the transaction
            session.startTransaction();
            // Inserts documents in the given order
            return Mono.from(restaurants.insertOne(session, new Document("name", "Reactive Streams Pizza").append("cuisine", "Pizza")))
                    .then(Mono.from(movies.insertOne(session, new Document("title", "Java: Into the Streams").append("type", "Movie"))))
                    // Commits the transaction
                    .flatMap(result -> Mono.from(session.commitTransaction())
                            .thenReturn(result))
                    .onErrorResume(error -> Mono.from(session.abortTransaction()).then(Mono.error(error)))
                    .doFinally(signalType -> session.close());
        })
        // Closes the client after the transaction completes
        .doFinally(signalType -> mongoClient.close())
        // Prints the results of the transaction
        .subscribe(
                result -> System.out.println("Transaction succeeded"),
                error -> System.err.println("Transaction failed: " + error)
        );

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**:

• Transacciones

• Sesiones de servidor

• Coherencia causal