io.micronaut.data.r2dbc.repository

Interface ReactorCrudRepository<E,ID>

Type Parameters:

E - The entity type

ID - The ID type

All Superinterfaces:

io.micronaut.data.repository.GenericRepository<E,ID>, io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

public interface ReactorCrudRepository<E,ID>
extends io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

CRUD repository for Project Reactor.

See Also:

ReactiveStreamsCrudRepository

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<java.lang.Long>	count()
reactor.core.publisher.Mono<java.lang.Long>	delete(E entity)
reactor.core.publisher.Mono<java.lang.Long>	deleteAll()
reactor.core.publisher.Mono<java.lang.Long>	deleteAll(@NotNull java.lang.Iterable<? extends E> entities)
reactor.core.publisher.Mono<java.lang.Long>	deleteById(ID id)
reactor.core.publisher.Mono<java.lang.Boolean>	existsById(ID id)
reactor.core.publisher.Flux<E>	findAll()
reactor.core.publisher.Mono<E>	findById(ID id)
<S extends E> reactor.core.publisher.Mono<S>	save(S entity)
<S extends E> reactor.core.publisher.Flux<S>	saveAll(@Valid @NotNull java.lang.Iterable<S> entities)
<S extends E> reactor.core.publisher.Mono<S>	update(S entity)

Method Detail

save

@NonNull
<S extends E> reactor.core.publisher.Mono<S> save(@NonNull @Valid @NotNull
                                                           S entity)

Specified by:

save in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

saveAll

@NonNull
<S extends E> reactor.core.publisher.Flux<S> saveAll(@NonNull @Valid @NotNull
                                                              @Valid @NotNull java.lang.Iterable<S> entities)

Specified by:

saveAll in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

update

@NonNull
<S extends E> reactor.core.publisher.Mono<S> update(@NonNull @Valid @NotNull
                                                             S entity)

Specified by:

update in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

findById

@NonNull
reactor.core.publisher.Mono<E> findById(@NonNull @NotNull
                                                 ID id)

Specified by:

findById in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

existsById

@NonNull
reactor.core.publisher.Mono<java.lang.Boolean> existsById(@NonNull @NotNull
                                                                   ID id)

Specified by:

existsById in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

findAll

@NonNull
reactor.core.publisher.Flux<E> findAll()

Specified by:

findAll in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

count

@NonNull
reactor.core.publisher.Mono<java.lang.Long> count()

Specified by:

count in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

deleteById

@NonNull
reactor.core.publisher.Mono<java.lang.Long> deleteById(@NonNull @NotNull
                                                                ID id)

Specified by:

deleteById in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

delete

@NonNull
reactor.core.publisher.Mono<java.lang.Long> delete(@NonNull @NotNull
                                                            E entity)

Specified by:

delete in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

deleteAll

@NonNull
reactor.core.publisher.Mono<java.lang.Long> deleteAll(@NonNull @NotNull
                                                               @NotNull java.lang.Iterable<? extends E> entities)

Specified by:

deleteAll in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>

deleteAll

@NonNull
reactor.core.publisher.Mono<java.lang.Long> deleteAll()

Specified by:

deleteAll in interface io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository<E,ID>