BlockingReactorRepositoryOperations (javadoc 3.0.1 API)

All Superinterfaces:

io.micronaut.context.ApplicationContextProvider, ReactiveCapableRepository, ReactorReactiveCapableRepository, RepositoryOperations

All Known Implementing Classes:

DefaultR2dbcRepositoryOperations
```
public interface BlockingReactorRepositoryOperations
extends RepositoryOperations, ReactorReactiveCapableRepository
```
Implementation of RepositoryOperations that blocks every call from ReactorReactiveRepositoryOperations.

Since:

2.4.0

Author:

Denis Stepanov

Method Summary

All Methods Instance Methods Default Methods
Modifier and Type	Method and Description
`default <T> long`	`count(PagedQuery<T> pagedQuery)` Counts all results for the given query.
`default <T> int`	`delete(DeleteOperation<T> operation)` Deletes the entity.
`default <T> java.util.Optional<java.lang.Number>`	`deleteAll(DeleteBatchOperation<T> operation)` Deletes all the entities of the given type.
`default java.util.Optional<java.lang.Number>`	`executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery)` Executes an update for the given query and parameter values.
`default <T> boolean`	`exists(PreparedQuery<T,java.lang.Boolean> preparedQuery)` Execute a query that checks for existence.
`default <T> java.lang.Iterable<T>`	`findAll(PagedQuery<T> query)` Finds all results for the given query.
`default <T,R> java.lang.Iterable<R>`	`findAll(PreparedQuery<T,R> preparedQuery)` Finds all results for the given query.
`default <T> T`	`findOne(java.lang.Class<T> type, java.io.Serializable id)` Find one by ID.
`default <T,R> R`	`findOne(PreparedQuery<T,R> preparedQuery)` Find one by Query.
`default <R> Page<R>`	`findPage(PagedQuery<R> query)` Find a page for the given entity and pageable.
`default <T> java.util.stream.Stream<T>`	`findStream(PagedQuery<T> query)` Finds a stream for the given arguments.
`default <T,R> java.util.stream.Stream<R>`	`findStream(PreparedQuery<T,R> preparedQuery)` Finds all results for the given query.
`default <T> T`	`persist(InsertOperation<T> operation)` Persist the operation returning a possibly new entity.
`default <T> java.lang.Iterable<T>`	`persistAll(InsertBatchOperation<T> operation)` Persist all the given entities.
`default <T> T`	`update(UpdateOperation<T> operation)` Updates the entity for the given operation.

Methods inherited from interface io.micronaut.data.r2dbc.operations.ReactorReactiveCapableRepository
reactive

Methods inherited from interface io.micronaut.data.operations.RepositoryOperations
executeDelete, getEntity, getQueryHints, updateAll

Methods inherited from interface io.micronaut.context.ApplicationContextProvider
getApplicationContext

- Method Detail
  - findOne
```
@Nullable
default <T> T findOne(@NonNull
                                java.lang.Class<T> type,
                                @NonNull
                                java.io.Serializable id)
```
    Description copied from interface: RepositoryOperations
    
    Find one by ID.
    
    Specified by:
    
    findOne in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    type - The type
    
    id - The id
    
    Returns:
    
    A result or null
  - findOne
```
@Nullable
default <T,R> R findOne(@NonNull
                                  PreparedQuery<T,R> preparedQuery)
```
    Description copied from interface: RepositoryOperations
    
    Find one by Query.
    
    Specified by:
    
    findOne in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic resultType
    
    R - The result type
    
    Parameters:
    
    preparedQuery - The prepared query
    
    Returns:
    
    A result or null
  - findAll
```
@NonNull
default <T,R> java.lang.Iterable<R> findAll(@NonNull
                                                     PreparedQuery<T,R> preparedQuery)
```
    Description copied from interface: RepositoryOperations
    
    Finds all results for the given query.
    
    Specified by:
    
    findAll in interface RepositoryOperations
    
    Type Parameters:
    
    T - The entity type
    
    R - The result type
    
    Parameters:
    
    preparedQuery - The prepared query
    
    Returns:
    
    An iterable result
  - findStream
```
@NonNull
default <T,R> java.util.stream.Stream<R> findStream(@NonNull
                                                             PreparedQuery<T,R> preparedQuery)
```
    Description copied from interface: RepositoryOperations
    
    Finds all results for the given query.
    
    Specified by:
    
    findStream in interface RepositoryOperations
    
    Type Parameters:
    
    T - The entity type
    
    R - The result type
    
    Parameters:
    
    preparedQuery - The prepared query
    
    Returns:
    
    An iterable result
  - persist
