使用EntityFramework Core如何不修改连接字符串动态切换MySQL数据库

核心原理 #

MySqlConnector的连接池基于连接字符串的哈希值分配，只要所有DbContext使用完全相同的连接字符串，就会共用同一个连接池。你之前使用SetDefaultSchema无效的原因是：MySQL中的「数据库（Database）」对应EF Core概念里的Catalog，而非Schema，SetDefaultSchema配置的EF Core层级Schema不会被Pomelo映射为MySQL的数据库名。

方案1：固定DbContext对应固定数据库（推荐静态场景） #

适合不同DbContext固定对应指定数据库的场景，无额外性能开销：

1. 统一所有DbContext的连接字符串，无需在连接字符串中指定Database参数，或统一使用同一个默认数据库名即可。
2. 在对应DbContext的OnModelCreating方法中，给实体显式指定所属的MySQL数据库名：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    // 单个实体指定映射到INFORMATION_SCHEMA库的TABLES表
    modelBuilder.Entity<InformationSchemaTable>()
        .ToTable("TABLES", "INFORMATION_SCHEMA");
    
    // 批量给当前DbContext的所有实体指定所属数据库
    foreach (var entityType in modelBuilder.Model.GetEntityTypes())
    {
        // 第二个参数即为MySQL数据库名
        entityType.SetTableName(entityType.GetTableName(), "你需要的目标数据库名");
    }
}

方案2：运行时动态切换数据库（适合动态场景） #

如果需要同一个DbContext根据业务场景切换访问不同数据库，可以通过EF Core拦截器在连接打开后执行USE语句切换数据库：

1. 注册DbContext时注入拦截器，所有DbContext共用同一份连接字符串：

services.AddDbContext<MyCustomDbContext>(options =>
{
    options.UseMySql("你的统一连接字符串", new MySqlServerVersion("你的MySQL版本号"))
           .AddInterceptors(new MySqlDbSwitchInterceptor());
});

2. 实现连接拦截器和上下文存储类：

// 线程安全的当前数据库存储类
public static class DbContextStorage
{
    private static readonly AsyncLocal<string> _currentDb = new();
    public static string CurrentTargetDb
    {
        get => _currentDb.Value;
        set => _currentDb.Value = value;
    }
}

// 连接拦截器
public class MySqlDbSwitchInterceptor : DbConnectionInterceptor
{
    public override InterceptionResult ConnectionOpening(DbConnection connection, ConnectionEventData eventData, InterceptionResult result)
    {
        var targetDb = DbContextStorage.CurrentTargetDb;
        if (!string.IsNullOrEmpty(targetDb) && connection.Database != targetDb)
        {
            connection.Open();
            using var cmd = connection.CreateCommand();
            cmd.CommandText = $"USE `{targetDb}`";
            cmd.ExecuteNonQuery();
        }
        return base.ConnectionOpening(connection, eventData, result);
    }

    public override async ValueTask<InterceptionResult> ConnectionOpeningAsync(DbConnection connection, ConnectionEventData eventData, InterceptionResult result, CancellationToken cancellationToken = default)
    {
        var targetDb = DbContextStorage.CurrentTargetDb;
        if (!string.IsNullOrEmpty(targetDb) && connection.Database != targetDb)
        {
            await connection.OpenAsync(cancellationToken);
            using var cmd = connection.CreateCommand();
            cmd.CommandText = $"USE `{targetDb}`";
            await cmd.ExecuteNonQueryAsync(cancellationToken);
        }
        return await base.ConnectionOpeningAsync(connection, eventData, result, cancellationToken);
    }
}

3. 业务使用时先指定目标数据库即可：

DbContextStorage.CurrentTargetDb = "INFORMATION_SCHEMA";
// 后续当前异步上下文内的DbContext操作都会访问指定数据库

注意事项 #

• 所有DbContext使用的连接字符串必须完全一致，哪怕多一个空格、大小写不同都会触发新连接池的生成。
• 连接字符串绑定的数据库账号需要具备所有要访问的数据库的对应操作权限。
• 静态映射方案性能优于动态拦截方案，没有额外的SQL执行开销，优先选择。

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