public interface ReactiveNosqlOperations
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count(NosqlEntityInformation<?,?> entityInformation) |
reactor.core.publisher.Mono<Long> |
count(NosqlQuery query,
NosqlEntityInformation<?,?> entityInformation) |
reactor.core.publisher.Mono<Boolean> |
createTableIfNotExists(NosqlEntityInformation<?,?> information)
Creates table for entity information.
|
<T,ID> reactor.core.publisher.Flux<T> |
delete(NosqlQuery query,
NosqlEntityInformation<T,ID> entityInformation) |
reactor.core.publisher.Mono<Void> |
deleteAll(NosqlEntityInformation<?,?> entityInformation) |
<ID> reactor.core.publisher.Mono<Void> |
deleteById(NosqlEntityInformation<?,ID> entityInformation,
ID id) |
reactor.core.publisher.Mono<Boolean> |
dropTableIfExists(String tableName)
Drops table and returns true if result indicates table state changed to
DROPPED or DROPPING.
|
reactor.core.publisher.Mono<Boolean> |
exists(NosqlQuery query,
NosqlEntityInformation<?,?> entityInformation) |
<ID> reactor.core.publisher.Mono<Boolean> |
existsById(NosqlEntityInformation<?,ID> entityInformation,
ID id) |
<T> reactor.core.publisher.Flux<T> |
find(NosqlQuery query,
NosqlEntityInformation<T,?> entityInformation) |
<T> reactor.core.publisher.Flux<T> |
findAll(Class<T> entityClass) |
<T,ID> reactor.core.publisher.Flux<T> |
findAll(NosqlEntityInformation<T,ID> entityInformation) |
<T,ID> reactor.core.publisher.Flux<T> |
findAllById(NosqlEntityInformation<T,ID> entityInformation,
org.reactivestreams.Publisher<ID> idStream) |
<T,ID> reactor.core.publisher.Mono<T> |
findById(NosqlEntityInformation<T,ID> entityInformation,
ID id) |
<T> reactor.core.publisher.Mono<T> |
findById(Object id,
Class<T> entityClass) |
MappingNosqlConverter |
getConverter() |
String |
getTableName(Class<?> domainClass)
Returns the table name associated to the domainClass
|
<S,ID> reactor.core.publisher.Mono<S> |
insert(NosqlEntityInformation<?,ID> entityInformation,
S objectToSave) |
<T> reactor.core.publisher.Mono<T> |
insert(T objectToSave) |
<S,ID> reactor.core.publisher.Mono<S> |
update(NosqlEntityInformation<?,ID> entityInformation,
S object) |
<T> reactor.core.publisher.Mono<T> |
update(T object) |
String getTableName(Class<?> domainClass)
domainClass
- the domain classreactor.core.publisher.Mono<Boolean> createTableIfNotExists(NosqlEntityInformation<?,?> information)
NosqlDbFactory.getTableReqTimeout()
and
NosqlDbFactory.getTableReqPollInterval()
to check the result.
Throws @RuntimeException
if result indicates table state
different than ACTIVE.reactor.core.publisher.Mono<Boolean> dropTableIfExists(String tableName)
NosqlDbFactory.getTableReqTimeout()
and
NosqlDbFactory.getTableReqPollInterval()
to check the result.<T,ID> reactor.core.publisher.Flux<T> findAll(NosqlEntityInformation<T,ID> entityInformation)
<T> reactor.core.publisher.Flux<T> findAll(Class<T> entityClass)
<T,ID> reactor.core.publisher.Mono<T> findById(NosqlEntityInformation<T,ID> entityInformation, ID id)
<T,ID> reactor.core.publisher.Flux<T> findAllById(NosqlEntityInformation<T,ID> entityInformation, org.reactivestreams.Publisher<ID> idStream)
<T> reactor.core.publisher.Mono<T> insert(T objectToSave)
<S,ID> reactor.core.publisher.Mono<S> insert(NosqlEntityInformation<?,ID> entityInformation, S objectToSave)
<T> reactor.core.publisher.Mono<T> update(T object)
<S,ID> reactor.core.publisher.Mono<S> update(NosqlEntityInformation<?,ID> entityInformation, S object)
<ID> reactor.core.publisher.Mono<Void> deleteById(NosqlEntityInformation<?,ID> entityInformation, ID id)
reactor.core.publisher.Mono<Void> deleteAll(NosqlEntityInformation<?,?> entityInformation)
<T,ID> reactor.core.publisher.Flux<T> delete(NosqlQuery query, NosqlEntityInformation<T,ID> entityInformation)
<T> reactor.core.publisher.Flux<T> find(NosqlQuery query, NosqlEntityInformation<T,?> entityInformation)
reactor.core.publisher.Mono<Boolean> exists(NosqlQuery query, NosqlEntityInformation<?,?> entityInformation)
<ID> reactor.core.publisher.Mono<Boolean> existsById(NosqlEntityInformation<?,ID> entityInformation, ID id)
reactor.core.publisher.Mono<Long> count(NosqlEntityInformation<?,?> entityInformation)
reactor.core.publisher.Mono<Long> count(NosqlQuery query, NosqlEntityInformation<?,?> entityInformation)
MappingNosqlConverter getConverter()
Copyright © 2022 Oracle Corporation. All rights reserved.