Class ExecutorAsyncOperationsSupportingCriteria

java.lang.Object

io.micronaut.data.runtime.operations.ExecutorAsyncOperations

io.micronaut.data.runtime.operations.ExecutorAsyncOperationsSupportingCriteria

All Implemented Interfaces:

AsyncCriteriaCapableRepository, AsyncCriteriaRepositoryOperations, AsyncRepositoryOperations, AsyncPageIdCriteriaRepositoryOperations

@Internal
public final class ExecutorAsyncOperationsSupportingCriteria
extends ExecutorAsyncOperations
implements AsyncCriteriaRepositoryOperations, AsyncPageIdCriteriaRepositoryOperations

A variation of ExecutorAsyncOperations that supports AsyncCriteriaRepositoryOperations.

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
ExecutorAsyncOperationsSupportingCriteria(RepositoryOperations operations, CriteriaRepositoryOperations criteriaRepositoryOperations, Executor executor)	Default constructor.

Method Summary

Modifier and Type	Method	Description
CompletionStage<Number>	deleteAll(jakarta.persistence.criteria.CriteriaDelete<Number> query)	Executes delete for the given query and parameter values.
CompletionStage<Boolean>	exists(jakarta.persistence.criteria.CriteriaQuery<?> query)	Exists query.
<T> CompletionStage<List<T>>	findAll(jakarta.persistence.criteria.CriteriaQuery<T> query)	Finds all results for the given query.
<T> CompletionStage<List<T>>	findAll(jakarta.persistence.criteria.CriteriaQuery<T> query, int offset, int limit)	Finds all results for the given query.
<R> CompletionStage<R>	findOne(jakarta.persistence.criteria.CriteriaQuery<R> query)	Find one by Query.
<T> CompletionStage<List<T>>	findPageIds(jakarta.persistence.criteria.CriteriaQuery<T> query, int offset, int limit)
jakarta.persistence.criteria.CriteriaBuilder	getCriteriaBuilder()
CompletionStage<Number>	updateAll(jakarta.persistence.criteria.CriteriaUpdate<Number> query)	Executes an update for the given query and parameter values.

Methods inherited from class ExecutorAsyncOperations

count, delete, deleteAll, executeDelete, executeUpdate, exists, findAll, findAll, findOne, findOne, findOptional, findOptional, findPage, getExecutor, persist, persistAll, update, updateAll

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface AsyncCriteriaRepositoryOperations

async

Methods inherited from interface AsyncRepositoryOperations

execute

Constructor Details

ExecutorAsyncOperationsSupportingCriteria

public ExecutorAsyncOperationsSupportingCriteria(RepositoryOperations operations,
 CriteriaRepositoryOperations criteriaRepositoryOperations,
 Executor executor)

Default constructor.

Parameters:

operations - The target operations

criteriaRepositoryOperations - The criteria operations

executor - The executor to use.

Method Details

getCriteriaBuilder

public jakarta.persistence.criteria.CriteriaBuilder getCriteriaBuilder()

Specified by:

getCriteriaBuilder in interface AsyncCriteriaRepositoryOperations

Returns:

The criteria builder

exists

public CompletionStage<Boolean> exists(jakarta.persistence.criteria.CriteriaQuery<?> query)

Description copied from interface: AsyncCriteriaRepositoryOperations

Exists query.

Specified by:

exists in interface AsyncCriteriaRepositoryOperations

Parameters:

query - The query

Returns:

True if query returns true or any row

findOne

public <R> CompletionStage<R> findOne(jakarta.persistence.criteria.CriteriaQuery<R> query)

Description copied from interface: AsyncCriteriaRepositoryOperations

Find one by Query.

Specified by:

findOne in interface AsyncCriteriaRepositoryOperations

Type Parameters:

R - The result type

Parameters:

query - The query

Returns:

A result or null

findAll

public <T> CompletionStage<List<T>> findAll(jakarta.persistence.criteria.CriteriaQuery<T> query)

Description copied from interface: AsyncCriteriaRepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface AsyncCriteriaRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The query

Returns:

An iterable result

findAll

public <T> CompletionStage<List<T>> findAll(jakarta.persistence.criteria.CriteriaQuery<T> query,
 int offset,
 int limit)

Description copied from interface: AsyncCriteriaRepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface AsyncCriteriaRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The query

offset - The offset

limit - The limit

Returns:

An iterable result

findPageIds

public <T> CompletionStage<List<T>> findPageIds(jakarta.persistence.criteria.CriteriaQuery<T> query,
 int offset,
 int limit)

Specified by:

findPageIds in interface AsyncPageIdCriteriaRepositoryOperations

Type Parameters:

T - The result type

Parameters:

query - The page-ID criteria query

offset - The offset

limit - The limit

Returns:

The page IDs

updateAll

public CompletionStage<Number> updateAll(jakarta.persistence.criteria.CriteriaUpdate<Number> query)

Description copied from interface: AsyncCriteriaRepositoryOperations

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:

updateAll in interface AsyncCriteriaRepositoryOperations

Parameters:

query - The prepared query

Returns:

An optional number with the count of the number of records updated

deleteAll

public CompletionStage<Number> deleteAll(jakarta.persistence.criteria.CriteriaDelete<Number> query)

Description copied from interface: AsyncCriteriaRepositoryOperations

Executes delete for the given query and parameter values. If it is possible to return the number of objects deleted, then do so.

Specified by:

deleteAll in interface AsyncCriteriaRepositoryOperations

Parameters:

query - The query

Returns:

An optional number with the count of the number of records updated