Web 的动态连接字符串 Api

Question

我正在通过 Web api 公开我的存储库操作。存储库已通过 Entity framework 和工作单元模式实现。我有同一个数据库的许多实例。每一个代表不同客户的数据。现在的问题是如何通过每个 webapi 调用动态设置连接字符串？我应该在每次调用时获取连接字符串参数吗？或者我应该为每个客户托管网络 Api？

Answer 1

您可以更改每个 DbContext 实例的连接字符串

示例：

public class AwesomeContext : DbContext
{
    public AwesomeContext (string connectionString)
        : base(connectionString)
    {
    }
    public DbSet<AwesomePeople> AwesomePeoples { get; set; }
}

然后像这样使用 DbContext：

   using(AwesomeContext context = new AwesomeContext("newConnectionString"))
   {
     return context.AwesomePeoples.ToList();
   }

根据有多少个 ConnectionString，您可以为客户端/constring 映射创建一个 DB table 或将其保存在解决方案中（例如数组）。

如果你不能't/don不想更改构造函数你也可以稍后再做

将此添加到您的 DbContext 覆盖中：

    public void SetConnectionString(string connectionString)
    {
        this.Database.Connection.ConnectionString = connectionString;
    }

并在执行任何数据库操作之前调用该方法：

   using(AwesomeContext context = new AwesomeContext())
   {

    context.SetConnectionString(ConfigurationManager.ConnectionStrings["newConnectionString"].ConnectionString)
    return context.AwesomePeoples.ToList();

   }

Answer 2

根据提供的信息，我会使用同一个控制器并查找连接字符串，而不是为每个客户端托管单独的 Web API 实例。托管多个实例会更复杂，鉴于唯一的区别是连接字符串，我认为复杂性不合理。

我们需要做的第一件事是确定正在调用哪个客户端以获得适当的连接字符串。这可以通过令牌、headers、请求数据或路由来完成。路由是最简单的，也是客户端最常访问的，所以我将演示如何使用它；但是，在决定如何做出决定时，请仔细考虑您的要求。

[Route( "{clientId}" )]
public Foo Get( string clientId ) { /* ... */ }

接下来我们需要为客户端获取正确的DbContext。我们想继续使用 DI，但这很复杂，因为在创建控制器之前我们不知道需要什么连接字符串来构造 object。因此，我们需要注入某种形式的工厂而不是 object 本身。在这种情况下，我们将其表示为 Func<string, IUnitOfWork>，并理解它将 'clientId' 作为字符串，而 returns 是适当实例化的 IUnitOfWork。我们也可以为此使用命名接口。

[RoutePrefix("foo")]
public class FooController : ApiController
{  
    private Func<string, IUnitOfWork> unitOfWorkFactory;

    public FooController( Func<string, IUnitOfWork> unitOfWorkFactory )
    {
        this.unitOfWorkFactory = unitOfWorkFactory;
    }

    [Route( "{clientId}" )]
    public Foo Get( string clientId )
    {
        var unitOfWork = unitOfWorkFactory(clientId);
        // ...
    }
}

剩下的就是配置我们的依赖注入容器来为我们提供Func<string, IUnitOfWork>。这在实施之间可能会有很大差异。以下是在 Autofac 中执行此操作的一种可能方法。

protected override void Load( ContainerBuilder builder )
{
    // It is expected `MyDbContext` has a constructor that takes the connection string as a parameter
    // This registration may need to be tweaked depending on what other constructors you have.
    builder.Register<MyDbContext>().ForType<DbContext>().InstancePerRequest();

    // It is expected `UnitOfWork`'s constructor takes a `DbContext` as a parameter
    builder.RegisterType<UnitOfWork>().ForType<IUnitOfWork>().InstancePerRequest();

    builder.Register<Func<string, Bar>>(
        c =>
            {
                var dbContextFactory = c.Resolve<Func<string, DbContext>>();
                var unitOfWorkFactory = c.Resolve<Func<DbContext, IUnitOfWork>>();

                return clientId =>
                    {
                        // You may have injected another type to help with this
                        var connectionString = GetConnectionStringForClient(clientId);
                        return unitOfWorkFactory(dbContextFactory(connectionString));
                    };
            });
 }

使用了 Autofac，因为注释表明当前正在使用 Autofac，尽管使用其他容器可能会产生类似的结果。

控制器应该能够被实例化，并且每个请求都会使用适当的连接字符串。

基于链接项目的示例注册：

builder.Register<Func<string, IEmployeeService>>(
    c =>
        {
            var dbContextFactory = c.Resolve<Func<string, IMainContext>>();
            var unitOfWorkFactory = c.Resolve<Func<IMainContext, IUnitOfWork>>();
            var repositoryFactory = c.Resolve<Func<IMainContext, IEmployeeRepository>>();
            var serviceFactory = c.Resolve<Func<IUnitOfWork, IEmployeeService>>();

            return clientId =>
                {
                    // You may have injected another type to help with this
                    var connectionString = GetConnectionStringForClient(clientId);

                    IMainContext dbContext = dbContextFactory(connectionString);
                    IUnitOfWork unitOfWork = unitOfWorkFactory(dbContext);
                    IEmployeeRepository employeeRepository = repositoryFactory(dbContext);
                    unitOfWork.employeeRepositoty = employeeRepository;

                    return serviceFactory(unitOfWork);
                };
        });

如果您发现注册变得过于繁琐，因为需要手动进行一些布线，您可能需要在确定客户端后查看更新（或创建新的）容器，以便您可以更多地依赖容器。

Web 的动态连接字符串 Api

Dynamic connection string to Web Api

asp.net-web-api

entity-framework-6

connection-string