如何用Entity Framework Core实现跨多库动态访问表？

我们系统架构如下：

• 可配置主机：以IP地址定义服务器；
• 可配置数据库：按国家代码创建数据库；
• 企业专属表：各企业拥有结构一致、以企业代码命名的表，部分表含年份标识。

目前使用动态存储过程查询SQL Server，通过共享的COMPANY表获取服务器、数据库、企业代码及年份信息构建动态SQL（示例SQL如下）：

USE dbUnified
GO
DECLARE
     @SQL NVARCHAR(MAX) = ''
    ,@idCompany INT
    ,@serverERP VARCHAR(50)
    ,@baseERP VARCHAR(50)
    ,@codeERP VARCHAR(50)
    ,@yearERP VARCHAR(50)

SELECT 
     @serverERP = C.serverERP 
    ,@baseERP = C.baseERP
    ,@codeERP = C.codeERP
    ,@yearERP = C.yearERP
FROM
    COMPANY C
WHERE
    idCompany = @idCompany

-- Dynamic SQL for tables without year
SET @SQL = '
    SELECT 
        * 
    FROM 
        ['+@serverERP+'].['+@baseERP+'].[dbo].[TABLENAME'+@codeERP+'00]
'

-- Dynamic SQL for tables with year
SET @SQL = '
    SELECT 
        * 
    FROM 
        ['+@serverERP+'].['+@baseERP+'].[dbo].[TABLENAME'+@codeERP+@yearERP+']
'

EXEC SP_ExecuteSQL @SQL

计划迁移至Entity Framework Core，面临两个核心挑战：

1. 动态表与列映射：需将非直观的表名（如PL03{CompanyCode}00）、列名（如PL03001）映射为有意义的C#实体名（如Invoice）和属性名（如supplierCode）；
2. 动态数据库选择：当前DbContext仅能访问固定库（如dbUnified），需实现程序化动态连接其他库表。

期望实现单DbContext支持如下查询：

companyInfoDbContext.Invoice.FirstOrDefault(x => x.supplierCode == "123" && x.invoiceNumber == "321");
// or
companyInfoDbContext.Supplier.FirstOrDefault(x => x.supplierCode == "123");

已完成dbUnified的DbContext创建，尚未解决多库程序化访问问题，求实现方案及示例。

一、动态表/列映射实现 #

利用EF Core的**模型构建器（ModelBuilder）**在运行时动态配置实体与数据库对象的映射关系，核心思路是基于企业代码、年份信息动态生成表名，同时通过HasColumnName映射列名。

1. 定义基础实体类 #

先创建标准化的C#实体：

public class Invoice
{
    public int Id { get; set; }
    public string SupplierCode { get; set; }
    public string InvoiceNumber { get; set; }
    // 其他业务属性...
}

public class Supplier
{
    public int Id { get; set; }
    public string SupplierCode { get; set; }
    public string SupplierName { get; set; }
    // 其他业务属性...
}

2. 动态配置映射规则 #

在DbContext中添加方法，根据企业信息动态配置实体的表名和列映射：

public class CompanyInfoDbContext : DbContext
{
    // 存储当前企业的配置信息
    private readonly CompanyConfig _companyConfig;

    // 构造函数注入企业配置
    public CompanyInfoDbContext(DbContextOptions<CompanyInfoDbContext> options, CompanyConfig companyConfig)
        : base(options)
    {
        _companyConfig = companyConfig;
    }

