public class SimpleReactiveNosqlRepository<T,ID extends Serializable> extends Object implements ReactiveNosqlRepository<T,ID>
Constructor and Description |
---|
SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata,
org.springframework.context.ApplicationContext applicationContext) |
SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata,
ReactiveNosqlOperations reactiveNosqlOperations) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count() |
reactor.core.publisher.Mono<Void> |
delete(T entity) |
reactor.core.publisher.Mono<Void> |
deleteAll() |
reactor.core.publisher.Mono<Void> |
deleteAll(Iterable<? extends T> entities) |
reactor.core.publisher.Mono<Void> |
deleteAll(org.reactivestreams.Publisher<? extends T> entityStream) |
reactor.core.publisher.Mono<Void> |
deleteAllById(Iterable<? extends ID> ids) |
reactor.core.publisher.Mono<Void> |
deleteById(ID id) |
reactor.core.publisher.Mono<Void> |
deleteById(org.reactivestreams.Publisher<ID> idPublisher) |
reactor.core.publisher.Mono<Boolean> |
existsById(ID id) |
reactor.core.publisher.Mono<Boolean> |
existsById(org.reactivestreams.Publisher<ID> publisher) |
reactor.core.publisher.Flux<T> |
findAll() |
reactor.core.publisher.Flux<T> |
findAll(org.springframework.data.domain.Sort sort) |
reactor.core.publisher.Flux<T> |
findAllById(Iterable<ID> ids) |
reactor.core.publisher.Flux<T> |
findAllById(org.reactivestreams.Publisher<ID> idStream) |
reactor.core.publisher.Mono<T> |
findById(ID id) |
reactor.core.publisher.Mono<T> |
findById(org.reactivestreams.Publisher<ID> idPublisher) |
String |
getConsistency()
Returns the configured read request consistency value.
|
String |
getDurability()
Returns the configured request durability value.
|
int |
getTimeout()
Returns the configured request timeout value, in milliseconds, or 0 if
it has not been set.
|
<S extends T> |
save(S entity) |
<S extends T> |
saveAll(Iterable<S> entities) |
<S extends T> |
saveAll(org.reactivestreams.Publisher<S> entityStream) |
void |
setConsistency(String consistency)
Sets the read request consistency value.
|
void |
setDurability(String durability)
Sets the request durability value.
|
void |
setTimeout(int milliseconds)
Sets the request timeout value, in milliseconds.
|
public SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata, org.springframework.context.ApplicationContext applicationContext)
public SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata, ReactiveNosqlOperations reactiveNosqlOperations)
public <S extends T> reactor.core.publisher.Mono<S> save(S entity)
save
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities)
saveAll
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)
saveAll
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<T> findById(ID id)
findById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<ID> idPublisher)
findById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Boolean> existsById(ID id)
existsById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Boolean> existsById(org.reactivestreams.Publisher<ID> publisher)
existsById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAll()
findAll
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAllById(Iterable<ID> ids)
findAllById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> idStream)
findAllById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Long> count()
count
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteById(ID id)
deleteById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher<ID> idPublisher)
deleteById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> delete(T entity)
delete
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAllById(Iterable<? extends ID> ids)
deleteAllById
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities)
deleteAll
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)
deleteAll
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAll()
deleteAll
in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAll(org.springframework.data.domain.Sort sort)
findAll
in interface org.springframework.data.repository.reactive.ReactiveSortingRepository<T,ID extends Serializable>
public int getTimeout()
ReactiveNosqlRepository
getTimeout
in interface ReactiveNosqlRepository<T,ID extends Serializable>
ReactiveNosqlRepository.getTimeout()
public void setTimeout(int milliseconds)
ReactiveNosqlRepository
NosqlTable.timeout()
.setTimeout
in interface ReactiveNosqlRepository<T,ID extends Serializable>
ReactiveNosqlRepository.setTimeout(int)
public String getConsistency()
ReactiveNosqlRepository
getConsistency
in interface ReactiveNosqlRepository<T,ID extends Serializable>
ReactiveNosqlRepository.getConsistency()
public void setConsistency(String consistency)
ReactiveNosqlRepository
Consistency
values.
This set takes precedence over the one set when using
NosqlTable.consistency()
.setConsistency
in interface ReactiveNosqlRepository<T,ID extends Serializable>
ReactiveNosqlRepository.setConsistency(String)
public String getDurability()
ReactiveNosqlRepository
getDurability
in interface ReactiveNosqlRepository<T,ID extends Serializable>
NosqlRepository.getDurability()
public void setDurability(String durability)
ReactiveNosqlRepository
Durability.COMMIT_NO_SYNC
,
Durability.COMMIT_WRITE_NO_SYNC
or
Durability.COMMIT_SYNC
.
This set takes precedence over the one set when using
NosqlTable.durability()
.
Note: This applies to On-Prem installations only.
setDurability
in interface ReactiveNosqlRepository<T,ID extends Serializable>
NosqlRepository.setDurability(String)
Copyright © 2022 Oracle Corporation. All rights reserved.