diff --git a/operator/src/main/java/it/aboutbits/postgresql/crd/grant/GrantReconciler.java b/operator/src/main/java/it/aboutbits/postgresql/crd/grant/GrantReconciler.java
index 2c2da1d..cfd8a25 100644
--- a/operator/src/main/java/it/aboutbits/postgresql/crd/grant/GrantReconciler.java
+++ b/operator/src/main/java/it/aboutbits/postgresql/crd/grant/GrantReconciler.java
@@ -169,9 +169,10 @@ public DeleteControl cleanup(
                     .rescheduleAfter(60, TimeUnit.SECONDS);
         }
 
+        var database = spec.getDatabase();
         var clusterConnection = clusterConnectionOptional.get();
 
-        try (var dsl = contextFactory.getDSLContext(clusterConnection)) {
+        try (var dsl = contextFactory.getDSLContext(clusterConnection, database)) {
             dsl.transaction(cfg -> {
                 var tx = cfg.dsl();