Merge pull request #259 from thobe/1.1-routing-refactor

Refactor routing logic to better handle failures
neo4j · Oct 26, 2016 · 9dcbbf9 · 9dcbbf9
2 parents 0b2b4b2 + 28a3c3f
commit 9dcbbf9
Show file tree

Hide file tree

Showing 25 changed files with 3,722 additions and 1,208 deletions.
diff --git a/driver/src/main/java/org/neo4j/driver/internal/ClusterView.java b/driver/src/main/java/org/neo4j/driver/internal/ClusterView.java
diff --git a/driver/src/main/java/org/neo4j/driver/internal/NetworkSession.java b/driver/src/main/java/org/neo4j/driver/internal/NetworkSession.java
@@ -113,6 +113,11 @@ public StatementResult run( String statementText, Value statementParameters )
     public StatementResult run( Statement statement )
     {
         ensureConnectionIsValidBeforeRunningSession();
+        return run( connection, statement );
+    }
+
+    public static StatementResult run( Connection connection, Statement statement )
+    {
         InternalStatementResult cursor = new InternalStatementResult( connection, null, statement );
         connection.run( statement.text(), statement.parameters().asMap( Values.ofValue() ),
                 cursor.runResponseCollector() );