Operações em lote em transações

Visão geral

Neste guia, você pode aprender como usar o Driver MongoDB .NET/C# para executar transações. Astransações permitem que você execute uma série de operações que não alteram nenhum dado até que a transação seja confirmada. Se qualquer operação na transação retornar um erro, o driver cancelará a transação e descartará todas as alterações de dados antes que elas se tornem visíveis.

O MongoDB garante que os dados envolvidos em suas operações de transação permaneçam consistentes, mesmo que as operações encontrem erros inesperados.

Sessões

No MongoDB, as transações são executadas dentro de sessões lógicas. Uma sessão é um agrupamento de operações de leitura ou escrita relacionadas que você pretende executar sequencialmente. As sessões permitem consistência causal para um grupo de operações ou permitem que você execute operações em uma transação ACID.

Ao usar o driver .NET/C#, você pode criar uma nova sessão a partir de uma instância MongoClient como tipo IClientSession . Recomendamos que você reutilize seu cliente para várias sessões e transações, em vez de fazer a instância de um novo cliente a cada vez.

O exemplo seguinte mostra como criar uma sessão chamando o 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

Crie um IClientSession utilizando o método StartSession() síncrono ou o método assíncrono StartSessionAsync() em sua instância do MongoClient . Você pode então modificar o estado da sessão usando o conjunto de métodos fornecido pela interface IClientSession . Selecione a partir dos seguintes separadores Synchronous Methods e Asynchronous Methods para saber mais sobre os métodos para gerir a sua transação:

Exemplo

Este exemplo mostra como criar uma sessão, criar uma transação e inserir documentos em várias coleções dentro da transação por meio das seguintes etapas:

1. Crie uma sessão a partir do cliente usando o método StartSession().

2. Crie um objeto TransactionOptions para configurar a transação.

3. Use o método StartTransaction() para iniciar uma transação.

4. Insira documentos nas coleções books e films .

5. Confirme a transação usando o método CommitTransaction() .

var books = database.GetCollection<Book>("books");
var films = database.GetCollection<Film>("films");
// Begins transaction
using (var session = mongoClient.StartSession())
{
    // Configures transaction options
    var transactionOptions = new TransactionOptions(
        readConcern: ReadConcern.Majority,
        writeConcern: WriteConcern.WMajority
    );
    session.StartTransaction(transactionOptions);
    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!

Informações adicionais

Para saber mais sobre os conceitos mencionados neste guia, consulte as seguintes páginas no manual do servidor:

• Transações

• Sessões do servidor

• Isolamento de leitura, consistência e atualidade