Operaciones por lotes en 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.

MongoDB garantiza que los datos involucrados en sus operaciones de transacción permanezcan consistentes, incluso si las operaciones encuentran errores inesperados.

Sesiones

En MongoDB, las transacciones se ejecutan dentro de sesiones lógicas. Una sesión es un agrupamiento de operaciones relacionadas de lectura o escritura que se pretende ejecutar en secuencia. Las sesiones permiten la coherencia causal para un grupo de operaciones o te permiten ejecutar operaciones en una transacción ACID.

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.

El siguiente ejemplo muestra cómo crear una sesión llamando al método StartSession():

var client = new MongoClient("mongodb://localhost:27017");
var session = client.StartSession();

var client = new MongoClient("mongodb://localhost:27017");
var sessionOptions = new ClientSessionOptions
{
    CausalConsistency = true,
    DefaultTransactionOptions = new TransactionOptions(
         readConcern:  ReadConcern.Available,
         writeConcern:   WriteConcern.Acknowledged)
};
var session = client.StartSession(sessionOptions);

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