Merge pull request #313 from Shaddix/feature/fix-312-replica

FIX #312 Cannot delete from table "lock" because it does not have a repli…

Author: azygis

src/Hangfire.PostgreSql/Scripts/Install.v21.sql

@@ -0,0 +1,13 @@
+SET search_path = 'hangfire';
+
+DO $$
+BEGIN
+    IF EXISTS(SELECT 1 FROM "schema" WHERE "version"::integer >= 21) THEN
+        RAISE EXCEPTION 'version-already-applied';
+END IF;
+END $$;
+
+-- Set REPLICA IDENTITY to allow replication
+ALTER TABLE "lock" REPLICA IDENTITY USING INDEX "lock_resource_key";
+
+RESET search_path;

tests/Hangfire.PostgreSql.Tests/PostgreSqlInstallerFacts.cs

@@ -19,7 +19,7 @@ public void InstallingSchemaUpdatesVersionAndShouldNotThrowAnException()
           PostgreSqlObjectsInstaller.Install(connection, schemaName);
 
           int lastVersion = connection.Query<int>($@"SELECT version FROM ""{schemaName}"".""schema""").Single();
-          Assert.Equal(20, lastVersion);
+          Assert.Equal(21, lastVersion);
 
           connection.Execute($@"DROP SCHEMA ""{schemaName}"" CASCADE;");
         });
@@ -38,7 +38,7 @@ public void InstallingSchemaWithCapitalsUpdatesVersionAndShouldNotThrowAnExcepti
           PostgreSqlObjectsInstaller.Install(connection, schemaName);
 
           int lastVersion = connection.Query<int>($@"SELECT version FROM ""{schemaName}"".""schema""").Single();
-          Assert.Equal(20, lastVersion);
+          Assert.Equal(21, lastVersion);
 
           connection.Execute($@"DROP SCHEMA ""{schemaName}"" CASCADE;");
         });