Merge pull request #2808 from gterdem/1371-Add_multitenant_migrations_to_the_migrator_console_application

Add multi tenant migrations to the migrator console application

templates/app/aspnet-core/src/MyCompanyName.MyProjectName.Domain/Data/MyProjectNameDbMigrationService.cs

@@ -1,8 +1,12 @@
-using System.Threading.Tasks;
+using System;
+using System.Linq;
+using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Logging.Abstractions;
 using Volo.Abp.Data;
 using Volo.Abp.DependencyInjection;
+using Volo.Abp.MultiTenancy;
+using Volo.Abp.TenantManagement;
 
 namespace MyCompanyName.MyProjectName.Data
 {
@@ -12,13 +16,19 @@ namespace MyCompanyName.MyProjectName.Data
 
         private readonly IDataSeeder _dataSeeder;
         private readonly IMyProjectNameDbSchemaMigrator _dbSchemaMigrator;
+        private readonly ITenantRepository _tenantRepository;
+        private readonly ICurrentTenant _currentTenant;
 
         public MyProjectNameDbMigrationService(
             IDataSeeder dataSeeder,
-            IMyProjectNameDbSchemaMigrator dbSchemaMigrator)
+            IMyProjectNameDbSchemaMigrator dbSchemaMigrator,
+            ITenantRepository tenantRepository,
+            ICurrentTenant currentTenant)
         {
             _dataSeeder = dataSeeder;
             _dbSchemaMigrator = dbSchemaMigrator;
+            _tenantRepository = tenantRepository;
+            _currentTenant = currentTenant;
 
             Logger = NullLogger<MyProjectNameDbMigrationService>.Instance;
         }
@@ -27,13 +37,38 @@ namespace MyCompanyName.MyProjectName.Data
         {
             Logger.LogInformation("Started database migrations...");
 
-            Logger.LogInformation("Migrating database schema...");
+            await MigrateHostDatabaseAsync();
+
+            foreach (var tenant in await _tenantRepository.GetListAsync())
+            {
+                using (_currentTenant.Change(tenant.Id))
+                {
+                    await MigrateTenantDatabasesAsync(tenant);
+                }
+            }
+            Logger.LogInformation("Successfully completed database migrations.");
+        }
+
+        private async Task MigrateHostDatabaseAsync()
+        {
+            Logger.LogInformation("Migrating host database schema...");
             await _dbSchemaMigrator.MigrateAsync();
 
-            Logger.LogInformation("Executing database seed...");
+            Logger.LogInformation("Executing host database seed...");
             await _dataSeeder.SeedAsync();
 
-            Logger.LogInformation("Successfully completed database migrations.");
+            Logger.LogInformation("Successfully completed host database migrations.");
+        }
+
+        private async Task MigrateTenantDatabasesAsync(Tenant tenant)
+        {
+            Logger.LogInformation($"Migrating {tenant.Name} database schema...");
+            await _dbSchemaMigrator.MigrateAsync();
+
+            Logger.LogInformation($"Executing {tenant.Name} database seed...");
+            await _dataSeeder.SeedAsync(tenant.Id);
+
+            Logger.LogInformation($"Successfully completed {tenant.Name} database migrations.");
         }
     }
 }

templates/app/aspnet-core/src/MyCompanyName.MyProjectName.EntityFrameworkCore.DbMigrations/EntityFrameworkCore/EntityFrameworkCoreMyProjectNameDbSchemaMigrator.cs

@@ -1,24 +1,29 @@
-using System.Threading.Tasks;
+using System;
+using System.Threading.Tasks;
 using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.DependencyInjection;
 using MyCompanyName.MyProjectName.Data;
 using Volo.Abp.DependencyInjection;
 
 namespace MyCompanyName.MyProjectName.EntityFrameworkCore
 {
     [Dependency(ReplaceServices = true)]
-    public class EntityFrameworkCoreMyProjectNameDbSchemaMigrator 
+    public class EntityFrameworkCoreMyProjectNameDbSchemaMigrator
         : IMyProjectNameDbSchemaMigrator, ITransientDependency
     {
-        private readonly MyProjectNameMigrationsDbContext _dbContext;
+        private readonly IServiceProvider _serviceProvider;
 
-        public EntityFrameworkCoreMyProjectNameDbSchemaMigrator(MyProjectNameMigrationsDbContext dbContext)
+        public EntityFrameworkCoreMyProjectNameDbSchemaMigrator(IServiceProvider serviceProvider)
         {
-            _dbContext = dbContext;
+            _serviceProvider = serviceProvider;
         }
 
         public async Task MigrateAsync()
         {
-            await _dbContext.Database.MigrateAsync();
+            await _serviceProvider
+                .GetRequiredService<MyProjectNameMigrationsDbContext>()
+                .Database
+                .MigrateAsync();
         }
     }
 }