|
34 | 34 |
|
35 | 35 | import org.neo4j.cypherdsl.core.Node; |
36 | 36 | import org.neo4j.cypherdsl.core.ResultStatement; |
37 | | -import org.neo4j.cypherdsl.core.executables.ExecutableStatement; |
38 | 37 | import org.neo4j.driver.Driver; |
39 | 38 | import org.neo4j.driver.Record; |
40 | 39 | import org.neo4j.driver.Session; |
@@ -140,7 +139,7 @@ Long createInstance(Class<?> type) { |
140 | 139 | statement = Cypher.create(nodeTemplate).returning(nodeTemplate.internalId()).build(); |
141 | 140 | } |
142 | 141 |
|
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(); |
144 | 143 |
|
145 | 144 | tx.commit(); |
146 | 145 | return id; |
@@ -182,7 +181,7 @@ long[] createRelatedInstances(Class<?> type) { |
182 | 181 | .build(); |
183 | 182 | } |
184 | 183 |
|
185 | | - Record record = ExecutableStatement.makeExecutable(statement).fetchWith(tx).get(0); |
| 184 | + Record record = tx.run(statement.getCypher(), statement.getCatalog().getParameters()).single(); |
186 | 185 | long id1 = record.get(0).asLong(); |
187 | 186 | long id2 = record.get(1).asLong(); |
188 | 187 |
|
@@ -270,7 +269,7 @@ private void assertInternal(Long expectedVersion, Class<?> type, Long id) { |
270 | 269 |
|
271 | 270 | private void assertImpl(Long expectedVersion, ResultStatement resultStatement) { |
272 | 271 | 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(); |
274 | 273 | assertThat(result).hasSize(1) |
275 | 274 | .first().satisfies(record -> { |
276 | 275 | long version = record.get(0).asLong(); |
|
0 commit comments