parameterize postgres provider schema name

Author: Poorya

src/providers/WorkflowCore.Persistence.PostgreSQL/MigrationContextFactory.cs

@@ -7,7 +7,7 @@ public class MigrationContextFactory : IDesignTimeDbContextFactory<PostgresConte
     {
         public PostgresContext CreateDbContext(string[] args)
         {
-            return new PostgresContext(@"Server=127.0.0.1;Port=5432;Database=workflow;User Id=postgres;Password=password;");
+            return new PostgresContext(@"Server=127.0.0.1;Port=5432;Database=workflow;User Id=postgres;Password=password;","wfc");
         }
     }
 }

src/providers/WorkflowCore.Persistence.PostgreSQL/PostgresContext.cs

@@ -12,11 +12,13 @@ namespace WorkflowCore.Persistence.PostgreSQL
     public class PostgresContext : WorkflowDbContext
     {
         private readonly string _connectionString;
+        private readonly string _schemaName;
 
-        public PostgresContext(string connectionString)
+        public PostgresContext(string connectionString,string schemaName)
             :base()
         {   
             _connectionString = connectionString;
+            _schemaName = schemaName;
         }
 
         protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
@@ -27,37 +29,37 @@ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
 
         protected override void ConfigureSubscriptionStorage(EntityTypeBuilder<PersistedSubscription> builder)
         {
-            builder.ToTable("Subscription", "wfc");
+            builder.ToTable("Subscription", _schemaName);
             builder.Property(x => x.PersistenceId).ValueGeneratedOnAdd();
         }
 
         protected override void ConfigureWorkflowStorage(EntityTypeBuilder<PersistedWorkflow> builder)
         {
-            builder.ToTable("Workflow", "wfc");
+            builder.ToTable("Workflow", _schemaName);
             builder.Property(x => x.PersistenceId).ValueGeneratedOnAdd();
         }
 
         protected override void ConfigureExecutionPointerStorage(EntityTypeBuilder<PersistedExecutionPointer> builder)
         {
-            builder.ToTable("ExecutionPointer", "wfc");
+            builder.ToTable("ExecutionPointer", _schemaName);
             builder.Property(x => x.PersistenceId).ValueGeneratedOnAdd();
         }
 
         protected override void ConfigureExecutionErrorStorage(EntityTypeBuilder<PersistedExecutionError> builder)
         {
-            builder.ToTable("ExecutionError", "wfc");
+            builder.ToTable("ExecutionError", _schemaName);
             builder.Property(x => x.PersistenceId).ValueGeneratedOnAdd();
         }
 
         protected override void ConfigureExetensionAttributeStorage(EntityTypeBuilder<PersistedExtensionAttribute> builder)
         {
-            builder.ToTable("ExtensionAttribute", "wfc");
+            builder.ToTable("ExtensionAttribute", _schemaName);
             builder.Property(x => x.PersistenceId).ValueGeneratedOnAdd();
         }
 
         protected override void ConfigureEventStorage(EntityTypeBuilder<PersistedEvent> builder)
         {
-            builder.ToTable("Event", "wfc");
+            builder.ToTable("Event", _schemaName);
             builder.Property(x => x.PersistenceId).ValueGeneratedOnAdd();
         }
     }

src/providers/WorkflowCore.Persistence.PostgreSQL/PostgresContextFactory.cs

@@ -9,15 +9,17 @@ namespace WorkflowCore.Persistence.PostgreSQL
     public class PostgresContextFactory : IWorkflowDbContextFactory
     {
         private readonly string _connectionString;
+        private readonly string _schemaName;
 
-        public PostgresContextFactory(string connectionString)
+        public PostgresContextFactory(string connectionString, string schemaName)
         {
             _connectionString = connectionString;
+            _schemaName = schemaName;
         }
 
         public WorkflowDbContext Build()
         {
-            return new PostgresContext(_connectionString);
+            return new PostgresContext(_connectionString,_schemaName);
         }
     }
 }

src/providers/WorkflowCore.Persistence.PostgreSQL/ServiceCollectionExtensions.cs

@@ -10,9 +10,10 @@ namespace Microsoft.Extensions.DependencyInjection
 {
     public static class ServiceCollectionExtensions
     {
-        public static WorkflowOptions UsePostgreSQL(this WorkflowOptions options, string connectionString, bool canCreateDB, bool canMigrateDB)
+        public static WorkflowOptions UsePostgreSQL(this WorkflowOptions options,
+            string connectionString, bool canCreateDB, bool canMigrateDB, string schemaName="wfc")
         {
-            options.UsePersistence(sp => new EntityFrameworkPersistenceProvider(new PostgresContextFactory(connectionString), canCreateDB, canMigrateDB));
+            options.UsePersistence(sp => new EntityFrameworkPersistenceProvider(new PostgresContextFactory(connectionString, schemaName), canCreateDB, canMigrateDB));
             return options;
         }
     }

test/WorkflowCore.Tests.PostgreSQL/PostgresPersistenceProviderFixture.cs

@@ -19,7 +19,7 @@ public class PostgresPersistenceProviderFixture : BasePersistenceFixture
         public PostgresPersistenceProviderFixture(PostgresDockerSetup dockerSetup, ITestOutputHelper output)
         {
             output.WriteLine($"Connecting on {PostgresDockerSetup.ConnectionString}");
-            _subject = new EntityFrameworkPersistenceProvider(new PostgresContextFactory(PostgresDockerSetup.ConnectionString), true, true);
+            _subject = new EntityFrameworkPersistenceProvider(new PostgresContextFactory(PostgresDockerSetup.ConnectionString,"wfc"), true, true);
             _subject.EnsureStoreExists();
         }
     }