Skip to content

Commit 0a45f86

Browse files
committed
Assume 3.1+ Neo4j for bookmark test
1 parent eb67a9c commit 0a45f86

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

driver/src/test/java/org/neo4j/driver/v1/integration/TransactionAsyncIT.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -360,8 +360,7 @@ public void shouldNotAllowNewStatementsAfterAnIncorrectStatement()
360360
@Test
361361
public void shouldFailBoBeginTxWithInvalidBookmark()
362362
{
363-
assumeTrue( "Neo4j " + neo4j.version() + " does not support bookmarks",
364-
neo4j.version().greaterThanOrEqual( v3_1_0 ) );
363+
assumeDatabaseSupportsBookmarks();
365364

366365
Session session = neo4j.driver().session( "InvalidBookmark" );
367366

@@ -941,6 +940,8 @@ public void shouldAllowQueriesWhenMarkedForSuccess()
941940
@Test
942941
public void shouldUpdateSessionBookmarkAfterCommit()
943942
{
943+
assumeDatabaseSupportsBookmarks();
944+
944945
String bookmarkBefore = session.lastBookmark();
945946

946947
getBlocking( session.beginTransactionAsync()
@@ -1000,4 +1001,10 @@ private void testConsume( String query )
10001001
// no records should be available, they should all be consumed
10011002
assertNull( await( cursor.nextAsync() ) );
10021003
}
1004+
1005+
private void assumeDatabaseSupportsBookmarks()
1006+
{
1007+
assumeTrue( "Neo4j " + neo4j.version() + " does not support bookmarks",
1008+
neo4j.version().greaterThanOrEqual( v3_1_0 ) );
1009+
}
10031010
}

0 commit comments

Comments
 (0)