/ /

Java Sync Driver

Docs Home

Librerías de clientes

Java

Java Sync Driver

Docs Home

Librerías de clientes

Java

Java Sync Driver

Transacciones

Overview

En esta guía, puede aprender a utilizar el controlador Java para realizar transacciones. Las transacciones permiten ejecutar una serie de operaciones que no modifican ningún dato hasta que se confirma la transacción. Si alguna operación de la transacción devuelve un error, el controlador la cancela y descarta todos los cambios de datos antes de que sean 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. Las sesiones permiten ejecutar operaciones en una transacción compatible con ACID, que cumple con los requisitos de atomicidad, consistencia, aislamiento y durabilidad.

Al utilizar el controlador Java, 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.

Importante

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

Coherencia causal

MongoDB permite la consistencia causal en ciertas sesiones de cliente. El modelo de consistencia causal garantiza que, en un sistema distribuido, las operaciones dentro de una sesión se ejecuten en un orden causal. Los clientes observan resultados consistentes con las relaciones causales o las dependencias entre operaciones. Por ejemplo, si se realiza una serie de operaciones donde una depende lógicamente del resultado de otra, las lecturas posteriores reflejan la 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 controlador debe habilitar la opción de consistencia causal. Esta opción está habilitada por defecto.
Las operaciones deben ejecutarse en una sola sesión en un solo subproceso. De lo contrario, las sesiones o subprocesos deben comunicarse entre sí los valores de tiempo de la operación y del clúster. Para ver un ejemplo de dos sesiones que comunican estos valores, consulte los ejemplos de consistencia causal en el manual de MongoDB Server.
Debes utilizar una preocupación de lectura MAJORITY.
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 brindan las sesiones causalmente consistentes:

Garantía	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 anterior.
Escrituras monotónicas	Si una operación de escritura debe preceder a otras operaciones de escritura, el servidor ejecuta esta operación de escritura primero. Por ejemplo, si llama a `insertOne()` para insertar un documento y luego llama a `updateOne()` para modificar el documento insertado, el servidor ejecuta 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 ejecuta primero las operaciones de lectura. Por ejemplo, si llama a `find()` para recuperar un documento y luego llama a `deleteOne()` para eliminar el documento recuperado, el servidor ejecuta primero la operación de búsqueda.

Tip

Para obtener más información sobre los conceptos mencionados en esta sección, consulte las siguientes entradas del manual de MongoDB Server:

Métodos

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 describe los métodos que puede usar para administrar su transacción:

Método	Descripción
`startTransaction()`	Starts a new transaction for this session with the default transaction options. Pass an instance of `TransactionOptions` as a parameter to start a transaction with given options. You cannot start a transaction if there's already an active transaction running in the session. Parameter: `TransactionOptions transactionOptions`
`abortTransaction()`	Ends the active transaction for this session. Returns an error if there is no active transaction for the session or the transaction was previously ended.
`commitTransaction()`	Commits the active transaction for this session. Returns an error if there is no active transaction for the session or if the transaction was ended.
`withTransaction()`	Starts a new transaction for this session and runs the given function. This method handles retries, committing, and aborting transactions. Pass an instance of `TransactionBody` as a parameter that defines the operations you want to execute within the transaction. Parameter: `TransactionBody<T> transactionBody`

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

Tip

Tiempo de espera de transacción

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

Ejemplo

El siguiente ejemplo demuestra cómo puede crear una sesión, crear una transacción y confirmar una operación de inserción de varios documentos mediante los siguientes pasos:

Cree una sesión desde el cliente utilizando el método startSession().
Establecer opciones de transacción para configurar el comportamiento de la transacción.
Utilice el método withTransaction() para iniciar una transacción.
Insertar varios documentos. El método withTransaction() ejecuta, confirma y cancela la transacción. Si alguna operación genera 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 necesita mayor control sobre sus transacciones, puede usar el método startTransaction(). Puede usar este método junto con los métodos commitTransaction() y abortTransaction() descritos en la sección anterior para administrar manualmente el ciclo de vida de las transacciones.

Nota

Operaciones paralelas no admitidas

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

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:

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.

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

Operaciones compuestas

Operaciones en conjuntos de réplicas