Interface ReactiveNosqlOperations
- All Known Implementing Classes:
ReactiveNosqlTemplate
public interface ReactiveNosqlOperations
-
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Long>count(NosqlQuery query, NosqlEntityInformation<?, ?> entityInformation) reactor.core.publisher.Mono<Long>count(NosqlEntityInformation<?, ?> entityInformation) reactor.core.publisher.Mono<Boolean>createTableIfNotExists(NosqlEntityInformation<?, ?> entityInformation) 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,ID> reactor.core.publisher.Flux<T> findAll(NosqlEntityInformation<T, ID> entityInformation) <T> reactor.core.publisher.Flux<T><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>getTableName(Class<?> domainClass) Returns the table name associated to the domainClass<T,ID> reactor.core.publisher.Mono<T> insert(NosqlEntityInformation<?, ID> entityInformation, T entity) <T> reactor.core.publisher.Mono<T>insert(T entity) <T,ID> reactor.core.publisher.Mono<T> update(NosqlEntityInformation<?, ID> entityInformation, T entity) <T> reactor.core.publisher.Mono<T>update(T entity)
-
Method Details
-
getTableName
Returns the table name associated to the domainClass- Parameters:
domainClass- the domain class- Returns:
- the table name
-
createTableIfNotExists
reactor.core.publisher.Mono<Boolean> createTableIfNotExists(NosqlEntityInformation<?, ?> entityInformation) Creates table for entity information. UsesNosqlDbFactory.getTableReqTimeout()andNosqlDbFactory.getTableReqPollInterval()to check the result. Throws @RuntimeExceptionif result indicates table state different than ACTIVE. -
dropTableIfExists
Drops table and returns true if result indicates table state changed to DROPPED or DROPPING. UsesNosqlDbFactory.getTableReqTimeout()andNosqlDbFactory.getTableReqPollInterval()to check the result. -
findAll
-
findAll
-
findById
-
findById
<T,ID> reactor.core.publisher.Mono<T> findById(NosqlEntityInformation<T, ID> entityInformation, ID id) -
findAllById
<T,ID> reactor.core.publisher.Flux<T> findAllById(NosqlEntityInformation<T, ID> entityInformation, org.reactivestreams.Publisher<ID> idStream) -
insert
<T> reactor.core.publisher.Mono<T> insert(T entity) -
insert
<T,ID> reactor.core.publisher.Mono<T> insert(NosqlEntityInformation<?, ID> entityInformation, T entity) -
update
<T> reactor.core.publisher.Mono<T> update(T entity) -
update
<T,ID> reactor.core.publisher.Mono<T> update(NosqlEntityInformation<?, ID> entityInformation, T entity) -
deleteById
<ID> reactor.core.publisher.Mono<Void> deleteById(NosqlEntityInformation<?, ID> entityInformation, ID id) -
deleteAll
-
delete
<T,ID> reactor.core.publisher.Flux<T> delete(NosqlQuery query, NosqlEntityInformation<T, ID> entityInformation) -
find
<T> reactor.core.publisher.Flux<T> find(NosqlQuery query, NosqlEntityInformation<T, ?> entityInformation) -
exists
reactor.core.publisher.Mono<Boolean> exists(NosqlQuery query, NosqlEntityInformation<?, ?> entityInformation) -
existsById
<ID> reactor.core.publisher.Mono<Boolean> existsById(NosqlEntityInformation<?, ID> entityInformation, ID id) -
count
-
count
reactor.core.publisher.Mono<Long> count(NosqlQuery query, NosqlEntityInformation<?, ?> entityInformation) -
getConverter
MappingNosqlConverter getConverter()
-