/ /

Escritura de datos

Docs Home

/ /

Driver de Java Reactive Streams

Escritura de datos

Docs Home

Librerías de clientes

Java

Driver de Java Reactive Streams

Escritura de datos

Transacciones

Overview

En esta guía, aprenderá a usar el controlador Java Reactive Streams para realizar transacciones. Las transacciones permiten ejecutar una serie de operaciones que no se aplican hasta que todos los cambios en los datos se realicen correctamente. Si alguna operación de la transacción falla, el controlador la cancela y descarta todos los cambios en los datos sin que se vuelvan visibles.

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. Con las sesiones, se puede habilitar 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.

Al utilizar el controlador Java Reactive Streams, puede crear una nueva sesión desde un MongoClient Instancia de tipo ClientSession. Recomendamos reutilizar el cliente para múltiples sesiones y transacciones en lugar de instanciar un nuevo cliente cada vez.

Advertencia

Use un ClientSession solo con el MongoClient (o el MongoDatabase o MongoCollection asociado) que lo creó. Usar un ClientSession con un MongoClient diferente genera errores de operación.

Datos de muestra

Los ejemplos de esta guía utilizan las colecciones y de los sample_restaurants.restaurants sample_mflix.movies conjuntos de datos de muestra de Atlas. Para aprender a crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de muestra, consulte Empezar.

Importante

Proyecto Reactor librería

Esta guía utiliza la biblioteca Project Reactor para consumir Publisher las instancias devueltas por los métodos del controlador Java Reactive Streams. Para obtener más información sobre la biblioteca Project Reactor y cómo usarla, consulte la sección "Introducción" en la documentación de Reactor. Para obtener más información sobre cómo usamos los métodos de la biblioteca Project Reactor en esta guía, consulte la guía "Escribir datos en MongoDB".

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:

Método	Descripción
`startTransaction()`	Starts a new transaction, configured with the given options, on this session. Throws an exception if there is already a transaction in progress for the session. To learn more about this method, see the startTransaction() page in the MongoDB Server manual.
`abortTransaction()`	Ends the active transaction for this session. Throws an exception if there is no active transaction for the session or if the transaction is already committed or ended. To learn more about this method, see the abortTransaction() page in the MongoDB Server manual.
`commitTransaction()`	Commits the active transaction for this session. Throws an exception if there is no active transaction for the session or if the transaction was ended. To learn more about this method, see the commitTransaction() page in the MongoDB Server manual.

Tip

Tiempo de espera de transacción

Puede establecer un límite de tiempo para las operaciones de sus transacciones. Para obtener más información, consulte la sección "Transacciones" de la guía "Limitar el tiempo de ejecución del servidor".

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:

Crea una sesión desde el cliente utilizando el método startSession()
Inicia una transacción utilizando el método startTransaction()
Inserta documentos en las colecciones restaurants y movies
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)
        );

Nota

Operaciones paralelas no admitidas

El controlador Java Reactive Streams no admite la ejecución de operaciones paralelas dentro de una sola transacción.

Si usa MongoDB Server v8.0 o posterior, puede realizar operaciones de escritura en varios espacios de nombres dentro de una sola transacción mediante operaciones de escritura masiva. Para obtener más información, consulte la sección "Escritura masiva del cliente" de la guía "Operaciones de escritura masiva".

Información Adicional

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

Documentación de la API

Para obtener más información sobre cualquiera de los tipos o métodos analizados en esta guía, consulte la siguiente documentación de API:

Volver

Guardado masivo

GridFS