Package com.oracle.nosql.spring.data.core

Interface ReactiveNosqlOperations

All Known Implementing Classes:

ReactiveNosqlTemplate

public interface ReactiveNosqlOperations

Method Summary

Modifier and Type	Method	Description
reactor.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>	findAll(Class<T> entityClass)
<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
<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

String getTableName(Class<?> domainClass)

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. Uses NosqlDbFactory.getTableReqTimeout() and NosqlDbFactory.getTableReqPollInterval() to check the result. Throws @RuntimeException if result indicates table state different than ACTIVE.

dropTableIfExists

reactor.core.publisher.Mono<Boolean> dropTableIfExists(String tableName)

Drops table and returns true if result indicates table state changed to DROPPED or DROPPING. Uses NosqlDbFactory.getTableReqTimeout() and NosqlDbFactory.getTableReqPollInterval() to check the result.

findAll

<T,
ID> reactor.core.publisher.Flux<T> findAll(NosqlEntityInformation<T,ID> entityInformation)

findAll

<T> reactor.core.publisher.Flux<T> findAll(Class<T> entityClass)

findById

<T> reactor.core.publisher.Mono<T> findById(Object id,
 Class<T> entityClass)

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

reactor.core.publisher.Mono<Void> deleteAll(NosqlEntityInformation<?,?> entityInformation)

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

reactor.core.publisher.Mono<Long> count(NosqlEntityInformation<?,?> entityInformation)

count

reactor.core.publisher.Mono<Long> count(NosqlQuery query,
 NosqlEntityInformation<?,?> entityInformation)

getConverter

MappingNosqlConverter getConverter()