如何在Entity Framework Core中将DBContext纳入现有ADO.Net事务？

嘿，我完全懂你现在的困扰——既有老的ADO.NET代码在事务里跑，又要加EF Core的操作，还得保证所有步骤都在同一个事务里对吧？别担心，这事儿其实很容易搞定，核心就是让EF Core复用你已经打开的ADO.NET连接和事务就行。

下面给你一步步来的具体方案：

核心思路 #

让EF Core的DbContext使用ADO.NET已经开启的同一连接，并且绑定到ADO.NET创建的事务上，这样两边的操作就会共享同一个事务上下文，要么一起提交，要么一起回滚。

具体实现步骤 #

1. 先准备好ADO.NET的连接和事务 #

首先你得确保你的ADO.NET连接已经打开，并且已经创建了事务（这部分应该是你现有代码里已经有的，不过还是贴出来确认下）：

// 初始化并打开ADO.NET连接
using var sqlConnection = new SqlConnection("你的SQL Server连接字符串");
sqlConnection.Open();

// 基于这个连接创建事务
using var adoTransaction = sqlConnection.BeginTransaction();

2. 配置EF Core的DbContext复用连接和事务 #

接下来要给你的MyDBContext配置使用上面的已打开连接，并且把事务绑定进去：

// 构建DbContext的配置选项，指定使用已有的ADO.NET连接
var dbContextOptions = new DbContextOptionsBuilder<MyDBContext>()
    .UseSqlServer(sqlConnection) // 传入已经打开的连接，EF Core不会再重新打开
    .Options;

// 创建DbContext实例
using var dbContext = new MyDBContext(dbContextOptions);

// 关键一步：把ADO.NET的事务传递给EF Core
dbContext.Database.UseTransaction(adoTransaction);

3. 执行跨技术栈的操作 #

现在不管是用ADO.NET执行的老操作，还是用EF Core执行的新操作，都属于同一个事务了：

// 执行EF Core的新增/修改操作
dbContext.YourEntities.Add(new YourEntity { Property = "测试数据" });
await dbContext.SaveChangesAsync();

// 继续执行原有的ADO.NET操作（在同一个事务里）
using var sqlCommand = new SqlCommand(
    "UPDATE OldTable SET Status = 1 WHERE Id = @Id", 
    sqlConnection, 
    adoTransaction
);
sqlCommand.Parameters.AddWithValue("@Id", 123);
await sqlCommand.ExecuteNonQueryAsync();

4. 统一管理事务的提交/回滚 #

最后所有操作完成后，统一提交事务；如果中间出错，就回滚：

try
{
    // 所有操作都没问题，提交事务
    adoTransaction.Commit();
}
catch (Exception ex)
{
    // 任何一步出错，回滚整个事务
    adoTransaction.Rollback();
    // 这里可以根据需要处理异常，比如日志记录、抛出给上层等
    throw new Exception("事务执行失败", ex);
}

注意事项 #

• 必须确保ADO.NET的连接是已经打开的，EF Core不会自动帮你打开它，否则会报错。
• 传递给UseTransaction的事务必须属于你给EF Core指定的那个连接，不能混用不同连接的事务。
• 如果你的项目用了依赖注入（DI）来创建DbContext，那可以在服务范围内手动覆盖连接和事务，比如：

  // 假设你从DI拿到了服务提供器
  using var scope = _serviceProvider.CreateScope();
  var dbContext = scope.ServiceProvider.GetRequiredService<MyDBContext>();
  // 绑定已有的事务
  dbContext.Database.UseTransaction(adoTransaction);
  // 然后执行EF操作即可
  

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