如何使用EF实现多数据源配置，解决多DbContext重复生成表问题

问题根因 #

• 三个DbContext使用了完全相同的连接字符串，默认指向同一个数据库
• 未在每个DbContext中显式限定要映射的实体范围，EF Core默认会扫描程序集内所有符合约定的实体全部映射
• 三个泛型仓储均注册到同一个IRepository<>接口，依赖注入时无法按领域匹配对应DbContext的仓储实例
• 分库场景下原生不支持跨库物理外键，需要业务层处理关联逻辑

解决方案 #

1. 拆分独立连接字符串 #

在配置文件中为每个DbContext配置独立的数据库连接字符串：

// appsettings.json
"ConnectionStrings": {
  "AppDb": "server=127.0.0.1;database=app_db;uid=root;pwd=xxx;port=3306",
  "UserAccessDb": "server=127.0.0.1;database=user_access_db;uid=root;pwd=xxx;port=3306",
  "AdministrationDb": "server=127.0.0.1;database=administration_db;uid=root;pwd=xxx;port=3306"
}

注册DbContext时分别传入对应的连接字符串即可。

2. 限定每个DbContext的实体映射范围 #

给不同领域的聚合根添加独立的标记接口（继承自原有IAggregateRoot）：

public interface IAppAggregateRoot : IAggregateRoot { }
public interface IUserAccessAggregateRoot : IAggregateRoot { }
public interface IAdministrationAggregateRoot : IAggregateRoot { }

对应领域的实体实现对应标记接口，然后在每个DbContext的OnModelCreating方法中仅扫描自身领域的实体：

// UserAccessDbContext示例，另外两个DbContext同理修改
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    // 仅扫描当前领域的聚合根实体
    var entityTypes = typeof(IUserAccessAggregateRoot).Assembly.GetTypes()
        .Where(t => t.IsClass && !t.IsAbstract && typeof(IUserAccessAggregateRoot).IsAssignableFrom(t));
    foreach (var type in entityTypes)
    {
        modelBuilder.Entity(type);
    }
    base.OnModelCreating(modelBuilder);
}

3. 生成独立迁移文件 #

执行迁移命令时指定DbContext，生成独立的迁移目录：

# AppDbContext迁移
dotnet ef migrations add InitAppDb --context AppDbContext -o Migrations/AppDb
dotnet ef database update --context AppDbContext

# UserAccessDbContext迁移
dotnet ef migrations add InitUserAccessDb --context UserAccessDbContext -o Migrations/UserAccessDb
dotnet ef database update --context UserAccessDbContext

# AdministrationDbContext迁移
dotnet ef migrations add InitAdministrationDb --context AdministrationDbContext -o Migrations/AdministrationDb
dotnet ef database update --context AdministrationDbContext

4. 修复仓储注册冲突 #

给不同领域的仓储定义独立的接口，避免同接口多实现的匹配问题：

// 分领域定义仓储接口
public interface IAppRepository<T> : IRepository<T>, IReadRepository<T> where T : class, IAppAggregateRoot { }
public interface IUserAccessRepository<T> : IRepository<T>, IReadRepository<T> where T : class, IUserAccessAggregateRoot { }
public interface IAdministrationRepository<T> : IRepository<T>, IReadRepository<T> where T : class, IAdministrationAggregateRoot { }

修改仓储实现对应接口：

public class AppRepository<T> : RepositoryBase<T>, IAppRepository<T> where T : class, IAppAggregateRoot
{
    public AppRepository(AppDbContext appDbContext) : base(appDbContext) { }
}
// 另外两个仓储同理修改

修改服务注册逻辑，按对应接口注册：

builder.RegisterGeneric(typeof(AppRepository<>))
    .As(typeof(IAppRepository<>))
    .InstancePerLifetimeScope();

builder.RegisterGeneric(typeof(AdministrationRepository<>))
    .As(typeof(IAdministrationRepository<>))
    .InstancePerLifetimeScope();

builder.RegisterGeneric(typeof(UserAccessRepository<>))
    .As(typeof(IUserAccessRepository<>))
    .InstancePerLifetimeScope();

5. 跨领域关联处理 #

分库场景无法创建跨库物理外键，建议在业务层做关联校验，高频关联数据可做冗余存储，通过领域事件同步数据一致性。

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