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 coherencia causal para un grupo de operaciones y ejecutar transacciones ACID. MongoDB garantiza que los datos involucrados en tus operaciones transaccionales se mantengan coherentes, incluso si las operaciones encuentran 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

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

Ejemplo de transacción

El siguiente ejemplo demuestra cómo crear una sesión, realizar 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