public class ReactiveNosqlTemplate extends NosqlTemplateBase implements ReactiveNosqlOperations, org.springframework.context.ApplicationContextAware
JSON_COLUMN, LOG, mappingNosqlConverter, nosqlClient, nosqlDbFactory, psCache
Constructor and Description |
---|
ReactiveNosqlTemplate(NosqlDbFactory nosqlDbFactory,
MappingNosqlConverter mappingNosqlConverter) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count(NosqlEntityInformation<?,?> entityInformation) |
reactor.core.publisher.Mono<Long> |
count(NosqlQuery query,
NosqlEntityInformation<?,?> entityInformation) |
static ReactiveNosqlTemplate |
create(NosqlDbConfig nosqlDBConfig) |
static ReactiveNosqlTemplate |
create(NosqlDbFactory nosqlDbFactory) |
reactor.core.publisher.Mono<Boolean> |
createTableIfNotExists(NosqlEntityInformation<?,?> information)
Creates a table for the given entity type if it doesn't exist.
|
<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.
|
<T> reactor.core.publisher.Flux<oracle.nosql.driver.values.MapValue> |
executeMapValueQuery(NosqlQuery query,
NosqlEntityInformation<T,?> entityInformation) |
<T> reactor.core.publisher.Flux<T> |
executeQuery(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) |
<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) |
Iterable<oracle.nosql.driver.values.MapValue> |
runQueryNosqlParams(NosqlEntityInformation<?,?> entityInformation,
String query,
Map<String,oracle.nosql.driver.values.FieldValue> nosqlParams)
nosqlParams is a Map of param_name to FieldValue
|
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext) |
<S,ID> reactor.core.publisher.Mono<S> |
update(NosqlEntityInformation<?,ID> entityInformation,
S object) |
<T> reactor.core.publisher.Mono<T> |
update(T object) |
doCreateTableIfNotExists, doDelete, doExecuteMapValueQuery, doGet, doPut, doRunQueryNosqlParams, doTableRequest, doUpdate
public ReactiveNosqlTemplate(NosqlDbFactory nosqlDbFactory, MappingNosqlConverter mappingNosqlConverter)
public static ReactiveNosqlTemplate create(NosqlDbConfig nosqlDBConfig) throws ClassNotFoundException
ClassNotFoundException
public static ReactiveNosqlTemplate create(NosqlDbFactory nosqlDbFactory) throws ClassNotFoundException
ClassNotFoundException
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
setApplicationContext
in interface org.springframework.context.ApplicationContextAware
org.springframework.beans.BeansException
public String getTableName(Class<?> domainClass)
ReactiveNosqlOperations
getTableName
in interface ReactiveNosqlOperations
domainClass
- the domain classpublic reactor.core.publisher.Mono<Boolean> createTableIfNotExists(NosqlEntityInformation<?,?> information)
createTableIfNotExists
in interface ReactiveNosqlOperations
public reactor.core.publisher.Mono<Boolean> dropTableIfExists(String tableName)
NosqlDbFactory.getTableReqTimeout()
and
NosqlDbFactory.getTableReqPollInterval()
to check the result.dropTableIfExists
in interface ReactiveNosqlOperations
public <T,ID> reactor.core.publisher.Flux<T> findAll(NosqlEntityInformation<T,ID> entityInformation)
findAll
in interface ReactiveNosqlOperations
public <T> reactor.core.publisher.Flux<T> findAll(Class<T> entityClass)
findAll
in interface ReactiveNosqlOperations
public <T> reactor.core.publisher.Mono<T> findById(Object id, Class<T> entityClass)
findById
in interface ReactiveNosqlOperations
public <T,ID> reactor.core.publisher.Mono<T> findById(NosqlEntityInformation<T,ID> entityInformation, ID id)
findById
in interface ReactiveNosqlOperations
public <T> reactor.core.publisher.Mono<T> insert(T objectToSave)
insert
in interface ReactiveNosqlOperations
public <S,ID> reactor.core.publisher.Mono<S> insert(NosqlEntityInformation<?,ID> entityInformation, S objectToSave)
insert
in interface ReactiveNosqlOperations
public <T> reactor.core.publisher.Mono<T> update(T object)
update
in interface ReactiveNosqlOperations
public <S,ID> reactor.core.publisher.Mono<S> update(NosqlEntityInformation<?,ID> entityInformation, S object)
update
in interface ReactiveNosqlOperations
public <ID> reactor.core.publisher.Mono<Void> deleteById(NosqlEntityInformation<?,ID> entityInformation, ID id)
deleteById
in interface ReactiveNosqlOperations
public reactor.core.publisher.Mono<Void> deleteAll(NosqlEntityInformation<?,?> entityInformation)
deleteAll
in interface ReactiveNosqlOperations
public <T,ID> reactor.core.publisher.Flux<T> delete(NosqlQuery query, NosqlEntityInformation<T,ID> entityInformation)
delete
in interface ReactiveNosqlOperations
public <T> reactor.core.publisher.Flux<T> find(NosqlQuery query, NosqlEntityInformation<T,?> entityInformation)
find
in interface ReactiveNosqlOperations
public reactor.core.publisher.Mono<Boolean> exists(NosqlQuery query, NosqlEntityInformation<?,?> entityInformation)
exists
in interface ReactiveNosqlOperations
public <ID> reactor.core.publisher.Mono<Boolean> existsById(NosqlEntityInformation<?,ID> entityInformation, ID id)
existsById
in interface ReactiveNosqlOperations
public reactor.core.publisher.Mono<Long> count(NosqlEntityInformation<?,?> entityInformation)
count
in interface ReactiveNosqlOperations
public reactor.core.publisher.Mono<Long> count(NosqlQuery query, NosqlEntityInformation<?,?> entityInformation)
count
in interface ReactiveNosqlOperations
public MappingNosqlConverter getConverter()
getConverter
in interface ReactiveNosqlOperations
public <T,ID> reactor.core.publisher.Flux<T> findAllById(NosqlEntityInformation<T,ID> entityInformation, org.reactivestreams.Publisher<ID> idStream)
findAllById
in interface ReactiveNosqlOperations
public Iterable<oracle.nosql.driver.values.MapValue> runQueryNosqlParams(NosqlEntityInformation<?,?> entityInformation, String query, Map<String,oracle.nosql.driver.values.FieldValue> nosqlParams)
public <T> reactor.core.publisher.Flux<T> executeQuery(NosqlQuery query, NosqlEntityInformation<T,?> entityInformation)
public <T> reactor.core.publisher.Flux<oracle.nosql.driver.values.MapValue> executeMapValueQuery(NosqlQuery query, NosqlEntityInformation<T,?> entityInformation)
Copyright © 2022 Oracle Corporation. All rights reserved.