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

…ca identity and publishes deletes #312
hangfire-postgres · Jul 12, 2023 · 4914923 · 4914923
1 parent 3949e31
commit 4914923
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 2 deletions.
diff --git a/src/Hangfire.PostgreSql/Scripts/Install.v21.sql b/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;
diff --git a/tests/Hangfire.PostgreSql.Tests/PostgreSqlInstallerFacts.cs b/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;");
         });