❔ MongoDb transactions in Asp.net core web api

Hello, i need some advice on what is the best thing to do. I am building asp.net core Web API with MongoDb identity. The logic goes like this controller > service > dbManagers.

I want to implement transactions so i can revert db operation if anything goes wrong. Now i dont want to repeat myself and add

using (var session = await _dbClient.StartSessionAsync())

using (var session = await _dbClient.StartSessionAsync())

in every method, instead i created a middleware:

public class DbTransactionMiddleware
{
  private readonly RequestDelegate _next;
  private readonly DbClient _dbClient;

  public DbTransactionMiddleware(RequestDelegate next, DbClient dbClient)
  {
    _next = next;
    _dbClient = dbClient;
  }

  public async Task InvokeAsync(HttpContext context)
  {
    using (var session = await _dbClient.StartSessionAsync())
    {
      session.StartTransaction();

      try
      {
        await _next(context);
        await session.CommitTransactionAsync();
      }
      catch (Exception ex)
      {
        await session.AbortTransactionAsync();
        throw;
      }
     }
    }
  }

public class DbTransactionMiddleware
{
  private readonly RequestDelegate _next;
  private readonly DbClient _dbClient;

  public DbTransactionMiddleware(RequestDelegate next, DbClient dbClient)
  {
    _next = next;
    _dbClient = dbClient;
  }

  public async Task InvokeAsync(HttpContext context)
  {
    using (var session = await _dbClient.StartSessionAsync())
    {
      session.StartTransaction();

      try
      {
        await _next(context);
        await session.CommitTransactionAsync();
      }
      catch (Exception ex)
      {
        await session.AbortTransactionAsync();
        throw;
      }
     }
    }
  }

But how can i access session object in my service. And what would be the better way to do something like this. Like what is best practice?

❔ MongoDb transactions in Asp.net core web api

using (var session = await _dbClient.StartSessionAsync())

using (var session = await _dbClient.StartSessionAsync())

in every method, instead i created a middleware:

public class DbTransactionMiddleware
{
  private readonly RequestDelegate _next;
  private readonly DbClient _dbClient;

  public DbTransactionMiddleware(RequestDelegate next, DbClient dbClient)
  {
    _next = next;
    _dbClient = dbClient;
  }

  public async Task InvokeAsync(HttpContext context)
  {
    using (var session = await _dbClient.StartSessionAsync())
    {
      session.StartTransaction();

      try
      {
        await _next(context);
        await session.CommitTransactionAsync();
      }
      catch (Exception ex)
      {
        await session.AbortTransactionAsync();
        throw;
      }
     }
    }
  }

public class DbTransactionMiddleware
{
  private readonly RequestDelegate _next;
  private readonly DbClient _dbClient;

  public DbTransactionMiddleware(RequestDelegate next, DbClient dbClient)
  {
    _next = next;
    _dbClient = dbClient;
  }

  public async Task InvokeAsync(HttpContext context)
  {
    using (var session = await _dbClient.StartSessionAsync())
    {
      session.StartTransaction();

      try
      {
        await _next(context);
        await session.CommitTransactionAsync();
      }
      catch (Exception ex)
      {
        await session.AbortTransactionAsync();
        throw;
      }
     }
    }
  }

But how can i access session object in my service. And what would be the better way to do something like this. Like what is best practice?

❔ MongoDb transactions in Asp.net core web api

Similar Threads

❔ MongoDb transactions in Asp.net core web api

Similar Threads

Similar Threads

Similar Threads