/ /

Driver Rust

Docs Home

Librerías de clientes

Rust

Driver Rust

Docs Home

Librerías de clientes

Rust

Driver Rust

Transacciones

Overview

En esta guía, puedes aprender a usar el driver de Rust para realizar transacciones. Las transacciones permiten realizar una serie de operaciones que cambian datos sólo si la transacción completa está confirmada. Si alguna operación en la transacción no tiene éxito, el driver detiene la transacción y descarta todos los cambios de datos antes de que se hagan visibles. Esta funcionalidad se denomina atomicidad.

En MongoDB, las transacciones se ejecutan dentro de sesiones lógicas. Una sesión es un grupo de operaciones de lectura o escritura relacionadas que deseas ejecutar de manera secuencial. Las sesiones permiten la coherencia causal para un grupo de operaciones y le permiten ejecutar operaciones en una transacción compatible con ACID, que es una transacción que cumple con una expectativa de atomicidad, consistencia, aislamiento y durabilidad. MongoDB garantiza que los datos involucrados en tus operaciones de transacción permanezcan coherentes, incluso si las operaciones encuentran errores inesperados.

Al usar el controlador Rust, puedes crear una nueva sesión desde un Client instancia como tipo ClientSession. Puedes mejorar el rendimiento de tu aplicación reutilizando tu cliente para varias sesiones y transacciones en lugar de crear un cliente nuevo cada vez.

Advertencia

Utilice un ClientSession solo en operaciones que se ejecuten en el Client que lo creó. Usar un ClientSession con un Client diferente da como resultado errores de operación.

Métodos

Crea ClientSession utilizando el método start_session() en tu instancia Client. Luego puedes modificar el estado de sesión utilizando los métodos proporcionados por el tipo ClientSession. La siguiente tabla describe estos métodos:

Método	Descripción
`start_transaction()`	Starts a new transaction, configured according to an optional `TransactionOptions` parameter, on this session. The session must be passed into each operation within the transaction, or the operation will run outside of the transaction. Errors returned from operations run within the transaction might include a `TRANSIENT_TRANSACTION_ERROR` label, which indicates that the entire transaction can be ended, then retried with the expectation that it will succeed. Parameter: `TransactionOptions`
`commit_transaction()`	Commits the active transaction for this session. This method returns an error if there is no active transaction for the session or the transaction was previously ended. This method might return an error that includes an `UNKNOWN_TRANSACTION_COMMIT_RESULT` label, which indicates that it is unknown if the committed transaction satisfies the set write concern. If you encounter this error, it is safe to retry the commit until the write concern is satisfied or the method returns an error without the label.
`abort_transaction()`	Ends the active transaction for this session. This method returns an error if there is no active transaction for the session or if the transaction was committed or ended.
`with_transaction()`	Starts a transaction on this session and runs the given callback, then commits or ends the transaction. When you use this method to perform a transaction, the driver automatically handles any errors, so you can choose to omit error handling code. Because the callback returns a future and can be run multiple times, the Rust language closure borrowing rules for captured values can be restrictive. So, the `with_transaction()` method accepts a context parameter that is passed to the callback. Parameters: context `C`, callback `FnMut(&'a mut ClientSession, &'a mut C)`, `TransactionOptions`

Importante

Métodos que se pueden ejecutar en transacciones

Para ejecutar tareas de MongoDB dentro de transacciones, se deben utilizar los métodos con el sufijo _with_session(). Estos métodos aceptan una instancia de ClientSession como parámetro.

Por ejemplo, para borrar un documento, por lo general se puede usar el método delete_one(). Sin embargo, para borrar un documento dentro de una transacción, se debe usar el método delete_one_with_session() y pasar la sesión como parámetro.

Ejemplo

El siguiente código define la función de retorno insert_media() que insertará datos en las colecciones books y films:

async fn insert_media(session: &mut ClientSession) -> Result<(), Error> {
    let books_coll = session
        .client()
        .database("db")
        .collection::<Document>("books");
    let films_coll = session
        .client()
        .database("db")
        .collection::<Document>("films");
    books_coll.insert_one_with_session(
        doc! { 
            "name": "Sula", 
            "author": "Toni Morrison"
        },
        None,
        session
    ).await?;
    films_coll.insert_one_with_session(
        doc! { "name": "Nostalgia", "year": 1983 },
        None,
        session
    ).await?;
    Ok(())
}

El siguiente código completa las siguientes acciones para realizar la transacción:

Crea una sesión desde el cliente utilizando el método start_session().
Utiliza el método with_transaction() para iniciar una transacción y ejecutar la función de retorno insert_media() dentro de la transacción.

let mut session = client.start_session(None).await?;
session
    .with_transaction((), |session, _| insert_media(session).boxed(), None)
    .await?;
println!("Successfully committed transaction!");

Successfully committed transaction!

Si necesitas más control sobre tus transacciones, consulta la Documentación de la API de ClientSession para encontrar un ejemplo que muestre cómo crear y confirmar una transacción manualmente.

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 obtener más información sobre las operaciones de inserción, consulta la Guía de Insertar documentos.

Documentación de la API

Para obtener más información sobre los métodos y tipos mencionados en esta guía, vea la siguiente documentación de la API:

Volver

Indexes

Colecciones de series de tiempo