Package io.micronaut.data.mongodb.repository

Interface MongoReactiveQueryExecutor<E>

Type Parameters:
E - The entity type
public interface MongoReactiveQueryExecutor<E>
MongoDB specific reactive repository that allows to use direct BSON objects reactive way. Essentially, the same as MongoQueryExecutor just reactive implementation.
Since:
4.2
Author:
radovanradic

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<Long>
    count(@Nullable org.bson.conversions.Bson filter)
    Count the records.
    reactor.core.publisher.Mono<Long>
    deleteAll(@NonNull org.bson.conversions.Bson filter)
    Delete the records matching the filter.
    reactor.core.publisher.Mono<Long>
    deleteAll(@NonNull org.bson.conversions.Bson filter, @NonNull com.mongodb.client.model.DeleteOptions options)
    Delete the records matching the filter.
    @NonNull reactor.core.publisher.Flux<E>
    findAll(@NonNull MongoFindOptions options)
    Finds all results.
    @NonNull reactor.core.publisher.Mono<Page<E>>
    findAll(@NonNull MongoFindOptions options, @NonNull Pageable pageable)
    Finds a page of records.
    @NonNull reactor.core.publisher.Flux<E>
    findAll(@NonNull Iterable<org.bson.conversions.Bson> pipeline)
    Finds all results.
    @NonNull reactor.core.publisher.Flux<E>
    findAll(@NonNull Iterable<org.bson.conversions.Bson> pipeline, @NonNull MongoAggregationOptions options)
    Finds all results.
    @NonNull reactor.core.publisher.Flux<E>
    findAll(@Nullable org.bson.conversions.Bson filter)
    Finds all results.
    @NonNull reactor.core.publisher.Mono<Page<E>>
    findAll(@Nullable org.bson.conversions.Bson filter, @NonNull Pageable pageable)
    Finds a page of records.
    reactor.core.publisher.Mono<E>
    findOne(@NonNull MongoFindOptions options)
    Finds one result.
    reactor.core.publisher.Mono<E>
    findOne(@NonNull Iterable<org.bson.conversions.Bson> pipeline)
    Finds a page of records.
    reactor.core.publisher.Mono<E>
    findOne(@NonNull Iterable<org.bson.conversions.Bson> pipeline, @NonNull MongoAggregationOptions options)
    Finds one result.
    reactor.core.publisher.Mono<E>
    findOne(@Nullable org.bson.conversions.Bson filter)
    Finds one result.
    reactor.core.publisher.Mono<Long>
    updateAll(@NonNull org.bson.conversions.Bson filter, @NonNull org.bson.conversions.Bson update)
    Update the records matching the filter.
    reactor.core.publisher.Mono<Long>
    updateAll(@NonNull org.bson.conversions.Bson filter, @NonNull org.bson.conversions.Bson update, @NonNull com.mongodb.client.model.UpdateOptions options)
    Update the records matching the filter.

  • Method Details

    • findOne

      reactor.core.publisher.Mono<E> findOne(@Nullable @Nullable org.bson.conversions.Bson filter)
      Finds one result.
      Parameters:
      filter - The filter to be applied
      Returns:
      The single result

    • findOne

      reactor.core.publisher.Mono<E> findOne(@NonNull @NonNull MongoFindOptions options)
      Finds one result.
      Parameters:
      options - The options
      Returns:
      The single result

    • findAll

      @NonNull @NonNull reactor.core.publisher.Flux<E> findAll(@Nullable @Nullable org.bson.conversions.Bson filter)
      Finds all results.
      Parameters:
      filter - The filter to be applied
      Returns:
      The records

    • findAll

      @NonNull @NonNull reactor.core.publisher.Flux<E> findAll(@NonNull @NonNull MongoFindOptions options)
      Finds all results.
      Parameters:
      options - The options
      Returns:
      The records

    • findAll

      @NonNull @NonNull reactor.core.publisher.Mono<Page<E>> findAll(@Nullable @Nullable org.bson.conversions.Bson filter, @NonNull @NonNull Pageable pageable)
      Finds a page of records.
      Parameters:
      filter - The filter
      pageable - The pageable
      Returns:
      The page

    • findAll

      @NonNull @NonNull reactor.core.publisher.Mono<Page<E>> findAll(@NonNull @NonNull MongoFindOptions options, @NonNull @NonNull Pageable pageable)
      Finds a page of records.
      Parameters:
      options - The options
      pageable - The pageable
      Returns:
      The page

    • findOne

      reactor.core.publisher.Mono<E> findOne(@NonNull @NonNull Iterable<org.bson.conversions.Bson> pipeline)
      Finds a page of records.
      Parameters:
      pipeline - The pipeline to be applied
      Returns:
      The single result

    • findOne

      reactor.core.publisher.Mono<E> findOne(@NonNull @NonNull Iterable<org.bson.conversions.Bson> pipeline, @NonNull @NonNull MongoAggregationOptions options)
      Finds one result.
      Parameters:
      pipeline - The pipeline to be applied
      options - The aggregation options
      Returns:
      The single result

    • findAll

      @NonNull @NonNull reactor.core.publisher.Flux<E> findAll(@NonNull @NonNull Iterable<org.bson.conversions.Bson> pipeline)
      Finds all results.
      Parameters:
      pipeline - The pipeline to be applied
      Returns:
      The results

    • findAll

      @NonNull @NonNull reactor.core.publisher.Flux<E> findAll(@NonNull @NonNull Iterable<org.bson.conversions.Bson> pipeline, @NonNull @NonNull MongoAggregationOptions options)
      Finds all results.
      Parameters:
      pipeline - The pipeline to be applied
      options - The options
      Returns:
      The results

    • count

      reactor.core.publisher.Mono<Long> count(@Nullable @Nullable org.bson.conversions.Bson filter)
      Count the records.
      Parameters:
      filter - The filter to be applied
      Returns:
      The count

    • deleteAll

      reactor.core.publisher.Mono<Long> deleteAll(@NonNull @NonNull org.bson.conversions.Bson filter)
      Delete the records matching the filter.
      Parameters:
      filter - The filter to be applied
      Returns:
      The deleted count

    • deleteAll

      reactor.core.publisher.Mono<Long> deleteAll(@NonNull @NonNull org.bson.conversions.Bson filter, @NonNull @NonNull com.mongodb.client.model.DeleteOptions options)
      Delete the records matching the filter.
      Parameters:
      filter - The filter to be applied
      options - The delete options
      Returns:
      The deleted count

    • updateAll

      reactor.core.publisher.Mono<Long> updateAll(@NonNull @NonNull org.bson.conversions.Bson filter, @NonNull @NonNull org.bson.conversions.Bson update)
      Update the records matching the filter.
      Parameters:
      filter - The filter to be applied
      update - The update modification
      Returns:
      The updated count

    • updateAll

      reactor.core.publisher.Mono<Long> updateAll(@NonNull @NonNull org.bson.conversions.Bson filter, @NonNull @NonNull org.bson.conversions.Bson update, @NonNull @NonNull com.mongodb.client.model.UpdateOptions options)
      Update the records matching the filter.
      Parameters:
      filter - The filter to be applied
      update - The update modification
      options - The update options
      Returns:
      The updated count