Skip to content

Commit 5529293

Browse files
committed
Don't extract the query on composite databases
1 parent ac6417e commit 5529293

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

cypher-aggregation/src/main/java/org/neo4j/gds/projection/CypherAggregation.java

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,10 +109,18 @@ public CompatUserAggregator create(Context ctx) throws ProcedureException {
109109
var metricsFacade = Neo4jProxy.lookupComponentProvider(ctx, MetricsFacade.class, true);
110110
var username = Neo4jProxy.lookupComponentProvider(ctx, Username.class, true);
111111
var transaction = Neo4jProxy.lookupComponentProvider(ctx, Transaction.class, true);
112-
var ktxs = GraphDatabaseApiProxy.resolveDependency(databaseService, KernelTransactions.class);
113-
var queryProvider = ExecutingQueryProvider.fromTransaction(ktxs, transaction);
114112

115113
var runsOnCompositeDatabase = Neo4jProxy.isCompositeDatabase(databaseService);
114+
115+
ExecutingQueryProvider queryProvider;
116+
if (runsOnCompositeDatabase) {
117+
queryProvider = ExecutingQueryProvider.empty();
118+
} else {
119+
assert GraphDatabaseApiProxy.containsDependency(databaseService, KernelTransactions.class);
120+
var ktxs = GraphDatabaseApiProxy.resolveDependency(databaseService, KernelTransactions.class);
121+
queryProvider = ExecutingQueryProvider.fromTransaction(ktxs, transaction);
122+
}
123+
116124
var writeMode = runsOnCompositeDatabase
117125
? WriteMode.NONE
118126
: WriteMode.LOCAL;

0 commit comments

Comments
 (0)