    public DbSet<Invoice> Invoice { get; set; }
    public DbSet<Supplier> Supplier { get; set; }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        ConfigureInvoiceMapping(modelBuilder);
        ConfigureSupplierMapping(modelBuilder);
        // 其他实体配置...
    }

    private void ConfigureInvoiceMapping(ModelBuilder modelBuilder)
    {
        // 生成动态表名：PL03{企业代码}{年份（有则用，无则补00）}
        string tableName = $"PL03{_companyConfig.CodeERP}{(_companyConfig.YearERP != null ? _companyConfig.YearERP : "00")}";
        
        modelBuilder.Entity<Invoice>()
            .ToTable(tableName)
            .Property(x => x.SupplierCode)
            .HasColumnName("PL03001") // 映射到数据库列名PL03001
            .Property(x => x.InvoiceNumber)
            .HasColumnName("PL03002"); // 映射到数据库列名PL03002
        // 其他属性列映射...
    }

    private void ConfigureSupplierMapping(ModelBuilder modelBuilder)
    {
        string tableName = $"SUPP{_companyConfig.CodeERP}00"; // 假设Supplier表无年份标识
        modelBuilder.Entity<Supplier>()
            .ToTable(tableName)
            .Property(x => x.SupplierCode)
            .HasColumnName("SUPP001")
            .Property(x => x.SupplierName)
            .HasColumnName("SUPP002");
        // 其他属性列映射...
    }
}

// 定义企业配置类，存储从COMPANY表获取的信息
public class CompanyConfig
{
    public string ServerERP { get; set; }
    public string BaseERP { get; set; }
    public string CodeERP { get; set; }
    public string YearERP { get; set; }
}

二、动态数据库/服务器连接实现 #

EF Core支持在运行时修改连接字符串，核心是根据企业配置动态生成包含服务器、数据库的连接字符串，然后注入到DbContext中。

1. 动态生成连接字符串 #

创建服务类，负责从dbUnified的COMPANY表获取企业配置，并生成目标数据库的连接字符串：

public class CompanyConfigService
{
    private readonly DbContextOptions<UnifiedDbContext> _unifiedDbOptions;

    public CompanyConfigService(DbContextOptions<UnifiedDbContext> unifiedDbOptions)
    {
        _unifiedDbOptions = unifiedDbOptions;
    }

    public async Task<CompanyConfig> GetCompanyConfigAsync(int idCompany)
    {
        using var dbContext = new UnifiedDbContext(_unifiedDbOptions);
        var company = await dbContext.COMPANY
            .FirstOrDefaultAsync(c => c.idCompany == idCompany);
        
        if (company == null)
            throw new ArgumentException("无效的企业ID");
        
        return new CompanyConfig
        {
            ServerERP = company.serverERP,
            BaseERP = company.baseERP,
            CodeERP = company.codeERP,
            YearERP = company.yearERP
        };
    }

    public string BuildConnectionString(CompanyConfig config)
    {
        // 构建包含目标服务器和数据库的连接字符串
        return $"Server={config.ServerERP};Database={config.BaseERP};Trusted_Connection=True;TrustServerCertificate=True;";
    }
}

2. 动态创建DbContext实例 #

在业务代码中，先获取企业配置，生成连接字符串，再创建对应的CompanyInfoDbContext：

// 示例：根据企业ID获取配置并查询数据
public async Task<Invoice> GetInvoiceAsync(int idCompany, string supplierCode, string invoiceNumber)
{
    var configService = new CompanyConfigService(_unifiedDbOptions);
    var companyConfig = await configService.GetCompanyConfigAsync(idCompany);
    var connectionString = configService.BuildConnectionString(companyConfig);

    // 动态配置DbContext的连接字符串
    var dbContextOptions = new DbContextOptionsBuilder<CompanyInfoDbContext>()
        .UseSqlServer(connectionString)
        .Options;

    using var companyDbContext = new CompanyInfoDbContext(dbContextOptions, companyConfig);
    return await companyDbContext.Invoice
        .FirstOrDefaultAsync(x => x.SupplierCode == supplierCode && x.InvoiceNumber == invoiceNumber);
}

三、注意事项 #

• 线程安全：每个请求应创建独立的DbContext实例，避免多线程共享导致的映射冲突；
• 缓存优化：可以缓存企业配置和连接字符串，减少对dbUnified的查询次数；
• 验证机制：添加对企业配置的合法性验证，避免无效的服务器/数据库连接；
• 迁移兼容性：动态映射的实体无法自动生成EF Core迁移脚本，建议手动维护数据库结构。

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