Package io.micronaut.data.tck.repositories

Interface PersonReactiveRepository

All Superinterfaces:
GenericRepository<Person,Long>, ReactiveStreamsCrudRepository<Person,Long>, ReactiveStreamsJpaSpecificationExecutor<Person>, ReactiveStreamsPageableRepository<Person,Long>, ReactorCrudRepository<Person,Long>, ReactorJpaSpecificationExecutor<Person>, ReactorPageableRepository<Person,Long>
public interface PersonReactiveRepository extends ReactorPageableRepository<Person,Long>, ReactorJpaSpecificationExecutor<Person>

  • Method Details

    • save

      reactor.core.publisher.Mono<Person> save(String name, int age)

    • getById

      reactor.core.publisher.Mono<Person> getById(Long id)

    • updatePerson

      reactor.core.publisher.Mono<Long> updatePerson(@Id Long id, @Parameter("name") String name)

    • list

      reactor.core.publisher.Flux<Person> list(Pageable pageable)

    • count

      reactor.core.publisher.Mono<Long> count(String name)

    • findByName

      reactor.core.publisher.Mono<Person> findByName(String name)

    • getByName

      reactor.core.publisher.Mono<PersonDto> getByName(String name)

    • queryByName

      reactor.core.publisher.Flux<PersonDto> queryByName(String name)

    • deleteByNameLike

      reactor.core.publisher.Mono<Long> deleteByNameLike(String name)

    • findByNameLike

      reactor.core.publisher.Flux<Person> findByNameLike(String name)

    • findByNameLike

      reactor.core.publisher.Mono<Page<Person>> findByNameLike(String name, Pageable pageable)

    • findPeople

      @Query(value="select * from person person_ where person_.name like :n", countQuery="select count(*) from person person_ where person_.name like :n") reactor.core.publisher.Mono<Page<Person>> findPeople(String n, Pageable pageable)

    • getMaxId

      @Query("SELECT MAX(id) FROM person WHERE id = -1") reactor.core.publisher.Mono<Long> getMaxId()

    • updatePeople

      reactor.core.publisher.Flux<Person> updatePeople(List<Person> people)

    • updateNamesCustom

      @Query("UPDATE person SET name = :newName WHERE (name = :oldName)") reactor.core.publisher.Mono<Long> updateNamesCustom(String newName, String oldName)

    • saveCustom

      @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, TRUE)") reactor.core.publisher.Mono<Long> saveCustom(List<Person> people)

    • saveCustomSingle

      @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, TRUE)") reactor.core.publisher.Mono<Long> saveCustomSingle(Person people)

    • saveCustomSingleExpression

      @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, TRUE)") @ParameterExpression(name="name",expression="#{person.name + \'XYZ\'}") @ParameterExpression(name="age",expression="#{person.age}") reactor.core.publisher.Mono<Long> saveCustomSingleExpression(Person person)

    • deleteCustom

      @Query("DELETE FROM person WHERE name = :name") reactor.core.publisher.Mono<Long> deleteCustom(List<Person> people)

    • deleteCustomSingle

      @Query("DELETE FROM person WHERE name = :name") reactor.core.publisher.Mono<Long> deleteCustomSingle(Person person)

    • deleteCustomSingleExpression

      @Query("DELETE FROM person WHERE name = :name") @ParameterExpression(name="name", expression="#{person.name}") reactor.core.publisher.Mono<Long> deleteCustomSingleExpression(Person person)

    • deleteCustomSingleNoEntity

      @Query("DELETE FROM person WHERE name = :xyz") reactor.core.publisher.Mono<Long> deleteCustomSingleNoEntity(String xyz)

    • searchByNameLike

      reactor.core.publisher.Mono<Page<PersonWithIdAndNameDto>> searchByNameLike(String name, Pageable pageable)

    • findNameByNameLike

      reactor.core.publisher.Mono<Page<String>> findNameByNameLike(String name, Pageable pageable)

    • queryByAgeGreaterThan

      reactor.core.publisher.Mono<Page<PersonDto>> queryByAgeGreaterThan(int age, Pageable pageable)