CypherExecutor { public Neo4jResponse executeQueries(List<Neo4jStatement> queries) throws SQLException { HttpPost request = new HttpPost(currentTransactionUrl); StringEntity requestEntity = new StringEntity(Neo4jStatement.toJson(queries, mapper), ContentType.APPLICATION_JSON); request.setEntity(requestEntity); return this.executeHttpRequest(request); } CypherExecutor(String host, Integer port, Boolean secure, Properties properties); Neo4jResponse executeQueries(List<Neo4jStatement> queries); Neo4jResponse executeQuery(Neo4jStatement query); void commit(); void rollback(); Boolean getAutoCommit(); void setAutoCommit(Boolean autoCommit); String getServerVersion(); void close(); Integer getOpenTransactionId();  }
@Test public void executeQueryOnDownServerShouldFail() throws Exception { expectedEx.expect(SQLException.class); List<Neo4jStatement> queries = getRandomNeo4jStatementFromCSV("data/queries.csv", 1).get("object"); executor.executeQueries(queries); }