Don't extract the query on composite databases

neo4j · Nov 20, 2023 · 7b4175c · 7b4175c
1 parent 3fa65aa
commit 7b4175c
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/cypher-aggregation/src/main/java/org/neo4j/gds/projection/CypherAggregation.java b/cypher-aggregation/src/main/java/org/neo4j/gds/projection/CypherAggregation.java
@@ -109,10 +109,18 @@ public CompatUserAggregator create(Context ctx) throws ProcedureException {
         var metricsFacade = Neo4jProxy.lookupComponentProvider(ctx, MetricsFacade.class, true);
         var username = Neo4jProxy.lookupComponentProvider(ctx, Username.class, true);
         var transaction = Neo4jProxy.lookupComponentProvider(ctx, Transaction.class, true);
-        var ktxs = GraphDatabaseApiProxy.resolveDependency(databaseService, KernelTransactions.class);
-        var queryProvider = ExecutingQueryProvider.fromTransaction(ktxs, transaction);
 
         var runsOnCompositeDatabase = Neo4jProxy.isCompositeDatabase(databaseService);
+
+        ExecutingQueryProvider queryProvider;
+        if (runsOnCompositeDatabase) {
+            queryProvider = ExecutingQueryProvider.empty();
+        } else {
+            assert GraphDatabaseApiProxy.containsDependency(databaseService, KernelTransactions.class);
+            var ktxs = GraphDatabaseApiProxy.resolveDependency(databaseService, KernelTransactions.class);
+            queryProvider = ExecutingQueryProvider.fromTransaction(ktxs, transaction);
+        }
+
         var writeMode = runsOnCompositeDatabase
             ? WriteMode.NONE
             : WriteMode.LOCAL;