2
pom.xml
2
pom.xml
@@ -77,7 +77,7 @@
|
||||
<checkstyle.skip>${skipTests}</checkstyle.skip>
|
||||
<checkstyle.version>8.40</checkstyle.version>
|
||||
<classgraph.version>4.8.149</classgraph.version>
|
||||
<cypher-dsl.version>2023.0.0</cypher-dsl.version>
|
||||
<cypher-dsl.version>2023.2.0</cypher-dsl.version>
|
||||
<dist.id>spring-data-neo4j</dist.id>
|
||||
<dist.key>SDNEO4J</dist.key>
|
||||
<flatten-maven-plugin.version>1.2.5</flatten-maven-plugin.version>
|
||||
|
||||
@@ -1161,7 +1161,7 @@ public final class Neo4jTemplate implements
|
||||
.returning(Constants.NAME_OF_SYNTHESIZED_ROOT_NODE).build();
|
||||
|
||||
Map<String, Object> usedParameters = new HashMap<>(parameters);
|
||||
usedParameters.putAll(rootNodesStatement.getParameters());
|
||||
usedParameters.putAll(rootNodesStatement.getCatalog().getParameters());
|
||||
|
||||
final Collection<Long> rootNodeIds = new HashSet<>(neo4jClient
|
||||
.query(renderer.render(rootNodesStatement))
|
||||
@@ -1186,7 +1186,7 @@ public final class Neo4jTemplate implements
|
||||
.returning(cypherGenerator.createReturnStatementForMatch(entityMetaData)).build();
|
||||
|
||||
usedParameters = new HashMap<>(parameters);
|
||||
usedParameters.putAll(statement.getParameters());
|
||||
usedParameters.putAll(statement.getCatalog().getParameters());
|
||||
neo4jClient.query(renderer.render(statement))
|
||||
.bindAll(usedParameters)
|
||||
.fetch()
|
||||
|
||||
@@ -714,7 +714,7 @@ public final class ReactiveNeo4jTemplate implements
|
||||
.returning(cypherGenerator.createReturnStatementForMatch(entityMetaData)).build();
|
||||
|
||||
Map<String, Object> usedParameters = new HashMap<>(parameters);
|
||||
usedParameters.putAll(statement.getParameters());
|
||||
usedParameters.putAll(statement.getCatalog().getParameters());
|
||||
return neo4jClient.query(renderer.render(statement))
|
||||
.bindAll(usedParameters)
|
||||
.fetchAs(TupleOfLongsHolder.class)
|
||||
|
||||
@@ -159,7 +159,7 @@ public final class TemplateSupport {
|
||||
*/
|
||||
static Map<String, Object> mergeParameters(Statement statement, @Nullable Map<String, Object> parameters) {
|
||||
|
||||
Map<String, Object> mergedParameters = new HashMap<>(statement.getParameters());
|
||||
Map<String, Object> mergedParameters = new HashMap<>(statement.getCatalog().getParameters());
|
||||
if (parameters != null) {
|
||||
mergedParameters.putAll(parameters);
|
||||
}
|
||||
|
||||
@@ -84,7 +84,7 @@ final class CypherdslBasedQuery extends AbstractNeo4jQuery {
|
||||
statement = (Statement) parameters[0];
|
||||
}
|
||||
|
||||
Map<String, Object> boundParameters = statement.getParameters();
|
||||
Map<String, Object> boundParameters = statement.getCatalog().getParameters();
|
||||
return PreparedQuery.queryFor(returnedType)
|
||||
.withCypherQuery(statement.getCypher())
|
||||
.withParameters(boundParameters)
|
||||
@@ -99,6 +99,6 @@ final class CypherdslBasedQuery extends AbstractNeo4jQuery {
|
||||
Statement countStatement = (Statement) parameterAccessor.getValues()[1];
|
||||
return Optional.of(PreparedQuery.queryFor(Long.class)
|
||||
.withCypherQuery(countStatement.getCypher())
|
||||
.withParameters(countStatement.getParameters()).build());
|
||||
.withParameters(countStatement.getCatalog().getParameters()).build());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -126,7 +126,7 @@ public final class CypherdslConditionExecutorImpl<T> implements CypherdslConditi
|
||||
|
||||
Statement statement = CypherGenerator.INSTANCE.prepareMatchOf(this.metaData, condition)
|
||||
.returning(Functions.count(asterisk())).build();
|
||||
return this.neo4jOperations.count(statement, statement.getParameters());
|
||||
return this.neo4jOperations.count(statement, statement.getCatalog().getParameters());
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -66,7 +66,7 @@ final class ReactiveCypherdslBasedQuery extends AbstractReactiveNeo4jQuery {
|
||||
"The first parameter to a Cypher based method must be a statement");
|
||||
Statement statement = (Statement) parameters[0];
|
||||
|
||||
Map<String, Object> boundParameters = statement.getParameters();
|
||||
Map<String, Object> boundParameters = statement.getCatalog().getParameters();
|
||||
return PreparedQuery.queryFor(returnedType)
|
||||
.withCypherQuery(statement.getCypher())
|
||||
.withParameters(boundParameters)
|
||||
|
||||
@@ -113,7 +113,7 @@ public final class ReactiveCypherdslConditionExecutorImpl<T> implements Reactive
|
||||
|
||||
Statement statement = CypherGenerator.INSTANCE.prepareMatchOf(this.metaData, condition)
|
||||
.returning(Functions.count(asterisk())).build();
|
||||
return this.neo4jOperations.count(statement, statement.getParameters());
|
||||
return this.neo4jOperations.count(statement, statement.getCatalog().getParameters());
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -119,7 +119,7 @@ public final class ReactiveQuerydslNeo4jPredicateExecutor<T> implements Reactive
|
||||
Statement statement = CypherGenerator.INSTANCE.prepareMatchOf(this.metaData,
|
||||
Cypher.adapt(predicate).asCondition())
|
||||
.returning(Functions.count(asterisk())).build();
|
||||
return this.neo4jOperations.count(statement, statement.getParameters());
|
||||
return this.neo4jOperations.count(statement, statement.getCatalog().getParameters());
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user