AspNetCORE WebAPI依赖注入绑定动态连接字符串DAL的方案咨询

针对你这个ASP.NET Core WebAPI结合Tortuga.Chain的动态数据库连接问题，我整理了一套可行的解决方案，既能在根层通过DI绑定DAL，又能根据请求动态生成连接字符串：

因为连接字符串依赖请求上下文里的initial catalog，我们不能直接注册固定的仓储实例，而是要利用ASP.NET Core的范围服务和工厂模式，在每个请求生命周期内动态创建对应数据库的数据源和仓储。

1. 定义通用仓储接口与Tortuga.Chain实现 #

首先明确你的通用仓储契约，然后基于Tortuga.Chain的数据源实现具体仓储——这里的关键是让仓储依赖ISqlServerDataSource而非硬编码的连接字符串：

// 通用仓储接口
public interface IRepository<T> where T : class
{
    Task<IEnumerable<T>> GetAllAsync();
    // 按需添加其他CRUD方法
}

// Tortuga.Chain实现的SQL Server仓储
public class SqlServerRepository<T> : IRepository<T> where T : class
{
    private readonly ISqlServerDataSource _dataSource;

    // 构造函数注入数据源
    public SqlServerRepository(ISqlServerDataSource dataSource)
    {
        _dataSource = dataSource ?? throw new ArgumentNullException(nameof(dataSource));
    }

    public async Task<IEnumerable<T>> GetAllAsync()
    {
        // 利用Tortuga.Chain的流畅API查询
        return await _dataSource.From<T>().ToCollectionAsync();
    }
}

2. 实现动态数据源工厂 #

我们需要一个工厂类，根据传入的initial catalog拼接完整连接字符串并创建Tortuga.Chain的数据源。先在appsettings.json里配置基础连接字符串（不含Initial Catalog）：

{
  "ConnectionStrings": {
    "SqlServerBase": "Server=your-server;Integrated Security=True;TrustServerCertificate=True;"
  }
}

然后实现工厂：

public interface IDataSourceFactory
{
    ISqlServerDataSource CreateDataSource(string initialCatalog);
}

public class SqlServerDataSourceFactory : IDataSourceFactory
{
    private readonly string _baseConnectionString;

    // 从配置注入基础连接字符串
    public SqlServerDataSourceFactory(IConfiguration config)
    {
        _baseConnectionString = config.GetConnectionString("SqlServerBase") 
            ?? throw new InvalidOperationException("未配置基础SQL Server连接字符串");
    }

    public ISqlServerDataSource CreateDataSource(string initialCatalog)
    {
        if (string.IsNullOrWhiteSpace(initialCatalog))
            throw new ArgumentException("Initial Catalog不能为空", nameof(initialCatalog));
        
        // 拼接完整连接字符串
        var fullConnectionString = $"{_baseConnectionString}Initial Catalog={initialCatalog};";
        return new SqlServerDataSource(fullConnectionString);
    }
}

在Program.cs里注册这个工厂为范围服务（每个请求一个实例）：

builder.Services.AddScoped<IDataSourceFactory, SqlServerDataSourceFactory>();
// 必须注册HttpContextAccessor才能在DI中获取请求上下文
builder.Services.AddHttpContextAccessor();

3. 根层DI绑定动态仓储 #

这里有两种推荐方式，按需选择：

方式一：直接通过委托注册通用仓储（最简洁） #

在Program.cs里，注册IRepository<T>的动态创建逻辑，让DI容器在每个请求时自动根据请求上下文生成对应仓储：

builder.Services.AddScoped(typeof(IRepository<>), sp =>
{
    // 获取请求上下文
    var httpContextAccessor = sp.GetRequiredService<IHttpContextAccessor>();
    var httpContext = httpContextAccessor.HttpContext 
        ?? throw new InvalidOperationException("无法获取请求上下文");

    // 从请求中获取initial catalog（这里假设从Header获取，可根据实际改为请求体/路由参数）
    var initialCatalog = httpContext.Request.Headers["X-Database-Name"].FirstOrDefault();
    if (string.IsNullOrWhiteSpace(initialCatalog))
        throw new BadHttpRequestException("请求缺少X-Database-Name头信息");

    // 验证数据库名（可选但推荐，防止恶意输入）
    if (!IsValidDatabaseName(initialCatalog))
        throw new BadHttpRequestException("不允许访问该数据库");

    // 创建数据源和仓储
    var factory = sp.GetRequiredService<IDataSourceFactory>();
    var dataSource = factory.CreateDataSource(initialCatalog);
    var repositoryType = typeof(SqlServerRepository<>).MakeGenericType(sp.GetType().GenericTypeArguments[0]);
    
    return Activator.CreateInstance(repositoryType, dataSource) as IRepository;
});

// 辅助方法：验证数据库名是否在允许列表中
bool IsValidDatabaseName(string dbName)
{
    var allowedDatabases = new List<string> { "DB1", "DB2", "DB3" };
    return allowedDatabases.Contains(dbName);
}

方式二：使用仓储解析器（更灵活） #

如果需要在控制器里手动指定数据库名（而非自动从上下文获取），可以创建一个解析器：

public interface IRepositoryResolver
{
    IRepository<T> GetRepository<T>(string initialCatalog) where T : class;
}

public class RepositoryResolver : IRepositoryResolver
{
    private readonly IDataSourceFactory _factory;

    public RepositoryResolver(IDataSourceFactory factory)
    {
        _factory = factory;
    }

    public IRepository<T> GetRepository<T>(string initialCatalog) where T : class
    {
        var dataSource = _factory.CreateDataSource(initialCatalog);
        return new SqlServerRepository<T>(dataSource);
    }
}

注册解析器：

builder.Services.AddScoped<IRepositoryResolver, RepositoryResolver>();

然后在控制器里使用：

[ApiController]
[Route("api/[controller]")]
public class ProductsController : ControllerBase
{
    private readonly IRepositoryResolver _resolver;

    public ProductsController(IRepositoryResolver resolver)
    {
        _resolver = resolver;
    }

    [HttpPost("list")]
    public async Task<IActionResult> GetProducts([FromHeader] string X-Database-Name)
    {
        var productRepo = _resolver.GetRepository<Product>(X-Database-Name);
        var products = await productRepo.GetAllAsync();
        return Ok(products);
    }
}

4. 关键注意事项 #

• 安全验证：一定要对initial catalog做白名单验证，防止恶意用户指定不存在或敏感的数据库。
• 资源管理：Tortuga.Chain的ISqlServerDataSource会自动管理数据库连接的打开和关闭，无需手动释放，但要确保它是请求范围的，避免资源泄漏。
• 异常处理：在创建数据源和仓储时添加异常捕获，比如数据库不存在、连接失败等情况，返回友好的错误响应。
• 性能优化：可以考虑对常用数据库的数据源做缓存，避免重复创建连接字符串和数据源实例。

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