ASP.NET核心DI公司上下文提供程序？[副本]

Question

我正在用ASP.NET Core3实现webapi。

在后端，我们有许多公司数据库，它们具有完全相同的模式/表等。

我正在尝试实现一个公司数据库上下文提供程序，它将让我在运行时解析正确的公司数据库上下文。

在my Startup.cs中，我有以下代码，可以让您了解我要做的事情:

public void ConfigureServices(IServiceCollection services)
{
    services.AddDbContext<CompanyDbContext>(opt => opt.UseSqlServer(Configuration.GetConnectionString("CompanyDbConnection")));

    services.AddScoped<ICompanyRepository, CompanyRepository>();

    services.AddDbContext<System.Func<CompanyType, ICompanyDbContext>>(dbContextOptionsBuilder => key =>
    {
        switch (key)
        {
            case CompanyType.HKG:
                return dbContextOptionsBuilder.UseSqlServer(Configuration.GetConnectionString("HkgCompanyDbConnection"));
            case CompanyType.SHG:
                return dbContextOptionsBuilder.UseSqlServer(Configuration.GetConnectionString("ShgCompanyDbConnection"));
            default:
                throw new KeyNotFoundException();
        }
    });

    //...

与只有1个连接的通用CompanyContext不同，我希望将类似服务提供程序的东西注入CompanyRepository构造函数中，该构造函数将允许我在存储库函数中（通过传递参数）解析不同情况下的不同公司DBContext。

其思想是代码的最后一部分应该根据提供的键返回正确的上下文。但显然最后一部分不起作用。如果不明显，repository类将保存从数据库返回数据的所有函数。

一个人该怎么做呢？

Answer 1

下面的评论这是如何你可以做它，通过检查什么是公司Id或名称上的请求，我有一个怀疑这是你最终需要的。

哦，是的，我忘了，这段代码是在。NET Core2.2上测试过的，但它应该会带来不同。

    services.AddScoped<ICompanyType, CompanyType>();
    services.AddEntityFrameworkSqlServer();
    services.AddDbContext<CompanyDbContext>((serviceProvider, options) =>
        {
            var companyCode = serviceProvider.GetRequiredService<ICompanyType>().Get();
            string connectionString = string.Empty;
            switch (companyCode)
            {
                case CompanyType.HKG:
                    connectionString = Configuration.GetConnectionString("HkgCompanyDbConnection");
                    break;
                case CompanyType.SHG:
                    connectionString = Configuration.GetConnectionString("ShgCompanyDbConnection");
                    break;
                default:
                    throw new InvalidOperationException();
            }
            options
                .UseSqlServer(connectionString)
                .UseInternalServiceProvider(serviceProvider);
        });

和一些虚拟公司类型实现:

public class CompanyType: ICompanyType
{
    public const string HKG = "HKG";
    public const string SHG = "SHG";
    public string Get()
    {
        Random rand = new Random((int) DateTime.UtcNow.Ticks & 0x0000FFFF);
        var flipCoin = rand.Next(0, 1);
        return flipCoin == 0 ? HKG : SHG;
    }
}

public interface ICompanyType
{
    // dummy code, to be replaced with what is needed
    string Get();
}

Answer 2

我最近做了一些相当类似的事情（但不完全是），并且遇到了这个很好的答案，我认为它正好满足了你的需求。

基本步骤:

共享委托

public delegate IService ServiceResolver(CompanyType key);

添加要解析的实例

//Note: Default Service Lifetime for AddDbContext is Scoped - perfect!
services.AddDbContext<HkgCompanyContext>(options...);
services.AddDbContext<ShgCompanyContext>(options...);

解析程序服务

services.AddScoped<ServiceResolver>(serviceProvider => key =>
{
   switch (key)
   {
      case CompanyType.HKG:
         return serviceProvider.GetService(HkgCompanyContext);
      case CompanyType.SHG:
         return serviceProvider.GetService(ShgCompanyContext);
      default:
         throw new KeyNotFoundException();
   }
}