在仓储层运行时动态切换DbContext连接字符串的技术问询

针对你的需求，完全可以在仓储层实现动态设置连接字符串，核心思路是为每个目标数据库创建独立的DbContext实例（EF Core不允许修改已初始化DbContext的连接字符串），以下是具体实现步骤：

1. 改造DemoDbContext，添加动态创建实例的方法 #

为DbContext新增静态工厂方法，允许通过传入的连接字符串构建并返回新的DbContext实例：

namespace DemoApp.Persistence.DomainDbContext;

public partial class DemoDbContext : DbContext
{
    public DemoDbContext(DbContextOptions<DemoDbContext> options)
        : base(options)
    {
    }

    // 新增静态工厂方法，用于动态创建指定连接的DbContext
    public static DemoDbContext Create(string connectionString)
    {
        var optionsBuilder = new DbContextOptionsBuilder<DemoDbContext>();
        // 根据你的数据库类型调整，这里以SQL Server为例
        optionsBuilder.UseSqlServer(connectionString);

        return new DemoDbContext(optionsBuilder.Options);
    }

    // 原有的DbSet和OnModelCreating代码保持不变
    public virtual DbSet<ConfigSystem> ConfigSystems { get; set; }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        modelBuilder.Entity<ConfigSystem>(entity =>
        {
            entity.HasKey(e => e.ConfigSystemGuid);

            entity.ToTable("ConfigSystem", "dbo", tb => tb.HasTrigger("Tr_ConfigSystem_Update"));

            entity.HasIndex(e => e.ConfigSystemName, "UX_ConfigSystem").IsUnique();

            entity.Property(e => e.ConfigSystemGuid)
                .HasDefaultValueSql("(newsequentialid())")
                .HasColumnName("ConfigSystemGUID");
            entity.Property(e => e.EnvironmentId)
                .HasMaxLength(250)
                .IsUnicode(false)
                .HasColumnName("EnvironmentID");
            entity.Property(e => e.EnvironmentType)
                .HasMaxLength(50)
                .IsUnicode(false);
            entity.Property(e => e.Version)
                .HasMaxLength(25)
                .IsUnicode(false)
                .HasDefaultValueSql("((1))");
            entity.Property(e => e.VersionDate)
                .HasDefaultValueSql("(getdate())")
                .HasColumnType("smalldatetime");
        });

        OnModelCreatingPartial(modelBuilder);
    }

    partial void OnModelCreatingPartial(ModelBuilder modelBuilder);
}

2. 调整仓储类，支持传入连接字符串查询 #

修改仓储的查询方法，让每个方法接收连接字符串参数，并在内部创建对应连接的DbContext实例（用using确保资源及时释放）：

namespace DemoApp.Persistence.Repositories
{
    public class ConfigSystemRepository : DemoAppBaseRepository<ConfigSystem>, IConfigSystemRepository
    {
        // 移除原构造注入的DbContext，改为动态创建实例
        public ConfigSystemRepository()
        {
        }

        // 修改原有查询方法，添加连接字符串参数
        public async Task<List<ConfigSystem>> GetConfigSystemList(string connectionString)
        {
            using var dbContext = DemoDbContext.Create(connectionString);
            return await dbContext.ConfigSystems.Take(10).ToListAsync();
        }
     
        public async Task<ConfigSystem> GetConfigSystemItem(string connectionString)
        {
            using var dbContext = DemoDbContext.Create(connectionString);
            return await dbContext.ConfigSystems.FirstOrDefaultAsync();
        }       
    }
}

3. 在查询处理层汇总多数据库数据 #

结合你的CQRS模式，在查询处理程序中遍历服务器/数据库列表，逐个调用仓储方法传入对应连接字符串，最后汇总结果：

// 示例查询处理程序
public class GetAllConfigSystemsQueryHandler : IRequestHandler<GetAllConfigSystemsQuery, List<ConfigSystem>>
{
    private readonly IConfigSystemRepository _configSystemRepository;

    public GetAllConfigSystemsQueryHandler(IConfigSystemRepository configSystemRepository)
    {
        _configSystemRepository = configSystemRepository;
    }

    public async Task<List<ConfigSystem>> Handle(GetAllConfigSystemsQuery request, CancellationToken cancellationToken)
    {
        var allConfigs = new List<ConfigSystem>();
        // 假设你已获取到所有目标数据库的连接字符串列表
        var connectionStrings = GetTargetConnectionStrings();

        foreach (var connStr in connectionStrings)
        {
            var dbConfigs = await _configSystemRepository.GetConfigSystemList(connStr);
            allConfigs.AddRange(dbConfigs);
        }

        return allConfigs;
    }

    // 模拟获取所有目标数据库的连接字符串
    private List<string> GetTargetConnectionStrings()
    {
        return new List<string>
        {
            "Server=Server1;Database=Db1;User Id=xxx;Password=xxx;",
            "Server=Server2;Database=Db2;User Id=xxx;Password=xxx;"
            // 更多连接字符串...
        };
    }
}

关键说明 #

• EF Core的DbContext实例是不可变配置的，一旦初始化完成就无法修改连接字符串，因此必须为每个数据库创建独立实例。
• 使用using语句包裹DbContext实例，确保每次查询后及时释放数据库连接资源。
• 该方案无需提前在DI容器注册每个数据库实例，也不需要将连接字符串存入appsettings，完全通过动态传入的方式实现。

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