@API(status=STABLE, since="6.0") public final class ReactiveNeo4jTemplate extends Object implements ReactiveNeo4jOperations, BeanFactoryAware
ReactiveNeo4jOperations.ExecutableQuery<T>
Constructor and Description |
---|
ReactiveNeo4jTemplate(ReactiveNeo4jClient neo4jClient,
Neo4jMappingContext neo4jMappingContext,
ReactiveDatabaseSelectionProvider databaseSelectionProvider) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count(Class<?> domainType)
Counts the number of entities of a given type.
|
reactor.core.publisher.Mono<Long> |
count(org.neo4j.cypherdsl.core.Statement statement)
Counts the number of entities of a given type.
|
reactor.core.publisher.Mono<Long> |
count(org.neo4j.cypherdsl.core.Statement statement,
Map<String,Object> parameters)
Counts the number of entities of a given type.
|
reactor.core.publisher.Mono<Long> |
count(String cypherQuery)
Counts the number of entities of a given type.
|
reactor.core.publisher.Mono<Long> |
count(String cypherQuery,
Map<String,Object> parameters)
Counts the number of entities of a given type.
|
reactor.core.publisher.Mono<Void> |
deleteAll(Class<?> domainType)
Delete all entities of a given type.
|
<T> reactor.core.publisher.Mono<Void> |
deleteAllById(Iterable<?> ids,
Class<T> domainType)
Deletes all entities with one of the given ids, including all entities related to that entity.
|
<T> reactor.core.publisher.Mono<Void> |
deleteById(Object id,
Class<T> domainType)
Deletes a single entity including all entities related to that entity.
|
<T> reactor.core.publisher.Flux<T> |
findAll(Class<T> domainType)
Load all entities of a given type.
|
<T> reactor.core.publisher.Flux<T> |
findAll(org.neo4j.cypherdsl.core.Statement statement,
Class<T> domainType)
Load all entities of a given type by executing given statement.
|
<T> reactor.core.publisher.Flux<T> |
findAll(org.neo4j.cypherdsl.core.Statement statement,
Map<String,Object> parameters,
Class<T> domainType)
Load all entities of a given type by executing given statement with parameters.
|
<T> reactor.core.publisher.Flux<T> |
findAll(String cypherQuery,
Class<T> domainType)
Load all entities of a given type by executing given statement.
|
<T> reactor.core.publisher.Flux<T> |
findAll(String cypherQuery,
Map<String,Object> parameters,
Class<T> domainType)
Load all entities of a given type by executing given statement with parameters.
|
<T> reactor.core.publisher.Flux<T> |
findAllById(Iterable<?> ids,
Class<T> domainType)
Load all entities of a given type that are identified by the given ids.
|
<T> reactor.core.publisher.Mono<T> |
findById(Object id,
Class<T> domainType)
Load an entity from the database.
|
<T> reactor.core.publisher.Mono<T> |
findOne(org.neo4j.cypherdsl.core.Statement statement,
Map<String,Object> parameters,
Class<T> domainType)
Load one entity of a given type by executing given statement with parameters.
|
<T> reactor.core.publisher.Mono<T> |
findOne(String cypherQuery,
Map<String,Object> parameters,
Class<T> domainType)
Load one entity of a given type by executing given statement with parameters.
|
<T> reactor.core.publisher.Mono<T> |
save(T instance)
Saves an instance of an entity, including all the related entities of the entity.
|
<T> reactor.core.publisher.Flux<T> |
saveAll(Iterable<T> instances)
Saves several instances of an entity, including all the related entities of the entity.
|
void |
setBeanFactory(BeanFactory beanFactory) |
<T> reactor.core.publisher.Mono<ReactiveNeo4jOperations.ExecutableQuery<T>> |
toExecutableQuery(PreparedQuery<T> preparedQuery)
Takes a prepared query, containing all the information about the cypher template to be used, needed parameters and
an optional mapping function, and turns it into an executable query.
|
public ReactiveNeo4jTemplate(ReactiveNeo4jClient neo4jClient, Neo4jMappingContext neo4jMappingContext, ReactiveDatabaseSelectionProvider databaseSelectionProvider)
public reactor.core.publisher.Mono<Long> count(Class<?> domainType)
ReactiveNeo4jOperations
count
in interface ReactiveNeo4jOperations
domainType
- the type of the entities to be counted.null
.public reactor.core.publisher.Mono<Long> count(org.neo4j.cypherdsl.core.Statement statement)
ReactiveNeo4jOperations
count
in interface ReactiveNeo4jOperations
statement
- the Cypher Statement
that returns the count.null
.public reactor.core.publisher.Mono<Long> count(org.neo4j.cypherdsl.core.Statement statement, Map<String,Object> parameters)
ReactiveNeo4jOperations
count
in interface ReactiveNeo4jOperations
statement
- the Cypher Statement
that returns the count.parameters
- Map of parameters. Must not be null
.null
.public reactor.core.publisher.Mono<Long> count(String cypherQuery)
ReactiveNeo4jOperations
count
in interface ReactiveNeo4jOperations
cypherQuery
- the Cypher query that returns the count.null
.public reactor.core.publisher.Mono<Long> count(String cypherQuery, Map<String,Object> parameters)
ReactiveNeo4jOperations
count
in interface ReactiveNeo4jOperations
cypherQuery
- the Cypher query that returns the count.parameters
- Map of parameters. Must not be null
.null
.public <T> reactor.core.publisher.Flux<T> findAll(Class<T> domainType)
ReactiveNeo4jOperations
findAll
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Flux<T> findAll(org.neo4j.cypherdsl.core.Statement statement, Class<T> domainType)
ReactiveNeo4jOperations
findAll
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.statement
- Cypher Statement
. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Flux<T> findAll(org.neo4j.cypherdsl.core.Statement statement, Map<String,Object> parameters, Class<T> domainType)
ReactiveNeo4jOperations
findAll
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.statement
- Cypher Statement
. Must not be null
.parameters
- Map of parameters. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Mono<T> findOne(org.neo4j.cypherdsl.core.Statement statement, Map<String,Object> parameters, Class<T> domainType)
ReactiveNeo4jOperations
findOne
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.statement
- Cypher Statement
. Must not be null
.parameters
- Map of parameters. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Flux<T> findAll(String cypherQuery, Class<T> domainType)
ReactiveNeo4jOperations
findAll
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.cypherQuery
- Cypher query string. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Flux<T> findAll(String cypherQuery, Map<String,Object> parameters, Class<T> domainType)
ReactiveNeo4jOperations
findAll
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.cypherQuery
- Cypher query string. Must not be null
.parameters
- Map of parameters. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Mono<T> findOne(String cypherQuery, Map<String,Object> parameters, Class<T> domainType)
ReactiveNeo4jOperations
findOne
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.cypherQuery
- Cypher query string. Must not be null
.parameters
- Map of parameters. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Mono<T> findById(Object id, Class<T> domainType)
ReactiveNeo4jOperations
findById
in interface ReactiveNeo4jOperations
T
- the type of the entity.id
- the id of the entity to load. Must not be null
.domainType
- the type of the entity. Must not be null
.public <T> reactor.core.publisher.Flux<T> findAllById(Iterable<?> ids, Class<T> domainType)
ReactiveNeo4jOperations
findAllById
in interface ReactiveNeo4jOperations
T
- the type of the entities. Must not be null
.ids
- of the entities identifying the entities to load. Must not be null
.domainType
- the type of the entities. Must not be null
.null
.public <T> reactor.core.publisher.Mono<T> save(T instance)
ReactiveNeo4jOperations
save
in interface ReactiveNeo4jOperations
T
- the type of the entity.instance
- the entity to be saved. Must not be null
.public <T> reactor.core.publisher.Flux<T> saveAll(Iterable<T> instances)
ReactiveNeo4jOperations
saveAll
in interface ReactiveNeo4jOperations
T
- the type of the entity.instances
- the instances to be saved. Must not be null
.public <T> reactor.core.publisher.Mono<Void> deleteAllById(Iterable<?> ids, Class<T> domainType)
ReactiveNeo4jOperations
deleteAllById
in interface ReactiveNeo4jOperations
T
- the type of the entity.ids
- the ids of the entities to be deleted. Must not be null
.domainType
- the type of the entitypublic <T> reactor.core.publisher.Mono<Void> deleteById(Object id, Class<T> domainType)
ReactiveNeo4jOperations
deleteById
in interface ReactiveNeo4jOperations
T
- the type of the entity.id
- the id of the entity to be deleted. Must not be null
.domainType
- the type of the entitypublic reactor.core.publisher.Mono<Void> deleteAll(Class<?> domainType)
ReactiveNeo4jOperations
deleteAll
in interface ReactiveNeo4jOperations
domainType
- type of the entities to be deleted. Must not be null
.public <T> reactor.core.publisher.Mono<ReactiveNeo4jOperations.ExecutableQuery<T>> toExecutableQuery(PreparedQuery<T> preparedQuery)
ReactiveNeo4jOperations
toExecutableQuery
in interface ReactiveNeo4jOperations
T
- The type of the objects returned by this query.preparedQuery
- prepared query that should get converted to an executable querypublic void setBeanFactory(BeanFactory beanFactory) throws BeansException
setBeanFactory
in interface BeanFactoryAware
BeansException
Copyright © 2019–2020 Neo4j, Neo4j Sweden AB. All rights reserved.