```
@NonNull
default <T> T persist(@NonNull
                               InsertOperation<T> operation)
```
    Description copied from interface: RepositoryOperations
    
    Persist the operation returning a possibly new entity.
    
    Specified by:
    
    persist in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    operation - The operation
    
    Returns:
    
    The operation
  - update
```
@NonNull
default <T> T update(@NonNull
                              UpdateOperation<T> operation)
```
    Description copied from interface: RepositoryOperations
    
    Updates the entity for the given operation.
    
    Specified by:
    
    update in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    operation - The operation
    
    Returns:
    
    The operation
  - persistAll
```
@NonNull
default <T> java.lang.Iterable<T> persistAll(@NonNull
                                                      InsertBatchOperation<T> operation)
```
    Description copied from interface: RepositoryOperations
    
    Persist all the given entities.
    
    Specified by:
    
    persistAll in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    operation - The operation
    
    Returns:
    
    The entities, possibly mutated
  - executeUpdate
```
@NonNull
default java.util.Optional<java.lang.Number> executeUpdate(@NonNull
                                                                    PreparedQuery<?,java.lang.Number> preparedQuery)
```
    Description copied from interface: RepositoryOperations
    
    Executes an update for the given query and parameter values. If it is possible to return the number of objects updated, then do so.
    
    Specified by:
    
    executeUpdate in interface RepositoryOperations
    
    Parameters:
    
    preparedQuery - The prepared query
    
    Returns:
    
    An optional number with the count of the number of records updated
  - delete
```
default <T> int delete(@NonNull
                       DeleteOperation<T> operation)
```
    Description copied from interface: RepositoryOperations
    
    Deletes the entity.
    
    Specified by:
    
    delete in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    operation - The operation
    
    Returns:
    
    The number of entities deleted
  - deleteAll
```
default <T> java.util.Optional<java.lang.Number> deleteAll(@NonNull
                                                           DeleteBatchOperation<T> operation)
```
    Description copied from interface: RepositoryOperations
    
    Deletes all the entities of the given type.
    
    Specified by:
    
    deleteAll in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    operation - The operation
    
    Returns:
    
    The number of entities deleted
  - exists
```
default <T> boolean exists(@NonNull
                           PreparedQuery<T,java.lang.Boolean> preparedQuery)
```
    Description copied from interface: RepositoryOperations
    
    Execute a query that checks for existence.
    
    Specified by:
    
    exists in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic resultType
    
    Parameters:
    
    preparedQuery - The prepared query
    
    Returns:
    
    A result or null
  - findPage
```
default <R> Page<R> findPage(@NonNull
                             PagedQuery<R> query)
```
    Description copied from interface: RepositoryOperations
    
    Find a page for the given entity and pageable.
    
    Specified by:
    
    findPage in interface RepositoryOperations
    
    Type Parameters:
    
    R - The entity generic type
    
    Parameters:
    
    query - The query
    
    Returns:
    
    The page type
  - findAll
```
@NonNull
default <T> java.lang.Iterable<T> findAll(@NonNull
                                                   PagedQuery<T> query)
```
    Description copied from interface: RepositoryOperations
    
    Finds all results for the given query.
    
    Specified by:
    
    findAll in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    query - The root entity
    
    Returns:
    
    An iterable result
  - count
```
default <T> long count(PagedQuery<T> pagedQuery)
```
    Description copied from interface: RepositoryOperations
    
    Counts all results for the given query.
    
    Specified by:
    
    count in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    pagedQuery - The paged query
    
    Returns:
    
    An iterable result
  - findStream
```
@NonNull
default <T> java.util.stream.Stream<T> findStream(@NonNull
                                                           PagedQuery<T> query)
```
    Description copied from interface: RepositoryOperations
    
    Finds a stream for the given arguments.
    
    Specified by:
    
    findStream in interface RepositoryOperations
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    query - The query
    
    Returns:
    
    The stream

Interface BlockingReactorRepositoryOperations

Method Summary

Methods inherited from interface io.micronaut.data.r2dbc.operations.ReactorReactiveCapableRepository

Methods inherited from interface io.micronaut.data.operations.RepositoryOperations

Methods inherited from interface io.micronaut.context.ApplicationContextProvider

Method Detail

findOne

findOne

findAll

findStream

persist

update

persistAll

executeUpdate

delete

deleteAll

exists

findPage

findAll

count

findStream