如何在ASP.NET 8 MVC控制器中注入带动态连接字符串的DbContext

问题背景 #

我使用C#、ASP.NET 8.0（MVC）、EF Core 8.0（刚接触EF Core），在AppSettings.Json中配置了多个数据库连接字符串。现在需要根据第三方系统传入控制器（比如HomeController）的特定值，动态使用对应的数据库连接字符串创建DbContext。

我目前实现了一个静态类来创建DbContext，代码如下：

现有DbContextFactory代码 #

public static class DbContextFactory
{
    public static Dictionary<string, string>? DbConnectionStrings { get; set; }

    public static void SetDbConnectionString(Dictionary<string, string>? dbConnectionStrings)
    {
        DbConnectionStrings = dbConnectionStrings;
    }

    public static ApplicationContext Create(string dbConnId)
    {
        DbContextOptionsBuilder<ApplicationContext> optionsBuilder = new();
        optionsBuilder.UseSqlServer(DbConnectionStrings![dbConnId]);
        return new ApplicationContext(optionsBuilder.Options);
    }
}

现有控制器代码 #

public IActionResult GetGroupMemebers(string userid)
{
    try
    {
        string databaseId = GetUserDatabaseFromCustomApplication(userid);
        appContext ??= DbContextFactory.Create(databaseId.ToLower());        

       IEnumerable<TeamOwner>? teamOwners = databaseService.GetTeamOwnersAsync(appContext, userid);
        
        // 其他业务逻辑
        
    }
    catch (Exception ex)
    {       
        return View("Index", grpMemVM);
    }
}

现在想知道通过依赖注入实现动态传入对应连接字符串DbContext的最佳方式，希望能提供示例代码。

最佳实践：结合依赖注入的DbContext工厂模式 #

静态类的方式存在线程安全风险、难以测试、不符合依赖注入设计原则等问题。推荐使用依赖注入友好的工厂类，配合ASP.NET的DI容器管理，同时保证动态切换连接字符串的能力。

步骤1：配置AppSettings.Json #

确保连接字符串配置格式如下（示例）：

{
  "ConnectionStrings": {
    "DbA": "Server=xxx;Database=DbA;Trusted_Connection=True;TrustServerCertificate=True",
    "DbB": "Server=xxx;Database=DbB;Trusted_Connection=True;TrustServerCertificate=True",
    "DbC": "Server=xxx;Database=DbC;Trusted_Connection=True;TrustServerCertificate=True"
  }
}

步骤2：创建非静态的DbContext工厂接口和实现 #

定义工厂接口以支持依赖注入和测试：

public interface IApplicationContextFactory
{
    ApplicationContext Create(string dbConnId);
}

public class ApplicationContextFactory : IApplicationContextFactory
{
    private readonly IConfiguration _configuration;

    // 通过DI注入IConfiguration，直接读取配置文件中的连接字符串
    public ApplicationContextFactory(IConfiguration configuration)
    {
        _configuration = configuration;
    }

    public ApplicationContext Create(string dbConnId)
    {
        var connectionString = _configuration.GetConnectionString(dbConnId) 
            ?? throw new InvalidOperationException($"找不到ID为{dbConnId}的数据库连接字符串");

        var optionsBuilder = new DbContextOptionsBuilder<ApplicationContext>();
        optionsBuilder.UseSqlServer(connectionString);
        
        return new ApplicationContext(optionsBuilder.Options);
    }
}

步骤3：在Program.cs中注册服务 #

在ASP.NET 8的Program.cs里注册工厂接口和实现：

var builder = WebApplication.CreateBuilder(args);

// 添加控制器视图服务
builder.Services.AddControllersWithViews();

// 注册DbContext工厂（Scoped生命周期，和控制器一致）
builder.Services.AddScoped<IApplicationContextFactory, ApplicationContextFactory>();

// 可选：注册默认DbContext配置（动态切换时主要用工厂，此配置可作为 fallback）
builder.Services.AddDbContext<ApplicationContext>(options =>
{
    options.UseSqlServer(builder.Configuration.GetConnectionString("Default"));
});

var app = builder.Build();

// 中间件配置
app.UseHttpsRedirection();
app.UseStaticFiles();
app.UseRouting();
app.UseAuthorization();

app.MapControllerRoute(
    name: "default",
    pattern: "{controller=Home}/{action=Index}/{id?}");

app.Run();

步骤4：在控制器中使用工厂动态创建DbContext #

修改控制器代码，通过构造函数注入工厂，按需创建对应连接的DbContext：

public class HomeController : Controller
{
    private readonly IApplicationContextFactory _dbContextFactory;
    private readonly IDatabaseService _databaseService;

    // 构造函数注入工厂和业务服务
    public HomeController(IApplicationContextFactory dbContextFactory, IDatabaseService databaseService)
    {
        _dbContextFactory = dbContextFactory;
        _databaseService = databaseService;
    }

    public async Task<IActionResult> GetGroupMemebers(string userid)
    {
        try
        {
            string databaseId = GetUserDatabaseFromCustomApplication(userid);
            // 使用using管理DbContext生命周期，确保资源及时释放
            using var appContext = _dbContextFactory.Create(databaseId.ToLower());        

            IEnumerable<TeamOwner>? teamOwners = await _databaseService.GetTeamOwnersAsync(appContext, userid);
            
            // 业务逻辑处理，填充视图模型
            var grpMemVM = new GroupMembersViewModel();
            // ...
            
            return View("Index", grpMemVM);
        }
        catch (Exception ex)
        {       
            // 异常处理逻辑
            var grpMemVM = new GroupMembersViewModel();
            return View("Index", grpMemVM);
        }
    }

    // 从第三方系统获取用户对应的数据库ID
    private string GetUserDatabaseFromCustomApplication(string userid)
    {
        // 示例逻辑：根据userid映射到数据库ID
        return userid.StartsWith("A") ? "DbA" : "DbB";
    }
}

关键改进点 #

1. 移除静态类：避免线程安全问题，同时支持单元测试（可Mock工厂接口）。
2. 原生配置读取：通过DI注入的IConfiguration直接读取AppSettings，无需手动维护连接字符串字典。
3. 生命周期管理：用using包裹动态创建的DbContext，确保资源及时释放，避免内存泄漏。
4. 符合依赖注入原则：控制器通过构造函数注入依赖，代码更易维护和扩展。

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