SimpleReactiveNosqlRepository (Oracle NoSQL Database SDK for Spring Data 1.2.0 API)

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

Constructors
Constructor and Description
`SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata, org.springframework.context.ApplicationContext applicationContext)`
`SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata, ReactiveNosqlOperations reactiveNosqlOperations)`

Method Summary

All Methods Instance Methods Concrete Methods
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>`	`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.
`int`	`getTimeout()` 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>`	`saveAll(Iterable<S> entities)`
`<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`	`setTimeout(int milliseconds)` Sets the request timeout value, in milliseconds.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - SimpleReactiveNosqlRepository
```
public SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata,
                                     org.springframework.context.ApplicationContext applicationContext)
```
  - SimpleReactiveNosqlRepository
```
public SimpleReactiveNosqlRepository(NosqlEntityInformation<T,ID> metadata,
                                     ReactiveNosqlOperations reactiveNosqlOperations)
```
- Method Detail
  - save
```
public <S extends T> reactor.core.publisher.Mono<S> save(S entity)
```
    Specified by:
    
    save in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - saveAll
```
public <S extends T> reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities)
```
    Specified by:
    
    saveAll in interface org.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 interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - findById
```
public reactor.core.publisher.Mono<T> findById(ID id)
```
    Specified by:
    
    findById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - findById
```
public reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<ID> idPublisher)
```
    Specified by:
    
    findById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - existsById
```
public reactor.core.publisher.Mono<Boolean> existsById(ID id)
```
    Specified by:
    
    existsById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - existsById
```
public reactor.core.publisher.Mono<Boolean> existsById(org.reactivestreams.Publisher<ID> publisher)
```
    Specified by:
    
    existsById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - findAll
```
public reactor.core.publisher.Flux<T> findAll()
```
    Specified by:
    
    findAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - findAllById
```
public reactor.core.publisher.Flux<T> findAllById(Iterable<ID> ids)
```
    Specified by:
    
    findAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - findAllById
```
public reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> idStream)
```
    Specified by:
    
    findAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - count
```
public reactor.core.publisher.Mono<Long> count()
```
    Specified by:
    
    count in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - deleteById
```
public reactor.core.publisher.Mono<Void> deleteById(ID id)
```
    Specified by:
    
    deleteById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - deleteById
```
public reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher<ID> idPublisher)
```
    Specified by:
    
    deleteById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - delete
```
public reactor.core.publisher.Mono<Void> delete(T entity)
```
    Specified by:
    
    delete in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - deleteAll
```
public reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities)
```
    Specified by:
    
    deleteAll in interface org.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 interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - deleteAll
```
public reactor.core.publisher.Mono<Void> deleteAll()
```
    Specified by:
    
    deleteAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID extends Serializable>
  - findAll
```
public reactor.core.publisher.Flux<T> findAll(org.springframework.data.domain.Sort sort)
```
    Specified by:
    
    findAll in interface org.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 interface ReactiveNosqlRepository<T,ID extends Serializable>
    
    See Also:
    
    ReactiveNosqlRepository.getTimeout()
  - 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 using NosqlTable.timeout().
    
    Specified by:
    
    setTimeout in interface ReactiveNosqlRepository<T,ID extends Serializable>
    
    See Also:
    
    ReactiveNosqlRepository.setTimeout(int)
  - getConsistency
```
public String getConsistency()
```
    Description copied from interface: ReactiveNosqlRepository
    
    Returns the configured read request consistency value.
    
    Specified by:
    
    getConsistency in interface ReactiveNosqlRepository<T,ID extends Serializable>
    
    See Also:
    
    ReactiveNosqlRepository.getConsistency()
  - setConsistency
```
public void setConsistency(String consistency)
```
    Description copied from interface: ReactiveNosqlRepository
    
    Sets the read request consistency value. The value must be one of Consistency values. This set takes precedence over the one set when using NosqlTable.consistency().
    
    Specified by:
    
    setConsistency in interface ReactiveNosqlRepository<T,ID extends Serializable>
    
    See Also:
    
    ReactiveNosqlRepository.setConsistency(String)

Class SimpleReactiveNosqlRepository<T,ID extends Serializable>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

SimpleReactiveNosqlRepository

SimpleReactiveNosqlRepository

Method Detail

save

saveAll

saveAll

findById

findById

existsById

existsById

findAll

findAllById

findAllById

count

deleteById

deleteById

delete

deleteAll

deleteAll

deleteAll

findAll

getTimeout

setTimeout

getConsistency

setConsistency