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.int
Returns 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) 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.
-
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:
save
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
saveAll
- Specified by:
saveAll
in 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:
saveAll
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
findById
- Specified by:
findById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
findById
- Specified by:
findById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
existsById
- Specified by:
existsById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
existsById
- Specified by:
existsById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
findAll
- Specified by:
findAll
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
findAllById
- Specified by:
findAllById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
findAllById
- Specified by:
findAllById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
count
- Specified by:
count
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
deleteById
- Specified by:
deleteById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
deleteById
- Specified by:
deleteById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
delete
- Specified by:
delete
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
deleteAllById
- Specified by:
deleteAllById
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
deleteAll
- Specified by:
deleteAll
in 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:
deleteAll
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
deleteAll
- Specified by:
deleteAll
in interfaceorg.springframework.data.repository.reactive.ReactiveCrudRepository<T,
ID extends Serializable>
-
findAll
- Specified by:
findAll
in interfaceorg.springframework.data.repository.reactive.ReactiveSortingRepository<T,
ID extends Serializable>
-
getTimeout
public int getTimeout()Description copied from interface:ReactiveNosqlRepository
Returns the configured request timeout value, in milliseconds, or 0 if it has not been set.- Specified by:
getTimeout
in interfaceReactiveNosqlRepository<T,
ID extends Serializable> - See Also:
-
setTimeout
public void setTimeout(int milliseconds) Description copied from interface:ReactiveNosqlRepository
Sets 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:
setTimeout
in interfaceReactiveNosqlRepository<T,
ID extends Serializable> - See Also:
-
getConsistency
Description copied from interface:ReactiveNosqlRepository
Returns the configured read request consistency value.- Specified by:
getConsistency
in interfaceReactiveNosqlRepository<T,
ID extends Serializable> - See Also:
-
setConsistency
Description copied from interface:ReactiveNosqlRepository
Sets the read request consistency value. The value must be one ofConsistency
values. This set takes precedence over the one set when usingNosqlTable.consistency()
.- Specified by:
setConsistency
in interfaceReactiveNosqlRepository<T,
ID extends Serializable> - See Also:
-
getDurability
Description copied from interface:ReactiveNosqlRepository
Returns the configured request durability value.- Specified by:
getDurability
in interfaceReactiveNosqlRepository<T,
ID extends Serializable> - See Also:
-
setDurability
Description copied from interface:ReactiveNosqlRepository
Sets the request durability value. The value must be one of the defined Durability values:Durability.COMMIT_NO_SYNC
,Durability.COMMIT_WRITE_NO_SYNC
orDurability.COMMIT_SYNC
.This set takes precedence over the one set when using
NosqlTable.durability()
.Note: This applies to On-Prem installations only.
- Specified by:
setDurability
in interfaceReactiveNosqlRepository<T,
ID extends Serializable> - See Also:
-