.NET Core 中避免事务在 UserService 中提前提交的最佳实践

在 .NET Core 中进行数据库操作时，事务管理至关重要，它可以确保多个操作的完整性和一致性。然而，有时我们会遇到事务在 UserService 中提前提交的问题，导致数据不一致。本文将探讨这个问题并提供最佳实践解决方案。

问题描述

假设我们有一个 OrderService 和 UserService，分别负责处理订单和用户相关操作。在更新订单时，需要同时更新用户信息。以下代码示例展示了常见的错误做法：

public class OrderService
{
    private DbContext dbContext { get; set; }
    private IUserService userService { get; set; }

    public void Update(OrderDto orderDto)
    {
        using (var trans = dbContext.Database.BeginTransaction())
        {
            Order order = dbContext.Order.First();
            order.Update(orderDto);

            userService.UpdateOrderRecord(order);
            trans.Commit();
        }
    }
}

public class UserService : IUserService
{
    private DbContext dbContext { get; set; }

    public void UpdateOrderRecord(Order order)
    {
        using (var trans = dbContext.Database.BeginTransaction())
        {
            var user = dbContext.User.First();
            user.UpdateOrderRecord(order);
            dbContext.SaveChanges();
            trans.Commit();
        }
    }
}

public class UserScoreService : IUserService
{
    private DbContext dbContext { get; set; }

    public void AddScore(User user)
    {
            dbContext.UserScore.Add(new UserScore(user));
            dbContext.SaveChanges();
    }
}

在这个示例中，OrderService 和 UserService 都使用独立的事务，导致 UserService 的更新操作可能会在 OrderService 的事务提交之前完成。如果 UserService 的更新操作失败，则会导致数据不一致。

最佳实践

为了避免这种情况，我们可以将 UserService 中的事务去掉，让其依赖于 OrderService 的事务，即让 UserService 的更新操作在 OrderService 的事务内进行。修改后的代码如下：

public class OrderService
{
    private DbContext dbContext { get; set; }
    private IUserService userService { get; set; }

    public void Update(OrderDto orderDto)
    {
        using (var trans = dbContext.Database.BeginTransaction())
        {
            Order order = dbContext.Order.First();
            order.Update(orderDto);

            userService.UpdateOrderRecord(order, dbContext); // 传入 OrderService 的 dbContext
            dbContext.SaveChanges();
            trans.Commit();
        }
    }
}

public class UserService : IUserService
{
    public void UpdateOrderRecord(Order order, DbContext dbContext)
    {
        var user = dbContext.User.First();
        user.UpdateOrderRecord(order);
    }
}

public class UserScoreService : IUserService
{
    private DbContext dbContext { get; set; }

    public void AddScore(User user)
    {
        dbContext.UserScore.Add(new UserScore(user));
        dbContext.SaveChanges();
    }
}

在这个修改后的代码中，UserService 的 UpdateOrderRecord 方法接受一个 DbContext 参数，并将更新操作放在 OrderService 的事务内完成。这样可以确保所有操作都在同一个事务中完成，从而保证数据的一致性。

总结

在 .NET Core 中进行数据库操作时，需要谨慎地管理事务。通过将依赖服务的更新操作放在主事务内，可以有效地避免事务提前提交的问题，确保数据的一致性。