Entity Framework Core多上下文操作的事务回滚方案咨询

1. 分布式事务协调（跨DbContext/数据库的事务） #

因为你操作的是两个不同的DbContext（可能对应不同数据库），可以用.NET的System.Transactions命名空间下的TransactionScope实现分布式事务，让两个操作处于同一事务中，任意一步失败都会自动回滚所有操作。

代码示例：

using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
using (var dbContext = _dbContextFactory.CreateDbContext())
using (var dbContext2 = _dbContextFactory2.CreateDbContext())
{
    await dbContext.AddAsync(sentObject);
    await dbContext.SaveChangesAsync();
    
    await dbContext2.AddAsync(convertedObject);
    await dbContext2.SaveChangesAsync();
    
    scope.Complete(); // 只有所有操作成功才提交事务
}

注意：需要确保你的数据库支持分布式事务（比如SQL Server支持MSDTC，PostgreSQL需额外配置），分布式事务会有一定性能开销，适合对数据一致性要求高的场景。

2. 手动补偿（回滚操作） #

如果分布式事务不可行（比如数据库不支持、不想引入性能开销），可以在第二个操作失败时，手动删除第一个插入的sentObject。

代码示例：

using (var dbContext = _dbContextFactory.CreateDbContext())
using (var dbContext2 = _dbContextFactory2.CreateDbContext())
{
    bool firstSaveSuccess = false;
    try
    {
        await dbContext.AddAsync(sentObject);
        await dbContext.SaveChangesAsync();
        firstSaveSuccess = true;
        
        await dbContext2.AddAsync(convertedObject);
        await dbContext2.SaveChangesAsync();
    }
    catch
    {
        if (firstSaveSuccess)
        {
            // 手动删除已插入的sentObject
            dbContext.Remove(sentObject);
            await dbContext.SaveChangesAsync();
        }
        throw; // 重新抛出异常，让上层处理
    }
}

这种方式需要注意：

• 确保sentObject插入后主键已被EF Core自动赋值（自增主键默认会填充），否则删除操作找不到对应数据。
• 处理删除时可能出现的异常（比如数据已被其他操作修改/删除），可添加校验或重试逻辑。
• 极端情况（如删除时数据库宕机）仍可能出现数据不一致，适合无法使用分布式事务、对一致性要求非极高的场景。

3. 预验证先于写入 #

在执行第一个插入操作前，先验证convertedObject的合法性（比如日期字段格式、范围是否正确），确认无误后再执行两个插入操作。从源头减少第二个操作失败的概率，避免不必要的回滚。

示例逻辑：

// 先验证convertedObject的日期字段
if (convertedObject.DateProperty < DateTime.MinValue || convertedObject.DateProperty > DateTime.MaxValue)
{
    throw new ArgumentException("日期字段格式错误");
}

// 验证通过后再执行数据库操作
using (var dbContext = _dbContextFactory.CreateDbContext())
using (var dbContext2 = _dbContextFactory2.CreateDbContext())
{
    await dbContext.AddAsync(sentObject);
    await dbContext.SaveChangesAsync();
    
    await dbContext2.AddAsync(convertedObject);
    await dbContext2.SaveChangesAsync();
}

这种方式不能完全避免所有失败场景（比如验证后数据库连接异常），但能大幅降低回滚发生频率，减少数据不一致风险。

内容的提问来源于stack exchange，提问作者Florent