diff --git a/src/libstore/ca-specific-schema.sql b/src/libstore/ca-specific-schema.sql
index d2ea347fb..c01dc5a76 100644
--- a/src/libstore/ca-specific-schema.sql
+++ b/src/libstore/ca-specific-schema.sql
@@ -21,7 +21,7 @@ create index if not exists IndexRealisations on Realisations(drvPath, outputName
 -- realisations
 create trigger if not exists DeleteSelfRefsViaRealisations before delete on ValidPaths
   begin
-    delete from RealisationsRefs where realisationReference = (
+    delete from RealisationsRefs where realisationReference in (
       select id from Realisations where outputPath = old.id
     );
   end;
diff --git a/src/libstore/local-store.cc b/src/libstore/local-store.cc
index e64917956..76524b01c 100644
--- a/src/libstore/local-store.cc
+++ b/src/libstore/local-store.cc
@@ -148,7 +148,7 @@ void migrateCASchema(SQLite& db, Path schemaPath, AutoCloseFD& lockFd)
             db.exec(R"(
                 create trigger if not exists DeleteSelfRefsViaRealisations before delete on ValidPaths
                 begin
-                    delete from RealisationsRefs where realisationReference = (
+                    delete from RealisationsRefs where realisationReference in (
                     select id from Realisations where outputPath = old.id
                     );
                 end;