Class SimpleReactiveNosqlRepository<T,ID extends Serializable>
java.lang.Object
com.oracle.nosql.spring.data.repository.support.SimpleReactiveNosqlRepository<T,ID>
- All Implemented Interfaces:
ReactiveNosqlRepository<T,,ID> org.springframework.data.repository.reactive.ReactiveCrudRepository<T,,ID> org.springframework.data.repository.reactive.ReactiveSortingRepository<T,,ID> org.springframework.data.repository.Repository<T,ID>
public class SimpleReactiveNosqlRepository<T,ID extends Serializable>
extends Object
implements ReactiveNosqlRepository<T,ID>
-
Constructor Summary
ConstructorsConstructorDescriptionSimpleReactiveNosqlRepository(NosqlEntityInformation<T, ID> metadata, ReactiveNosqlOperations reactiveNosqlOperations) SimpleReactiveNosqlRepository(NosqlEntityInformation<T, ID> metadata, org.springframework.context.ApplicationContext applicationContext) -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Long>count()reactor.core.publisher.Mono<Void>reactor.core.publisher.Mono<Void>reactor.core.publisher.Mono<Void>reactor.core.publisher.Mono<Void>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>reactor.core.publisher.Mono<T>Returns the configured read request consistency value.Returns the configured request durability value.intReturns the configured request timeout value, in milliseconds, or 0 if it has not been set.<S extends T>
reactor.core.publisher.Mono<S>save(S entity) <S extends T>
reactor.core.publisher.Flux<S><S extends T>
reactor.core.publisher.Flux<S>saveAll(org.reactivestreams.Publisher<S> entityStream) voidsetConsistency(String consistency) Sets the read request consistency value.voidsetDurability(String durability) Sets the request durability value.voidsetTimeout(int milliseconds) Sets the request timeout value, in milliseconds.
-
Constructor Details
-
SimpleReactiveNosqlRepository
public SimpleReactiveNosqlRepository(NosqlEntityInformation<T, ID> metadata, org.springframework.context.ApplicationContext applicationContext) -
SimpleReactiveNosqlRepository
public SimpleReactiveNosqlRepository(NosqlEntityInformation<T, ID> metadata, ReactiveNosqlOperations reactiveNosqlOperations)
-
-
Method Details
-
save
- Specified by:
savein interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
saveAll
- Specified by:
saveAllin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
saveAll
public <S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream) - Specified by:
saveAllin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
findById
- Specified by:
findByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
findById
- Specified by:
findByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
existsById
- Specified by:
existsByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
existsById
- Specified by:
existsByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
findAll
- Specified by:
findAllin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
findAllById
- Specified by:
findAllByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
findAllById
- Specified by:
findAllByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
count
- Specified by:
countin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
deleteById
- Specified by:
deleteByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
deleteById
- Specified by:
deleteByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
delete
- Specified by:
deletein interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
deleteAllById
- Specified by:
deleteAllByIdin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
deleteAll
- Specified by:
deleteAllin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
deleteAll
public reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream) - Specified by:
deleteAllin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
deleteAll
- Specified by:
deleteAllin interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
-
findAll
- Specified by:
findAllin interfaceorg.springframework.data.repository.reactive.ReactiveSortingRepository<T,ID extends Serializable>
-
getTimeout
public int getTimeout()Description copied from interface:ReactiveNosqlRepositoryReturns the configured request timeout value, in milliseconds, or 0 if it has not been set.- Specified by:
getTimeoutin interfaceReactiveNosqlRepository<T,ID extends Serializable> - See Also:
-
setTimeout
public void setTimeout(int milliseconds) Description copied from interface:ReactiveNosqlRepositorySets the request timeout value, in milliseconds. This overrides any default value set in NoSQLHandleConfig. The value must be positive. This set takes precedence over the one set when usingNosqlTable.timeout().- Specified by:
setTimeoutin interfaceReactiveNosqlRepository<T,ID extends Serializable> - See Also:
-
getConsistency
Description copied from interface:ReactiveNosqlRepositoryReturns the configured read request consistency value.- Specified by:
getConsistencyin interfaceReactiveNosqlRepository<T,ID extends Serializable> - See Also:
-
setConsistency
Description copied from interface:ReactiveNosqlRepositorySets the read request consistency value. The value must be one ofConsistencyvalues. This set takes precedence over the one set when usingNosqlTable.consistency().- Specified by:
setConsistencyin interfaceReactiveNosqlRepository<T,ID extends Serializable> - See Also:
-
getDurability
Description copied from interface:ReactiveNosqlRepositoryReturns the configured request durability value.- Specified by:
getDurabilityin interfaceReactiveNosqlRepository<T,ID extends Serializable> - See Also:
-
setDurability
Description copied from interface:ReactiveNosqlRepositorySets the request durability value. The value must be one of the defined Durability values:Durability.COMMIT_NO_SYNC,Durability.COMMIT_WRITE_NO_SYNCorDurability.COMMIT_SYNC.This set takes precedence over the one set when using
NosqlTable.durability().Note: This applies to On-Prem installations only.
- Specified by:
setDurabilityin interfaceReactiveNosqlRepository<T,ID extends Serializable> - See Also:
-