org.neo4j.driver.reactive

Interface RxStatementRunner

All Known Subinterfaces:

RxSession, RxTransaction

public interface RxStatementRunner

Common interface for components that can execute Neo4j statements using Reactive API.

Since:

2.0

See Also:

RxSession, RxTransaction

Method Summary

Modifier and Type	Method and Description
RxStatementResult	run(Statement statement) Register running of a statement and return a reactive result stream.
RxStatementResult	run(String statementTemplate) Register running of a statement and return a reactive result stream.
RxStatementResult	run(String statementTemplate, Map<String,Object> statementParameters) Register running of a statement and return a reactive result stream.
RxStatementResult	run(String statementTemplate, Record statementParameters) Register running of a statement and return a reactive result stream.
RxStatementResult	run(String statementTemplate, Value parameters) Register running of a statement and return a reactive result stream.

Method Detail

run

RxStatementResult run(String statementTemplate,
                      Value parameters)

Register running of a statement and return a reactive result stream. The statement is not executed when the reactive result is returned. Instead, the publishers in the result will actually start the execution of the statement. This method takes a set of parameters that will be injected into the statement by Neo4j. Using parameters is highly encouraged, it helps avoid dangerous cypher injection attacks and improves database performance as Neo4j can re-use query plans more often. This particular method takes a Value as its input. This is useful if you want to take a map-like value that you've gotten from a prior result and send it back as parameters. If you are creating parameters programmatically, run(String, Map) might be more helpful, it converts your map to a Value for you.

Parameters:

statementTemplate - text of a Neo4j statement

parameters - input parameters, should be a map Value, see Values.parameters(Object...).

Returns:

a reactive result.

run

RxStatementResult run(String statementTemplate,
                      Map<String,Object> statementParameters)

Register running of a statement and return a reactive result stream. The statement is not executed when the reactive result is returned. Instead, the publishers in the result will actually start the execution of the statement. This method takes a set of parameters that will be injected into the statement by Neo4j. Using parameters is highly encouraged, it helps avoid dangerous cypher injection attacks and improves database performance as Neo4j can re-use query plans more often. This version of run takes a Map of parameters. The values in the map must be values that can be converted to Neo4j types. See Values.parameters(Object...) for a list of allowed types.

Parameters:

statementTemplate - text of a Neo4j statement

statementParameters - input data for the statement

Returns:

a reactive result.

run

RxStatementResult run(String statementTemplate,
                      Record statementParameters)

Register running of a statement and return a reactive result stream. The statement is not executed when the reactive result is returned. Instead, the publishers in the result will actually start the execution of the statement. This method takes a set of parameters that will be injected into the statement by Neo4j. Using parameters is highly encouraged, it helps avoid dangerous cypher injection attacks and improves database performance as Neo4j can re-use query plans more often. This version of run takes a Record of parameters, which can be useful if you want to use the output of one statement as input for another.

Parameters:

statementTemplate - text of a Neo4j statement

statementParameters - input data for the statement

Returns:

a reactive result.

run

RxStatementResult run(String statementTemplate)

Register running of a statement and return a reactive result stream. The statement is not executed when the reactive result is returned. Instead, the publishers in the result will actually start the execution of the statement.

Parameters:

statementTemplate - text of a Neo4j statement

Returns:

a reactive result.

run

RxStatementResult run(Statement statement)

Register running of a statement and return a reactive result stream. The statement is not executed when the reactive result is returned. Instead, the publishers in the result will actually start the execution of the statement.

Parameters:

statement - a Neo4j statement

Returns:

a reactive result.