Updated solution-wide migration checker and handlers

services/administration/src/EShopOnAbp.AdministrationService.HttpApi.Host/DbMigrations/AdministrationServiceDatabaseMigrationChecker.cs

@@ -1,13 +1,13 @@
 using EShopOnAbp.AdministrationService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
 using Volo.Abp.Uow;
 
 namespace EShopOnAbp.AdministrationService.DbMigrations
 {
-    public class AdministrationServiceDatabaseMigrationChecker : PendingMigrationsCheckerBase<AdministrationServiceDbContext>
+    public class AdministrationServiceDatabaseMigrationChecker : PendingEfCoreMigrationsChecker<AdministrationServiceDbContext>
     {
         public AdministrationServiceDatabaseMigrationChecker(
             IUnitOfWorkManager unitOfWorkManager,

services/administration/src/EShopOnAbp.AdministrationService.HttpApi.Host/DbMigrations/AdministrationServiceDatabaseMigrationEventHandler.cs

@@ -1,8 +1,8 @@
 using EShopOnAbp.AdministrationService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
 using System.Linq;
 using System.Threading.Tasks;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.Authorization.Permissions;
 using Volo.Abp.Data;
 using Volo.Abp.EventBus.Distributed;
@@ -13,7 +13,7 @@ using Volo.Abp.Uow;
 namespace EShopOnAbp.AdministrationService.DbMigrations
 {
     public class AdministrationServiceDatabaseMigrationEventHandler
-    : DatabaseMigrationEventHandlerBase<AdministrationServiceDbContext>,
+    : DatabaseEfCoreMigrationEventHandler<AdministrationServiceDbContext>,
             IDistributedEventHandler<TenantCreatedEto>,
             IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {

services/catalog/src/EShopOnAbp.CatalogService.HttpApi.Host/CatalogServiceHttpApiHostModule.cs

@@ -1,5 +1,4 @@
 using EShopOnAbp.CatalogService.DbMigrations;
-using EShopOnAbp.CatalogService.EntityFrameworkCore;
 using EShopOnAbp.Shared.Hosting.AspNetCore;
 using EShopOnAbp.Shared.Hosting.Microservices;
 using Microsoft.AspNetCore.Builder;
@@ -9,6 +8,7 @@ using Microsoft.Extensions.Hosting;
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using EShopOnAbp.CatalogService.MongoDB;
 using Volo.Abp;
 using Volo.Abp.AspNetCore.Mvc;
 using Volo.Abp.Modularity;
@@ -19,7 +19,7 @@ namespace EShopOnAbp.CatalogService
     [DependsOn(
         typeof(CatalogServiceHttpApiModule),
         typeof(CatalogServiceApplicationModule),
-        typeof(CatalogServiceEntityFrameworkCoreModule),
+        typeof(CatalogServiceMongoDbModule),
         typeof(EShopOnAbpSharedHostingMicroservicesModule)
     )]
     public class CatalogServiceHttpApiHostModule : AbpModule

services/catalog/src/EShopOnAbp.CatalogService.HttpApi.Host/DbMigrations/CatalogServiceDatabaseMigrationChecker.cs

@@ -1,14 +1,13 @@
-using EShopOnAbp.CatalogService.EntityFrameworkCore;
+using System;
+using EShopOnAbp.CatalogService.MongoDB;
 using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
-using System;
-using System.Threading.Tasks;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
 using Volo.Abp.Uow;
 
 namespace EShopOnAbp.CatalogService.DbMigrations
 {
-    public class CatalogServiceDatabaseMigrationChecker : PendingMigrationsCheckerBase<CatalogServiceDbContext>
+    public class CatalogServiceDatabaseMigrationChecker : PendingMongoDbMigrationsChecker<CatalogServiceMongoDbContext>
     {
         public CatalogServiceDatabaseMigrationChecker(
             IUnitOfWorkManager unitOfWorkManager,

services/catalog/src/EShopOnAbp.CatalogService.HttpApi.Host/DbMigrations/CatalogServiceDatabaseMigrationEventHandler.cs

@@ -1,7 +1,8 @@
-using EShopOnAbp.CatalogService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
 using System.Threading.Tasks;
+using EShopOnAbp.CatalogService.MongoDB;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.MongoDb;
 using Volo.Abp.Data;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
@@ -10,20 +11,21 @@ using Volo.Abp.Uow;
 namespace EShopOnAbp.CatalogService.DbMigrations
 {
     public class CatalogServiceDatabaseMigrationEventHandler
-        : DatabaseMigrationEventHandlerBase<CatalogServiceDbContext>,
+        : DatabaseMongoDbMigrationEventHandler<CatalogServiceMongoDbContext>,
         IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {
         public CatalogServiceDatabaseMigrationEventHandler(
             ICurrentTenant currentTenant,
             IUnitOfWorkManager unitOfWorkManager,
             ITenantStore tenantStore,
-            IDistributedEventBus distributedEventBus
+            IDistributedEventBus distributedEventBus,
+            IServiceProvider serviceProvider
             ) : base(
                 currentTenant,
                 unitOfWorkManager,
                 tenantStore,
                 distributedEventBus,
-                CatalogServiceDbProperties.ConnectionStringName)
+                CatalogServiceDbProperties.ConnectionStringName,serviceProvider)
         {
         }
 

services/catalog/src/EShopOnAbp.CatalogService.HttpApi.Host/EShopOnAbp.CatalogService.HttpApi.Host.csproj

@@ -11,7 +11,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\EShopOnAbp.CatalogService.Application\EShopOnAbp.CatalogService.Application.csproj" />
-    <ProjectReference Include="..\EShopOnAbp.CatalogService.EntityFrameworkCore\EShopOnAbp.CatalogService.EntityFrameworkCore.csproj" />
+    <ProjectReference Include="..\EShopOnAbp.CatalogService.MongoDB\EShopOnAbp.CatalogService.MongoDB.csproj" />
     <ProjectReference Include="..\EShopOnAbp.CatalogService.HttpApi\EShopOnAbp.CatalogService.HttpApi.csproj" />
   </ItemGroup>
 

services/identity/src/EShopOnAbp.IdentityService.HttpApi.Host/DbMigrations/IdentityServiceDatabaseMigrationChecker.cs

@@ -1,7 +1,7 @@
 using EShopOnAbp.IdentityService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
 using System.Threading.Tasks;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.EventBus.Local;
 using Volo.Abp.MultiTenancy;
@@ -9,7 +9,7 @@ using Volo.Abp.Uow;
 
 namespace EShopOnAbp.IdentityService.DbMigrations
 {
-    public class IdentityServiceDatabaseMigrationChecker : PendingMigrationsCheckerBase<IdentityServiceDbContext>
+    public class IdentityServiceDatabaseMigrationChecker : PendingEfCoreMigrationsChecker<IdentityServiceDbContext>
     {
         protected ILocalEventBus LocalEventBus { get; }
 

services/identity/src/EShopOnAbp.IdentityService.HttpApi.Host/DbMigrations/IdentityServiceDatabaseMigrationEventHandler.cs

@@ -1,9 +1,9 @@
 using EShopOnAbp.IdentityService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using Serilog;
 using System;
 using System.Collections.Generic;
 using System.Threading.Tasks;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.Data;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.EventBus.Local;
@@ -14,7 +14,7 @@ using Volo.Abp.Uow;
 namespace EShopOnAbp.IdentityService.DbMigrations
 {
     public class IdentityServiceDatabaseMigrationEventHandler
-        : DatabaseMigrationEventHandlerBase<IdentityServiceDbContext>,
+        : DatabaseEfCoreMigrationEventHandler<IdentityServiceDbContext>,
             IDistributedEventHandler<TenantCreatedEto>,
             IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {

services/ordering/src/EShopOnAbp.OrderingService.HttpApi.Host/DbMigrations/OrderingServiceDatabaseMigrationChecker.cs

@@ -1,13 +1,13 @@
 using EShopOnAbp.OrderingService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
 using Volo.Abp.Uow;
 
 namespace EShopOnAbp.OrderingService.DbMigrations
 {
-    public class OrderingServiceDatabaseMigrationChecker : PendingMigrationsCheckerBase<OrderingServiceDbContext>
+    public class OrderingServiceDatabaseMigrationChecker : PendingEfCoreMigrationsChecker<OrderingServiceDbContext>
     {
         public OrderingServiceDatabaseMigrationChecker(
             IUnitOfWorkManager unitOfWorkManager,

services/ordering/src/EShopOnAbp.OrderingService.HttpApi.Host/DbMigrations/OrderingServiceDatabaseMigrationEventHandler.cs

@@ -1,7 +1,7 @@
 using EShopOnAbp.OrderingService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
 using System.Threading.Tasks;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.Data;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
@@ -10,7 +10,7 @@ using Volo.Abp.Uow;
 namespace EShopOnAbp.OrderingService.DbMigrations
 {
     public class OrderingServiceDatabaseMigrationEventHandler
-        : DatabaseMigrationEventHandlerBase<OrderingServiceDbContext>,
+        : DatabaseEfCoreMigrationEventHandler<OrderingServiceDbContext>,
         IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {
         public OrderingServiceDatabaseMigrationEventHandler(

services/payment/src/EShopOnAbp.PaymentService.HttpApi.Host/DbMigrations/PaymentServiceDatabaseMigrationChecker.cs

@@ -1,17 +1,13 @@
 using EShopOnAbp.PaymentService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
 using Volo.Abp.Uow;
 
 namespace EShopOnAbp.PaymentService.DbMigrations
 {
-    public class PaymentServiceDatabaseMigrationChecker : PendingMigrationsCheckerBase<PaymentServiceDbContext>
+    public class PaymentServiceDatabaseMigrationChecker : PendingEfCoreMigrationsChecker<PaymentServiceDbContext>
     {
         public PaymentServiceDatabaseMigrationChecker(
             IUnitOfWorkManager unitOfWorkManager,

services/payment/src/EShopOnAbp.PaymentService.HttpApi.Host/DbMigrations/PaymentServiceDatabaseMigrationEventHandler.cs

@@ -1,7 +1,7 @@
 using EShopOnAbp.PaymentService.EntityFrameworkCore;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations;
 using System;
 using System.Threading.Tasks;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.Data;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.MultiTenancy;
@@ -10,7 +10,7 @@ using Volo.Abp.Uow;
 namespace EShopOnAbp.PaymentService.DbMigrations
 {
     public class PaymentServiceDatabaseMigrationEventHandler
-        : DatabaseMigrationEventHandlerBase<PaymentServiceDbContext>,
+        : DatabaseEfCoreMigrationEventHandler<PaymentServiceDbContext>,
         IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {
         public PaymentServiceDatabaseMigrationEventHandler(