在Entity Framework Core中为所有数据库创建和应用迁移

Yurii N. 发表于 Dev

尤里·N

我有ApplicationDbContext，它可以动态地将连接字符串更改为数据库，具体取决于用户的库名。因此，对于每个库，我都有自己的数据库。在创建迁移并应用它们时，它们仅与具有默认连接字符串的默认数据库相关，其中未定义库名。

我如何才能对所有这些动态创建的数据库进行迁移并将其应用到库中，这些数据库取决于库名（它们在创建后就存在，它们已经完全定义并且可以正常工作）？

塞里·基斯里

如果我对您的理解正确，则应执行以下操作：

1）实施服务，该服务将迁移您的架构和种子数据。（尽管他们在最新版本中做了什么，我仍然更喜欢我的实现）

帮手

    public static async Task EnsureSeedData(IServiceProvider serviceProvider)
    {
        using (var scope = serviceProvider.GetRequiredService<IServiceScopeFactory>().CreateScope())
        {
            // here could be several seed services if necessary
            var seedService = scope.ServiceProvider.GetService<ISeedService>();
            await seedService.MigrateAsync();
            await seedService.SeedAsync();
        }
    }

ISeedService接口

internal interface ISeedService
{
    Task MigrateAsync();
    Task SeedAsync();
}

SeedService实施

internal sealed class SeedService : ISeedService
{
    private readonly InitializeContext _identityContext;

    public SeedService(InitializeContext identityContext)
    {
        _identityContext = identityContext;
    }

    public async Task MigrateAsync()
    {
        await _identityContext.Database.MigrateAsync();
    }

    public async Task SeedAsync()
    {
        if (_identityContext.AllMigrationsApplied())
        {
            var strategy = _identityContext.Database.CreateExecutionStrategy();
            await strategy.ExecuteAsync(async () =>
            {
                using (var transaction = await _identityContext.Database.BeginTransactionAsync())
                {
                    // seed data if necessary
                    transaction.Commit();
                }
            });
        }
    }
}

Program.cs文件

public class Program
{
    public static void Main(string[] args)
    {
        var host = CreateWebHostBuilder(args).Build();
        Task.Run(async () =>
        {
            await SeedData.EnsureSeedData(host.Services);
        }).Wait();
        host.Run();
    }

    public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
        WebHost.CreateDefaultBuilder(args)
            .UseStartup<Startup>();
}

2）在DI中注册上下文和相关服务，这将允许动态检索连接字符串。有几种方法可以实现，我的实现不是最好的方法，所以这取决于您。

Startup.cs文件

public class Startup
{
    public IConfiguration Configuration { get; }
    public Startup(IConfiguration configuration)
    {
        Configuration = configuration;
    }

    public void ConfigureServices(IServiceCollection services)
    {
        services.AddTransient<ISeedService, SeedService>();
        services.AddScoped<IDbConfiguration, FakeDbConfiguration>();
        services.AddDbContext<InitializeContext>((provider, builder) =>
        {
            var dbConfiguration = provider.GetService<IDbConfiguration>();
            builder.UseSqlServer(dbConfiguration.Connection);
        });

        // omitted
    }

    public void Configure(IApplicationBuilder app, IHostingEnvironment env)
    {
        // omitted
    }
}

DbConfiguration文件。

internal sealed class FakeDbConfiguration : IDbConfiguration
{
    private readonly IConfiguration _configuration;
    public FakeDbConfiguration(IConfiguration configuration)
    {
        _configuration = configuration;
    }

    // REPLACE THIS PART WITH YOURS IMPLEMENTATION
    public string Connection => _configuration["Database:Connection"];

希望对您有帮助。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。