Re-enabling all muted tests.

The tests were failing because in 4.0 we introduced a new parallel runtime which does not preserve the order of the unwind lists.
As the driver tests are testing the driver not missing any records rather than cypher semantics, we change the query to preserve order in our test instead.

Author: Zhen Li

driver/src/test/java/org/neo4j/driver/integration/ResultStreamIT.java

@@ -27,14 +27,12 @@
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.stream.IntStream;
 
-import org.neo4j.driver.internal.util.DisabledOnNeo4jWith;
 import org.neo4j.driver.Record;
 import org.neo4j.driver.StatementResult;
 import org.neo4j.driver.Transaction;
 import org.neo4j.driver.Value;
 import org.neo4j.driver.exceptions.ClientException;
 import org.neo4j.driver.exceptions.NoSuchRecordException;
-import org.neo4j.driver.internal.util.Neo4jFeature;
 import org.neo4j.driver.summary.ResultSummary;
 import org.neo4j.driver.util.ParallelizableIT;
 import org.neo4j.driver.util.SessionExtension;
@@ -282,13 +280,12 @@ void shouldConvertImmediatelyFailingStatementResultToStream()
     }
 
     @Test
-    @DisabledOnNeo4jWith( Neo4jFeature.NO_STREAMING )
     void shouldConvertEventuallyFailingStatementResultToStream()
     {
         List<Integer> seen = new ArrayList<>();
 
         ClientException e = assertThrows( ClientException.class,
-                () -> session.run( "UNWIND range(5, 0, -1) AS x RETURN x / x" )
+                () -> session.run( "CYPHER runtime=interpreted UNWIND range(5, 0, -1) AS x RETURN x / x" )
                         .stream()
                         .forEach( record -> seen.add( record.get( 0 ).asInt() ) ) );
 

driver/src/test/java/org/neo4j/driver/integration/SessionIT.java

@@ -94,7 +94,6 @@
 import static org.neo4j.driver.internal.util.Matchers.arithmeticError;
 import static org.neo4j.driver.internal.util.Matchers.connectionAcquisitionTimeoutError;
 import static org.neo4j.driver.internal.util.Neo4jFeature.BOLT_V4;
-import static org.neo4j.driver.internal.util.Neo4jFeature.NO_STREAMING;
 import static org.neo4j.driver.util.DaemonThreadFactory.daemon;
 import static org.neo4j.driver.util.Neo4jRunner.DEFAULT_AUTH_TOKEN;
 
@@ -865,12 +864,11 @@ void shouldNotRetryOnConnectionAcquisitionTimeout()
     }
 
     @Test
-    @DisabledOnNeo4jWith( NO_STREAMING )
     void shouldAllowConsumingRecordsAfterFailureInSessionClose()
     {
         Session session = neo4j.driver().session();
 
-        StatementResult result = session.run( "UNWIND [2, 4, 8, 0] AS x RETURN 32 / x" );
+        StatementResult result = session.run( "CYPHER runtime=interpreted UNWIND [2, 4, 8, 0] AS x RETURN 32 / x" );
 
         ClientException e = assertThrows( ClientException.class, session::close );
         assertThat( e, is( arithmeticError() ) );

driver/src/test/java/org/neo4j/driver/integration/async/AsyncSessionIT.java

@@ -80,7 +80,6 @@
 import static org.neo4j.driver.internal.util.Matchers.containsResultAvailableAfterAndResultConsumedAfter;
 import static org.neo4j.driver.internal.util.Matchers.syntaxError;
 import static org.neo4j.driver.internal.util.Neo4jFeature.BOLT_V3;
-import static org.neo4j.driver.internal.util.Neo4jFeature.NO_STREAMING;
 import static org.neo4j.driver.util.TestUtil.await;
 import static org.neo4j.driver.util.TestUtil.awaitAll;
 
@@ -156,10 +155,9 @@ void shouldFailForIncorrectQuery()
     }
 
     @Test
-    @DisabledOnNeo4jWith( NO_STREAMING )
     void shouldFailWhenQueryFailsAtRuntime()
     {
-        StatementResultCursor cursor = await( session.runAsync( "UNWIND [1, 2, 0] AS x RETURN 10 / x" ) );
+        StatementResultCursor cursor = await( session.runAsync( "CYPHER runtime=interpreted UNWIND [1, 2, 0] AS x RETURN 10 / x" ) );
 
         Record record1 = await( cursor.nextAsync() );
         assertNotNull( record1 );

driver/src/test/java/org/neo4j/driver/integration/reactive/RxStatementResultIT.java

@@ -26,10 +26,9 @@
 
 import org.neo4j.driver.Record;
 import org.neo4j.driver.exceptions.ClientException;
-import org.neo4j.driver.internal.util.DisabledOnNeo4jWith;
 import org.neo4j.driver.internal.util.EnabledOnNeo4jWith;
-import org.neo4j.driver.reactive.RxStatementResult;
 import org.neo4j.driver.reactive.RxSession;
+import org.neo4j.driver.reactive.RxStatementResult;
 import org.neo4j.driver.summary.ResultSummary;
 import org.neo4j.driver.summary.StatementType;
 import org.neo4j.driver.util.DatabaseExtension;
@@ -45,7 +44,6 @@
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.neo4j.driver.Values.parameters;
 import static org.neo4j.driver.internal.util.Neo4jFeature.BOLT_V4;
-import static org.neo4j.driver.internal.util.Neo4jFeature.NO_STREAMING;
 
 @EnabledOnNeo4jWith( BOLT_V4 )
 @ParallelizableIT
@@ -283,12 +281,11 @@ void shouldDiscardRecords()
     }
 
     @Test
-    @DisabledOnNeo4jWith( NO_STREAMING )
     void shouldStreamCorrectRecordsBackBeforeError()
     {
         RxSession session = neo4j.driver().rxSession();
 
-        RxStatementResult result = session.run( "UNWIND range(5, 0, -1) AS x RETURN x / x" );
+        RxStatementResult result = session.run( "CYPHER runtime=interpreted UNWIND range(5, 0, -1) AS x RETURN x / x" );
         StepVerifier.create( Flux.from( result.records() ).map( record -> record.get( 0 ).asInt() ) )
                 .expectNext( 1 )
                 .expectNext( 1 )

driver/src/test/java/org/neo4j/driver/internal/util/Neo4jFeature.java

@@ -28,8 +28,7 @@ public enum Neo4jFeature
     SPATIAL_TYPES( v3_4_0 ),
     TEMPORAL_TYPES( v3_4_0 ),
     BOLT_V3( v3_5_0 ),
-    BOLT_V4( v4_0_0 ),
-    NO_STREAMING( v4_0_0 ); // the cypher cannot streaming records before error
+    BOLT_V4( v4_0_0 );
 
     private final ServerVersion availableFromVersion;