Skip to content

Commit e584bd0

Browse files
refactor: Remove usage of Cypher-DSL driver integrations.
Signed-off-by: Michael Simons <michael@simons.ac>
1 parent 00cb7e9 commit e584bd0

File tree

2 files changed

+7
-9
lines changed

2 files changed

+7
-9
lines changed

src/test/java/org/springframework/data/neo4j/integration/imperative/Neo4jClientIT.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,7 @@
1919
import org.junit.jupiter.api.Test;
2020
import org.neo4j.cypherdsl.core.Cypher;
2121
import org.neo4j.cypherdsl.core.Node;
22-
import org.neo4j.cypherdsl.core.executables.ExecutableResultStatement;
23-
import org.neo4j.cypherdsl.core.executables.ExecutableStatement;
22+
import org.neo4j.cypherdsl.core.Statement;
2423
import org.neo4j.driver.Driver;
2524
import org.neo4j.driver.Record;
2625
import org.neo4j.driver.Session;
@@ -75,12 +74,12 @@ void clientShouldIntegrateWithCypherDSL(@Autowired TransactionTemplate transacti
7574

7675
Node namedAnswer = Cypher.node("TheAnswer", Cypher.mapOf("value",
7776
Cypher.literalOf(23).multiply(Cypher.literalOf(2)).subtract(Cypher.literalOf(4)))).named("n");
78-
ExecutableResultStatement statement = ExecutableStatement.makeExecutable(Cypher.create(namedAnswer)
77+
Statement statement = Cypher.create(namedAnswer)
7978
.returning(namedAnswer)
80-
.build());
79+
.build();
8180

8281
Long vanishedId = transactionTemplate.execute(transactionStatus -> {
83-
List<Record> records = statement.fetchWith(client.getQueryRunner());
82+
List<Record> records = client.getQueryRunner().run(statement.getCypher()).list();
8483
assertThat(records).hasSize(1)
8584
.first().extracting(r -> r.get("n").get("value").asLong()).isEqualTo(42L);
8685

src/test/java/org/springframework/data/neo4j/integration/versioned_self_references/TestBase.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@
3434

3535
import org.neo4j.cypherdsl.core.Node;
3636
import org.neo4j.cypherdsl.core.ResultStatement;
37-
import org.neo4j.cypherdsl.core.executables.ExecutableStatement;
3837
import org.neo4j.driver.Driver;
3938
import org.neo4j.driver.Record;
4039
import org.neo4j.driver.Session;
@@ -140,7 +139,7 @@ Long createInstance(Class<?> type) {
140139
statement = Cypher.create(nodeTemplate).returning(nodeTemplate.internalId()).build();
141140
}
142141

143-
long id = ExecutableStatement.makeExecutable(statement).fetchWith(tx).get(0).get(0).asLong();
142+
long id = tx.run(statement.getCypher(), statement.getCatalog().getParameters()).single().get(0).asLong();
144143

145144
tx.commit();
146145
return id;
@@ -182,7 +181,7 @@ long[] createRelatedInstances(Class<?> type) {
182181
.build();
183182
}
184183

185-
Record record = ExecutableStatement.makeExecutable(statement).fetchWith(tx).get(0);
184+
Record record = tx.run(statement.getCypher(), statement.getCatalog().getParameters()).single();
186185
long id1 = record.get(0).asLong();
187186
long id2 = record.get(1).asLong();
188187

@@ -270,7 +269,7 @@ private void assertInternal(Long expectedVersion, Class<?> type, Long id) {
270269

271270
private void assertImpl(Long expectedVersion, ResultStatement resultStatement) {
272271
try (Session session = driver.session(bookmarkCapture.createSessionConfig())) {
273-
List<Record> result = ExecutableStatement.makeExecutable(resultStatement).fetchWith(session);
272+
List<Record> result = session.run(resultStatement.getCypher(), resultStatement.getCatalog().getParameters()).list();
274273
assertThat(result).hasSize(1)
275274
.first().satisfies(record -> {
276275
long version = record.get(0).asLong();

0 commit comments

Comments
 (0)