如何在MySqlConnection与EntityFramework间共享连接实现单事务？

核心结论 #

完全可以实现两种方式共享连接并在同一事务中操作，核心思路是复用同一个IDbConnection实例——因为MySqlConnection和EF的底层连接都实现了这个接口。

具体实现方案 #

方案1：从MySqlConnection实例创建EF上下文

手动创建并管控MySqlConnection实例，再将其传入自定义的EF上下文构造函数，绑定同一事务：

// 手动初始化并打开连接
using var mysqlConn = new MySqlConnection("你的数据库连接字符串");
mysqlConn.Open();

// 开启全局事务
using var transaction = mysqlConn.BeginTransaction();

try
{
    // 传入已有连接实例初始化EF上下文
    using var dbContext = new YourCustomDbContext(mysqlConn);
    // 将事务绑定到EF上下文
    dbContext.Database.UseTransaction(transaction);

    // 用EF执行数据库操作
    dbContext.YourEntities.Add(new YourEntity());
    dbContext.SaveChanges();

    // 用MySqlConnection直接执行SQL
    using var cmd = mysqlConn.CreateCommand();
    cmd.Transaction = transaction;
    cmd.CommandText = "INSERT INTO demo_table (col1) VALUES ('test')";
    cmd.ExecuteNonQuery();

    // 提交事务
    transaction.Commit();
}
catch (Exception)
{
    transaction.Rollback();
    throw;
}

方案2：从EF上下文提取底层连接供MySqlConnection使用

如果已有EF上下文实例，可直接提取其底层连接（强转为MySqlConnection），共享同一事务：

using var dbContext = new YourCustomDbContext();
// 确保EF已打开连接（可通过执行查询或手动调用OpenConnection实现）
dbContext.Database.OpenConnection();

// 提取底层连接并强转为MySqlConnection
var mysqlConn = (MySqlConnection)dbContext.Database.GetDbConnection();
// 开启事务
using var transaction = mysqlConn.BeginTransaction();

try
{
    // 将事务绑定到EF上下文
    dbContext.Database.UseTransaction(transaction);

    // EF操作
    dbContext.YourEntities.Update(existingEntity);
    dbContext.SaveChanges();

    // 用MySqlConnection执行原生SQL
    using var cmd = mysqlConn.CreateCommand();
    cmd.Transaction = transaction;
    cmd.CommandText = "UPDATE demo_table SET col1 = 'updated' WHERE id = 1";
    cmd.ExecuteNonQuery();

    transaction.Commit();
}
catch (Exception)
{
    transaction.Rollback();
    throw;
}

关键注意事项 #

• 必须手动管控连接生命周期，避免EF自动处理连接的打开/关闭，防止连接被提前释放。
• 事务必须同时绑定到EF上下文和MySqlCommand实例，否则两种操作不会纳入同一事务。
• 需要给EF上下文添加接受IDbConnection的构造重载，示例如下：

public class YourCustomDbContext : DbContext
{
    private readonly IDbConnection _connection;

    public YourCustomDbContext(IDbConnection connection)
    {
        _connection = connection;
    }

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        // 使用传入的连接实例，不再指定连接字符串
        optionsBuilder.UseMySql(_connection, ServerVersion.AutoDetect(_connection));
    }

    // 定义你的实体集合
    public DbSet<YourEntity> YourEntities { get; set; }
}

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