Working With MongoDB Transactions With C# and the .NET Framework

Robert Walters3 min read • Published Jan 28, 2022 • Updated Sep 11, 2024

.NET MongoDB C#

Avalie esse Tutorial

Atualização 10/2019: o exemplo de código deste artigo foi atualizado para incluir o tratamento necessário do identificador de sessão para métodos de banco de dados.

Aplicativos C# conectados a um MongoDB database usam o driver MongoDB .NET. Para adicionar o driver .NET ao seu aplicativo Visual Studio, no NuGet Package Manager, pesquise "MongoDB".

Certifique-se de escolher a versão mais recente (>=2.7) do driver e pressione Install).

Antes da versão 4.0 do MongoDB, o MongoDB era transacionalmente consistente no nível do documento. Essas operações atômicas de documento único existentes fornecem a semântica de transação para atender às necessidades de integridade de dados da maioria dos aplicativos. Isso ocorre porque a flexibilidade do document model permite que os desenvolvedores incorporem facilmente dados relacionados a uma entidade como arrays e subdocumentos em um único documento avançado. Dito isto, há alguns casos em que a divisão do conteúdo em duas ou mais coleções seria apropriada e, para esses casos, as transações ACID de vários documentos tornam mais fácil do que nunca para os desenvolvedores abordarem toda a gama de casos de uso com o MongoDB . Para obter uma discussão mais detalhada sobre o design do document model do MongoDB, incluindo como representar relacionamentos um-para-muitos e muitos-para-muitos, confira este artigo sobre design de modelos de dados.

No código a seguir, criaremos um objeto Produto e executaremos uma transação no MongoDB que inserirá alguns dados de exemplo no MongoDB e, em seguida, atualizará os preços de todos os produtos em 10%.

Trecho de código

using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
using MongoDB.Driver;
using System;
using System.Threading.Tasks;

namespace MongoDBTransaction
{
    public static class Program
    {
        public class Product
        {
            [BsonId]
            public ObjectId Id { get; set; }
            [BsonElement("SKU")]
            public int SKU { get; set; }
            [BsonElement("Description")]
            public string Description { get; set; }
            [BsonElement("Price")]
            public Double Price { get; set; }
        }

// replace with your connection string if it is different
        const string MongoDBConnectionString = "mongodb://localhost";

public static async Task Main(string[] args)
        {
            if (!await UpdateProductsAsync()) { Environment.Exit(1); }
            Console.WriteLine("Finished updating the product collection");
            Console.ReadKey();
        }

private static async Task<bool> UpdateProductsAsync()
        {
            // Create client connection to our MongoDB database
            var client = new MongoClient(MongoDBConnectionString);

// Create the collection object that represents the "products" collection
            var database = client.GetDatabase("MongoDBStore");
            var products = database.GetCollection<Product>("products");

// Clean up the collection if there is data in there
            await database.DropCollectionAsync("products");

// collections can't be created inside a transaction so create it first
            await database.CreateCollectionAsync("products");

// Create a session object that is used when leveraging transactions
            using (var session = await client.StartSessionAsync())
            {
                // Begin transaction
                session.StartTransaction();

try
                {
                    // Create some sample data
                    var tv = new Product { Description = "Television", 
                                    SKU = 4001, 
                                    Price = 2000 };
                    var book = new Product { Description = "A funny book", 
                                    SKU = 43221, 
                                    Price = 19.99 };
                    var dogBowl = new Product { Description = "Bowl for Fido", 
                                    SKU = 123, 
                                    Price = 40.00 };

// Insert the sample data 
                    await products.InsertOneAsync(session, tv);
                    await products.InsertOneAsync(session, book);
                    await products.InsertOneAsync(session, dogBowl);

// Increase all the prices by 10% for all products
                    var update = new UpdateDefinitionBuilder<Product>()
                            .Mul<Double>(r => r.Price, 1.1);
                    await products.UpdateManyAsync(session, 
                            Builders<Product>.Filter.Empty, 
                            update); //,options);

// Made it here without error? Let's commit the transaction
                    await session.CommitTransactionAsync();
                }
                catch (Exception e)
                {
                    Console.WriteLine("Error writing to MongoDB: " + e.Message);
                    await session.AbortTransactionAsync();
                    return false;
                }

// Let's print the new results to the console
                Console.WriteLine("\n\nNew Prices (10% increase):\n");
                var resultsAfterCommit = await products
                        .Find<Product>(session, Builders<Product>.Filter.Empty)
                        .ToListAsync();
                foreach (Product d in resultsAfterCommit)
                {
                    Console.WriteLine(
                        String.Format("Product Name: {0}\tPrice: {1:0.00}", 
                                                    d.Description, d.Price)
                    );
                }

return true;
            }
        }
    }
}

Código-fonte disponível no Gist. A execução bem-sucedida gera o seguinte:

Pontos principais:

Você não precisa combinar propriedades de classe com objetos JSON. Basta definir um objeto de classe e inseri-lo diretamente no banco de dados. Não há necessidade de uma camada do mapeador relacional de objetos (ORM).
As transações do MongoDB usam isolamento de snapshot, o que significa que somente o cliente envolvido na sessão transacional vê quaisquer alterações até o momento em que a transação seja confirmada.
O driver .NET do MongoDB facilita o uso de transações e o uso da sintaxe baseada em LINQ para queries.

Informações adicionais sobre como usar C# e o driver .NET podem ser encontradas na documentação C# e driver .NET do MongoDB.

Avalie esse Tutorial

Relacionado

Início rápido

Crie seu primeiro aplicativo .NET Core com o MongoDB Atlas

Jun 04, 2024 | 6 min read

Tutorial

Create a RESTful API With .NET Core and MongoDB

Sep 11, 2024 | 8 min read

Tutorial

Desenvolvimento de um jogo de plataforma de rolagem lateral com Unity e MongoDB Realm

Feb 03, 2023 | 20 min read

Artigo

Como usar o Realm de forma eficaz em um aplicativo Xamarin.Forms

Sep 09, 2024 | 18 min read

Sumário

Pontos principais: