Make migrator usable with postgres

src/Infrastructure/LeanCode.EFMigrator/BaseFactory.cs

@@ -1,7 +1,5 @@
-using System;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Design;
-using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 
@@ -15,31 +13,20 @@ public abstract class BaseFactory<TContext, TFactory> : IDesignTimeDbContextFact
         typeof(TFactory).Assembly.GetName().Name
         ?? throw new InvalidOperationException("This type is not supported on Assembly-less runtimes.");
 
-    protected virtual void UseAdditionalSqlServerDbContextOptions(SqlServerDbContextOptionsBuilder builder) { }
-
-    protected virtual void UseAdditionalDbContextOptions(DbContextOptionsBuilder<TContext> builder) { }
-
     public TContext CreateDbContext(string[] args)
     {
-        var connectionString =
-            MigrationsConfig.GetConnectionString()
-            ?? throw new InvalidOperationException("Failed to find connection string.");
+        var builder = new DbContextOptionsBuilder<TContext>().UseLoggerFactory(
+            new ServiceCollection()
+                .AddLogging(cfg => cfg.AddConsole())
+                .BuildServiceProvider()
+                .GetRequiredService<ILoggerFactory>()
+        );
 
-        var builder = new DbContextOptionsBuilder<TContext>()
-            .UseLoggerFactory(
-                new ServiceCollection()
-                    .AddLogging(cfg => cfg.AddConsole())
-                    .BuildServiceProvider()
-                    .GetRequiredService<ILoggerFactory>()
-            )
-            .UseSqlServer(
-                connectionString,
-                cfg => UseAdditionalSqlServerDbContextOptions(cfg.MigrationsAssembly(AssemblyName))
-            );
-
-        UseAdditionalDbContextOptions(builder);
+        builder = UseDbProvider(builder);
 
         return (TContext?)Activator.CreateInstance(typeof(TContext), builder.Options)
             ?? throw new InvalidOperationException("Failed to create DbContext instance.");
     }
+
+    public abstract DbContextOptionsBuilder<TContext> UseDbProvider(DbContextOptionsBuilder<TContext> builder);
 }

src/Infrastructure/LeanCode.EFMigrator/LeanCode.EFMigrator.csproj

@@ -4,15 +4,14 @@
     <ProjectReference Include="../../Infrastructure/LeanCode.AzureIdentity/LeanCode.AzureIdentity.csproj" />
 
     <PackageReference Include="Microsoft.EntityFrameworkCore" />
-    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" />
 
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" />
     <PackageReference Include="Microsoft.Extensions.Logging" />
     <PackageReference Include="Microsoft.Extensions.Logging.Console" />
 
     <PackageReference Include="Azure.Identity" />
     <PackageReference Include="Azure.Security.KeyVault.Secrets" />
-    <PackageReference Include="Microsoft.Data.SqlClient" />
   </ItemGroup>
 
 </Project>

src/Infrastructure/LeanCode.EFMigrator/MigrationsConfig.cs

@@ -5,7 +5,7 @@ namespace LeanCode.EFMigrator;
 
 public static class MigrationsConfig
 {
-    public static string ConnectionStringKey { get; set; } = "SqlServer:ConnectionString";
+    public static string ConnectionStringKey { get; set; }
 
     [System.Diagnostics.CodeAnalysis.SuppressMessage("?", "CA1056", Justification = "It should be `string`.")]
     public static string KeyVaultUrlKey { get; set; } = "KeyVault:VaultUrl";

src/Infrastructure/LeanCode.EFMigrator/Migrator.cs

@@ -1,4 +1,4 @@
-using Microsoft.Data.SqlClient;
+using System.Data.Common;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Design;
 using static System.Console;
@@ -120,11 +120,12 @@ protected virtual int Seed()
     {
         int rowsAffected;
 
-        using (var connection = new SqlConnection(MigrationsConfig.GetConnectionString()))
+        using (var connection = GetDbConnection())
         {
             connection.Open();
 
-            using var command = new SqlCommand(File.ReadAllText(SeedPath), connection);
+            using var command = connection.CreateCommand();
+            command.CommandText = File.ReadAllText(SeedPath);
 
             rowsAffected = command.ExecuteNonQuery();
         }
@@ -133,4 +134,6 @@ protected virtual int Seed()
 
         return rowsAffected;
     }
+
+    protected abstract DbConnection GetDbConnection();
 }