.NET Core中支持多数据库提供程序的通用DbContext实现问题咨询

你只需要在通用DbContext层封装数据库类型选择逻辑，配合Scoped生命周期的租户请求上下文传递当前客户对应的数据库配置即可，完整实现步骤如下： #

1. 定义数据库类型枚举与请求级数据库信息容器 #

// 数据库类型枚举
public enum DatabaseType
{
    SqlServer,
    MySql
}

// 请求级的当前数据库配置容器，Scoped生命周期，每个请求对应独立实例
public class CurrentDbInfo
{
    public DatabaseType DbType { get; set; }
    public string ConnectionString { get; set; }
}

2. 实现通用GenericDbContext #

所有DbSet、实体配置统一写在这个上下文里，无需拆分两个上下文，仅在配置阶段动态选择提供程序：

public class GenericDbContext : DbContext
{
    private readonly CurrentDbInfo _currentDbInfo;

    // 业务实体DbSet统一在此定义，无需修改
    public DbSet<YourBusinessEntity> YourBusinessEntities { get; set; }

    public GenericDbContext(DbContextOptions<GenericDbContext> options, CurrentDbInfo currentDbInfo) 
        : base(options)
    {
        _currentDbInfo = currentDbInfo;
    }

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        if (!optionsBuilder.IsConfigured)
        {
            // 数据库提供程序选择逻辑仅在此处封装，业务层完全无感知
            switch (_currentDbInfo.DbType)
            {
                case DatabaseType.SqlServer:
                    optionsBuilder.UseSqlServer(_currentDbInfo.ConnectionString);
                    break;
                case DatabaseType.MySql:
                    // 可根据实际情况指定MySql版本，也可使用AutoDetect自动探测
                    optionsBuilder.UseMySql(_currentDbInfo.ConnectionString, ServerVersion.AutoDetect(_currentDbInfo.ConnectionString));
                    break;
            }
        }
        base.OnConfiguring(optionsBuilder);
    }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        // 通用实体配置直接在此写，两种数据库通用
        // 若存在个别数据库特殊适配，可通过以下方法判断后单独配置：
        // if (this.Database.IsSqlServer()) {  SqlServer特殊配置 }
        // if (this.Database.IsMySql()) {  MySql特殊配置 }
    }
}

3. 实现请求级客户数据库配置解析中间件 #

在请求管道中提前解析当前请求对应的客户标识，查询对应的数据库配置并赋值给Scoped的CurrentDbInfo：

public class CustomerDbResolveMiddleware
{
    private readonly RequestDelegate _next;

    public CustomerDbResolveMiddleware(RequestDelegate next)
    {
        _next = next;
    }

    public async Task InvokeAsync(HttpContext context, CurrentDbInfo currentDbInfo, ITenantConfigService tenantConfigService)
    {
        // 从请求头、路由、Token等位置获取当前客户标识，按需调整获取逻辑
        var customerId = context.Request.Headers["X-CustomerId"].FirstOrDefault();
        if (!string.IsNullOrEmpty(customerId))
        {
            // 从你的租户配置服务中查询该客户对应的数据库类型、连接串
            var tenantConfig = await tenantConfigService.GetTenantDbConfigAsync(customerId);
            currentDbInfo.DbType = tenantConfig.DbType;
            currentDbInfo.ConnectionString = tenantConfig.ConnectionString;
        }
        await _next(context);
    }
}

// 租户配置服务示例接口，你可根据实际存储实现（从配置文件、租户元数据表读取都可）
public interface ITenantConfigService
{
    Task<TenantDbConfig> GetTenantDbConfigAsync(string customerId);
}

4. 依赖注入与管道配置 #

var builder = WebApplication.CreateBuilder(args);

// 注册请求级数据库信息容器、租户配置服务
builder.Services.AddScoped<CurrentDbInfo>();
builder.Services.AddScoped<ITenantConfigService, YourTenantConfigServiceImpl>();

// 注册EF Core提供程序与通用DbContext，和你原来的写法兼容
builder.Services
    .AddEntityFrameworkMySql()
    .AddEntityFrameworkSqlServer()
    .AddDbContext<GenericDbContext>();

// 其他服务注册逻辑...

var app = builder.Build();

// 把数据库解析中间件加到管道中，位置要早于控制器/业务逻辑执行
app.UseMiddleware<CustomerDbResolveMiddleware>();

// 其他中间件配置...
app.Run();

5. 迁移适配方案 #

迁移阶段两种数据库的迁移语句分开生成即可，无需拆分上下文：

• 生成SqlServer迁移：Add-Migration InitialSqlServer -Context GenericDbContext -OutputDir Migrations/SqlServer
• 生成MySql迁移：Add-Migration InitialMySql -Context GenericDbContext -OutputDir Migrations/MySql
• 执行迁移时会自动匹配对应数据库的迁移文件，无需额外处理。

完成上述配置后，业务代码中直接注入GenericDbContext即可使用，完全不需要感知底层数据库类型，也无需做任何分支判断。

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