Transacciones

Overview

En esta guía, puede aprender a utilizar el controlador MongoDB.NET/C# 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 la consistencia causal para un grupo de operaciones o ejecutar operaciones en una transacción ACID. MongoDB garantiza que los datos involucrados en las transacciones se mantengan consistentes, incluso si se producen errores inesperados.

Al utilizar el controlador .NET/C#, puede crear una nueva sesión desde un MongoClient Instancia de tipo IClientSession. Recomendamos reutilizar el cliente para múltiples sesiones y transacciones en lugar de instanciar un nuevo cliente cada vez.

Métodos

Cree una instancia IClientSession mediante el método sincrónico StartSession() o el asincrónico StartSessionAsync() en su instancia MongoClient. A continuación, puede modificar el estado de la sesión mediante el conjunto de métodos proporcionado por la interfaz IClientSession. Seleccione una de las siguientes opciones. Synchronous Methods y Asynchronous Methods pestañas para conocer los métodos para administrar su transacción:

Ejemplo

Este ejemplo muestra cómo puede crear una sesión, crear una transacción e insertar documentos en múltiples colecciones dentro de la transacción a través de los siguientes pasos:

1. Cree una sesión desde el cliente utilizando el método StartSession().

2. Utilice el método StartTransaction() para iniciar una transacción.

3. Insertar documentos en las colecciones books y films.

4. Confirme la transacción utilizando el método CommitTransaction().

var books = database.GetCollection<Book>("books");
var films = database.GetCollection<Film>("films");
// Begins transaction
using (var session = mongoClient.StartSession())
{
    session.StartTransaction();
    try
    {
        // Creates sample data
        var book = new Book
        {
            Title = "Beloved",
            Author = "Toni Morrison",
            InStock = true
        };
        var film = new Film
        {
            Title = "Star Wars",
            Director = "George Lucas",
            InStock = true
        };
        // Inserts sample data
        books.InsertOne(session, book);
        films.InsertOne(session, film);
        // Commits our transaction
        session.CommitTransaction();
    } 
    catch (Exception e)
    {
        Console.WriteLine("Error writing to MongoDB: " + e.Message);
        return;
    }
    // Prints a success message if no error thrown
    Console.WriteLine("Successfully committed transaction!");
}

Successfully committed transaction!

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:

• Transacciones

• Sesiones de servidor

• Leer Aislamiento, Coherencia y Recencia