ASP.NET Core 2中动态切换连接字符串时如何创建数据库并初始化种子数据？

嘿，这个多租户动态建库的场景我之前在项目里实操过，刚好能给你一套落地的方案！核心思路是把租户连接信息的动态获取、数据库创建、种子初始化拆成独立模块，确保不重启应用就能完成整个流程。

1. 先给DbContext做动态连接改造 #

你的DbContext不能硬写连接字符串，得能实时拿到当前租户的连接信息。可以通过注入一个租户上下文服务来实现：

public class TenantDbContext : DbContext
{
    private readonly ITenantContext _tenantContext;

    // 构造注入租户上下文，用来拿当前租户的连接字符串
    public TenantDbContext(ITenantContext tenantContext)
    {
        _tenantContext = tenantContext;
    }

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        var connectionString = _tenantContext.CurrentTenant.ConnectionString;
        if (!string.IsNullOrEmpty(connectionString))
        {
            // 替换成你用的数据库提供商，比如UseNpgsql/UseSqlite
            optionsBuilder.UseSqlServer(connectionString);
        }
        base.OnConfiguring(optionsBuilder);
    }

    // 你的业务实体DbSet
    public DbSet<Product> Products { get; set; }
}

这里的ITenantContext是你自己实现的请求作用域服务，用来存储当前请求对应的租户信息（比如从请求头、路由或Token里解析出来）。

2. 写一个专门的租户数据库初始化服务 #

接下来需要一个独立服务，负责在租户注册时创建数据库并初始化种子数据。这个服务要能临时创建对应租户的DbContext实例，执行建库和种子操作：

public interface ITenantDatabaseInitializer
{
    Task SetupTenantDatabaseAsync(Tenant newTenant);
}

public class TenantDatabaseInitializer : ITenantDatabaseInitializer
{
    private readonly IServiceProvider _serviceProvider;

    public TenantDatabaseInitializer(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public async Task SetupTenantDatabaseAsync(Tenant newTenant)
    {
        // 创建临时作用域，确保每个租户的DbContext独立
        using var scope = _serviceProvider.CreateScope();
        var context = scope.ServiceProvider.GetRequiredService<TenantDbContext>();
        
        // 先检查数据库是否存在，避免重复创建
        var dbExists = await context.Database.CanConnectAsync();
        if (!dbExists)
        {
            // 创建数据库（如果用EF迁移，换成await context.Database.MigrateAsync()）
            await context.Database.EnsureCreatedAsync();
            // 初始化种子数据
            await SeedTenantDefaultDataAsync(context);
        }
    }

    private async Task SeedTenantDefaultDataAsync(TenantDbContext context)
    {
        // 种子数据要保证幂等性，先检查再添加
        if (!context.Products.Any())
        {
            context.Products.AddRange(new List<Product>
            {
                new Product { Name = "租户默认商品1", Price = 9.9m },
                new Product { Name = "租户默认商品2", Price = 19.9m }
            });
            await context.SaveChangesAsync();
        }
    }
}

当你在后台管理系统注册新租户时，直接调用这个服务的SetupTenantDatabaseAsync方法就行，完全不需要重启应用。

3. 确保租户上下文的请求隔离 #

在ASP.NET Core里，要把租户相关服务注册为请求作用域，保证每个请求拿到的都是当前租户的信息：

// 注册租户上下文和初始化服务
services.AddScoped<ITenantContext, TenantContext>();
services.AddScoped<ITenantDatabaseInitializer, TenantDatabaseInitializer>();
// DbContext也用请求作用域，避免连接串混乱
services.AddDbContext<TenantDbContext>();

然后写一个中间件，在请求进来时解析租户标识，把租户信息设置到TenantContext里：

public class TenantMiddleware
{
    private readonly RequestDelegate _next;

    public TenantMiddleware(RequestDelegate next)
    {
        _next = next;
    }

    public async Task InvokeAsync(HttpContext context, ITenantContext tenantContext, ITenantRepository tenantRepo)
    {
        // 从请求头获取租户ID，你也可以从路由、Token里取
        var tenantId = context.Request.Headers["X-Tenant-Id"].FirstOrDefault();
        if (!string.IsNullOrEmpty(tenantId))
        {
            var tenant = await tenantRepo.GetByIdAsync(tenantId);
            if (tenant != null)
            {
                tenantContext.CurrentTenant = tenant;
            }
        }

        await _next(context);
    }
}

// 注册中间件
app.UseMiddleware<TenantMiddleware>();

4. 几个关键注意事项 #

• 连接串安全：租户的连接字符串一定要加密存储，比如用ASP.NET Core的配置加密或者专门的密钥管理工具。
• 种子数据幂等：初始化种子时必须先检查数据是否存在，否则重复执行会导致主键冲突。
• 性能优化：如果租户数量大，建库和迁移操作可能耗时，可以把初始化逻辑放到后台任务里异步执行。
• DbContext隔离：绝对不能用单例的DbContext，否则会出现不同租户连接串混用的问题。

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