TransactionBehavior.cs

using MediatR;
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;

public class TransactionBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
{
    private readonly DbContext _dbContext;

    public TransactionBehavior(DbContext dbContext)
    {
        _dbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
    }

    public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
    {
        // Check if the current request should be transactional
        if (_dbContext.Database.CurrentTransaction != null)
        {
            return await next();
        }

        // Use a transaction to ensure all database operations are atomic
        await using var transaction = await _dbContext.Database.BeginTransactionAsync(cancellationToken);

        try
        {
            // Process the request
            var response = await next();

            // Commit the transaction if all operations succeed
            await transaction.CommitAsync(cancellationToken);

            return response;
        }
        catch (Exception)
        {
            // Roll back the transaction in case of an error
            await transaction.RollbackAsync(cancellationToken);
            throw;
        }
    }
}

Hello, please a example to use in a command or query