public interface Neo4jClient
| Modifier and Type | Field and Description |
|---|---|
static String |
DEFAULT_POOL_NAME
The default shared client name.
|
| Modifier and Type | Method and Description |
|---|---|
Neo4jClient |
begin(Handler<AsyncResult<Neo4jTransaction>> resultHandler)
Begins a new transaction
|
Neo4jClient |
bulkWrite(List<Query> queries,
Handler<AsyncResult<SummaryCounters>> resultHandler)
Executes a list of queries in one transaction
|
void |
close()
Closes this client
|
static Neo4jClient |
createNonShared(Vertx vertx,
Neo4jClientOptions config)
Creates a Neo4j client which maintains its own driver session.
|
static Neo4jClient |
createShared(Vertx vertx,
Neo4jClientOptions config)
Same as
createShared(Vertx, Neo4jClientOptions, String) but with a default data source name |
static Neo4jClient |
createShared(Vertx vertx,
Neo4jClientOptions config,
String dataSourceName)
Creates a Neo4j client that shares its driver session with any other client having the same name.
|
Neo4jClient |
delete(String query,
Handler<AsyncResult<List<Record>>> resultHandler)
Executes and returns deleted results
|
Neo4jClient |
delete(String query,
Value parameters,
Handler<AsyncResult<List<Record>>> resultHandler)
Executes and returns deleted results
|
Neo4jClient |
execute(String query,
Handler<AsyncResult<ResultSummary>> resultHandler)
Executes a write transaction
|
Neo4jClient |
execute(String query,
Value parameters,
Handler<AsyncResult<ResultSummary>> resultHandler)
Executes a write transaction
|
Neo4jClient |
find(String query,
Handler<AsyncResult<List<Record>>> resultHandler)
Finds a list of records
|
Neo4jClient |
find(String query,
Value parameters,
Handler<AsyncResult<List<Record>>> resultHandler)
Finds a list of records
|
Neo4jClient |
findOne(String query,
Handler<AsyncResult<Record>> resultHandler)
Finds exactly one record
|
Neo4jClient |
findOne(String query,
Value parameters,
Handler<AsyncResult<Record>> resultHandler)
Finds exactly one record
|
Neo4jClient |
queryStream(String query,
Handler<AsyncResult<Neo4jRecordStream>> recordStreamHandler)
Opens a new stream of records
|
Neo4jClient |
queryStream(String query,
Value parameters,
Handler<AsyncResult<Neo4jRecordStream>> recordStreamHandler)
Opens a new stream of records
|
static final String DEFAULT_POOL_NAME
static Neo4jClient createShared(Vertx vertx, Neo4jClientOptions config)
createShared(Vertx, Neo4jClientOptions, String) but with a default data source namevertx - the Vert.x instanceconfig - the driver configurationstatic Neo4jClient createShared(Vertx vertx, Neo4jClientOptions config, String dataSourceName)
vertx - the Vert.x instanceconfig - the driver configurationdataSourceName - the data source namestatic Neo4jClient createNonShared(Vertx vertx, Neo4jClientOptions config)
It is not recommended to create several non shared clients in an application.
vertx - the Vert.x instanceconfig - the driver configurationNeo4jClient execute(String query, Handler<AsyncResult<ResultSummary>> resultHandler)
query - the cypher queryresultHandler - the handler to be called when the query has completedNeo4jClient execute(String query, Value parameters, Handler<AsyncResult<ResultSummary>> resultHandler)
query - the cypher queryparameters - the cypher parametersresultHandler - the handler to be called when the query has completedNeo4jClient delete(String query, Handler<AsyncResult<List<Record>>> resultHandler)
query - the cypher queryresultHandler - the handler to be called when the query has completedNeo4jClient delete(String query, Value parameters, Handler<AsyncResult<List<Record>>> resultHandler)
query - the cypher queryparameters - the cypher parametersresultHandler - the handler to be called when the query has completedNeo4jClient findOne(String query, Handler<AsyncResult<Record>> resultHandler)
query - the cypher queryresultHandler - the handler to be called when the query has completedNeo4jClient findOne(String query, Value parameters, Handler<AsyncResult<Record>> resultHandler)
query - the cypher queryparameters - the cypher parametersresultHandler - the handler to be called when the query has completedNeo4jClient find(String query, Handler<AsyncResult<List<Record>>> resultHandler)
query - the cypher queryresultHandler - the handler to be called when the query has completedNeo4jClient find(String query, Value parameters, Handler<AsyncResult<List<Record>>> resultHandler)
query - the cypher queryparameters - the cypher parametersresultHandler - the handler to be called when the query has completedNeo4jClient bulkWrite(List<Query> queries, Handler<AsyncResult<SummaryCounters>> resultHandler)
queries - the list of queries to executeresultHandler - the handler to be called when the query has completedNeo4jClient begin(Handler<AsyncResult<Neo4jTransaction>> resultHandler)
resultHandler - the handler to be called when the transaction has begunNeo4jClient queryStream(String query, Handler<AsyncResult<Neo4jRecordStream>> recordStreamHandler)
query - the cypher queryrecordStreamHandler - the handler to be called when the stream of records is availableNeo4jClient queryStream(String query, Value parameters, Handler<AsyncResult<Neo4jRecordStream>> recordStreamHandler)
query - the cypher queryparameters - the cypher parametersrecordStreamHandler - the handler to be called when the stream of records is availablevoid close()
Copyright © 2020 Eclipse. All rights reserved.