public class SimpleReactiveMongoRepository<T,ID extends Serializable> extends Object implements ReactiveMongoRepository<T,ID>
Constructor and Description |
---|
SimpleReactiveMongoRepository(@NonNull MongoEntityInformation<T,ID> entityInformation,
@NonNull ReactiveMongoOperations mongoOperations) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
count() |
<S extends T> |
count(Example<S> example) |
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> publisher) |
<S extends T> |
exists(Example<S> example) |
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() |
<S extends T> |
findAll(Example<S> example) |
<S extends T> |
findAll(Example<S> example,
Sort sort) |
reactor.core.publisher.Flux<T> |
findAll(Sort sort) |
reactor.core.publisher.Flux<T> |
findAllById(Iterable<ID> ids) |
reactor.core.publisher.Flux<T> |
findAllById(org.reactivestreams.Publisher<ID> ids) |
reactor.core.publisher.Mono<T> |
findById(ID id) |
reactor.core.publisher.Mono<T> |
findById(org.reactivestreams.Publisher<ID> publisher) |
<S extends T> |
findOne(Example<S> example) |
<S extends T> |
insert(Iterable<S> entities)
Inserts the given entities.
|
<S extends T> |
insert(org.reactivestreams.Publisher<S> entities)
Inserts the given entities.
|
<S extends T> |
insert(S entity)
Inserts the given entity.
|
<S extends T> |
save(S entity) |
<S extends T> |
saveAll(Iterable<S> entities) |
<S extends T> |
saveAll(org.reactivestreams.Publisher<S> entityStream) |
public SimpleReactiveMongoRepository(@NonNull @NonNull MongoEntityInformation<T,ID> entityInformation, @NonNull @NonNull ReactiveMongoOperations mongoOperations)
public reactor.core.publisher.Mono<T> findById(ID id)
findById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<ID> publisher)
findById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Mono<S> findOne(Example<S> example)
findOne
in interface ReactiveQueryByExampleExecutor<T>
public reactor.core.publisher.Mono<Boolean> existsById(ID id)
existsById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Boolean> existsById(org.reactivestreams.Publisher<ID> publisher)
existsById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Mono<Boolean> exists(Example<S> example)
exists
in interface ReactiveQueryByExampleExecutor<T>
public reactor.core.publisher.Flux<T> findAll()
findAll
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAllById(Iterable<ID> ids)
findAllById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> ids)
findAllById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Flux<T> findAll(Sort sort)
findAll
in interface ReactiveSortingRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Flux<S> findAll(Example<S> example, Sort sort)
findAll
in interface ReactiveMongoRepository<T,ID extends Serializable>
findAll
in interface ReactiveQueryByExampleExecutor<T>
public <S extends T> reactor.core.publisher.Flux<S> findAll(Example<S> example)
findAll
in interface ReactiveMongoRepository<T,ID extends Serializable>
findAll
in interface ReactiveQueryByExampleExecutor<T>
public reactor.core.publisher.Mono<Long> count()
count
in interface ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Mono<Long> count(Example<S> example)
count
in interface ReactiveQueryByExampleExecutor<T>
public <S extends T> reactor.core.publisher.Mono<S> insert(S entity)
ReactiveMongoRepository
ReactiveCrudRepository.save(Object)
instead to avoid the usage of store-specific API.insert
in interface ReactiveMongoRepository<T,ID extends Serializable>
entity
- must not be null.public <S extends T> reactor.core.publisher.Flux<S> insert(Iterable<S> entities)
ReactiveMongoRepository
ReactiveCrudRepository.save(Object)
instead to avoid the usage of store-specific API.insert
in interface ReactiveMongoRepository<T,ID extends Serializable>
entities
- must not be null.public <S extends T> reactor.core.publisher.Flux<S> insert(org.reactivestreams.Publisher<S> entities)
ReactiveMongoRepository
ReactiveCrudRepository.save(Object)
instead to avoid the usage of store-specific API.insert
in interface ReactiveMongoRepository<T,ID extends Serializable>
entities
- must not be null.public <S extends T> reactor.core.publisher.Mono<S> save(S entity)
save
in interface ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities)
saveAll
in interface ReactiveCrudRepository<T,ID extends Serializable>
public <S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)
saveAll
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteById(ID id)
deleteById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher<ID> publisher)
deleteById
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> delete(T entity)
delete
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities)
deleteAll
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)
deleteAll
in interface ReactiveCrudRepository<T,ID extends Serializable>
public reactor.core.publisher.Mono<Void> deleteAll()
deleteAll
in interface ReactiveCrudRepository<T,ID extends Serializable>
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.