Package org.hibernate.reactive.mutiny.impl

Class MutinyQueryImpl<R>

java.lang.Object

org.hibernate.reactive.mutiny.impl.MutinyQueryImpl<R>

All Implemented Interfaces:

Mutiny.AbstractQuery, Mutiny.MutationQuery, Mutiny.Query<R>, Mutiny.SelectionQuery<R>

public class MutinyQueryImpl<R>
extends Object
implements Mutiny.Query<R>

Constructor Summary

Constructors

Constructor	Description
MutinyQueryImpl(ReactiveQuery<R> delegate, MutinySessionFactoryImpl factory)

Method Summary

Modifier and Type	Method	Description
Mutiny.Query<R>	enableFetchProfile(String profileName)	Enable a fetch profile which will be in effect during execution of this query.
io.smallrye.mutiny.Uni<Integer>	executeUpdate()	Asynchronously execute this delete, update, or insert query, returning the updated row count.
org.hibernate.CacheMode	getCacheMode()	Obtain the CacheMode in effect for this query.
String	getCacheRegion()
jakarta.persistence.CacheRetrieveMode	getCacheRetrieveMode()
jakarta.persistence.CacheStoreMode	getCacheStoreMode()
String	getComment()
int	getFirstResult()
org.hibernate.FlushMode	getFlushMode()	Obtain the FlushMode in effect for this query.
int	getMaxResults()
io.smallrye.mutiny.Uni<Long>	getResultCount()	Determine the size of the query result list that would be returned by calling Mutiny.SelectionQuery.getResultList() with no offset or limit applied to the query.
io.smallrye.mutiny.Uni<List<R>>	getResultList()	Asynchronously execute this query, returning the query results as a List, via a Uni.
io.smallrye.mutiny.Uni<R>	getSingleResult()	Asynchronously execute this query, returning a single row that matches the query, throwing an exception if the query returns zero rows or more than one matching row.
io.smallrye.mutiny.Uni<R>	getSingleResultOrNull()	Asynchronously execute this query, returning a single row that matches the query, or null if the query returns no results, throwing an exception if the query returns more than one matching row.
boolean	isCacheable()
boolean	isReadOnly()
Mutiny.Query<R>	setCacheable(boolean cacheable)	Enable or disable caching of this query result set in the second-level query cache.
Mutiny.Query<R>	setCacheMode(org.hibernate.CacheMode cacheMode)	Set the current CacheMode in effect while this query is being executed.
Mutiny.Query<R>	setCacheRegion(String cacheRegion)	Set the name of the cache region in which to store this query result set if caching is enabled.
Mutiny.Query<R>	setCacheRetrieveMode(jakarta.persistence.CacheRetrieveMode cacheRetrieveMode)	Set the current CacheRetrieveMode in effect while this query is being executed.
Mutiny.Query<R>	setCacheStoreMode(jakarta.persistence.CacheStoreMode cacheStoreMode)	Set the current CacheStoreMode in effect while this query is being executed.
Mutiny.Query<R>	setComment(String comment)	Set the comment for this query.
Mutiny.Query<R>	setFirstResult(int startPosition)	Set the position of the first result that may be returned by this query when executed, where the results are numbered from 0.
Mutiny.Query<R>	setFlushMode(jakarta.persistence.FlushModeType flushMode)	Set the current FlushModeType in effect while this query is being executed.
Mutiny.Query<R>	setFlushMode(org.hibernate.FlushMode flushMode)	Set the current FlushMode in effect while this query is being executed.
Mutiny.Query<R>	setLockMode(jakarta.persistence.LockModeType lockMode)	Set the LockModeType to use for the whole query.
Mutiny.Query<R>	setLockMode(String alias, org.hibernate.LockMode lockMode)	Set the LockMode to use for specified alias (as defined in the query's from clause).
Mutiny.Query<R>	setLockMode(org.hibernate.LockMode lockMode)	Set the LockMode to use for the whole query.
Mutiny.Query<R>	setMaxResults(int maxResult)	Set the maximum number of results that may be returned by this query when executed.
Mutiny.SelectionQuery<R>	setPage(org.hibernate.query.Page page)	Set the page of results to return.
Mutiny.Query<R>	setParameter(int position, Object value)	Set the value of an ordinal parameter.
<T1> Mutiny.Query<R>	setParameter(jakarta.persistence.Parameter<T1> param, T1 value)	Set the value of a typed parameter.
Mutiny.Query<R>	setParameter(String name, Object value)	Set the value of a named parameter.
Mutiny.Query<R>	setPlan(jakarta.persistence.EntityGraph<R> entityGraph)	Set the EntityGraph that will be used as a fetch plan for the root entity returned by this query.
Mutiny.Query<R>	setReadOnly(boolean readOnly)	Set the read-only/modifiable mode for entities and proxies loaded by this Query.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.reactive.mutiny.Mutiny.Query

setLockMode

Constructor Details

MutinyQueryImpl

public MutinyQueryImpl(ReactiveQuery<R> delegate,
 MutinySessionFactoryImpl factory)

Method Details

getMaxResults

public int getMaxResults()

Specified by:

getMaxResults in interface Mutiny.SelectionQuery<R>

Returns:

the maximum number results, or Integer.MAX_VALUE if not set

getResultCount

public io.smallrye.mutiny.Uni<Long> getResultCount()

Description copied from interface: Mutiny.SelectionQuery

Determine the size of the query result list that would be returned by calling Mutiny.SelectionQuery.getResultList() with no offset or limit applied to the query.

Specified by:

getResultCount in interface Mutiny.SelectionQuery<R>

Returns:

the size of the list that would be returned

getResultList

public io.smallrye.mutiny.Uni<List<R>> getResultList()

Description copied from interface: Mutiny.SelectionQuery

Asynchronously execute this query, returning the query results as a List, via a Uni. If the query has multiple results per row, the results are returned in an instance of Object[].

Specified by:

getResultList in interface Mutiny.SelectionQuery<R>

Returns:

the resulting rows as a List

See Also:

• Query.getResultList()

getFlushMode

public org.hibernate.FlushMode getFlushMode()

Description copied from interface: Mutiny.SelectionQuery

Obtain the FlushMode in effect for this query. By default, the query inherits the FlushMode of the Mutiny.Session from which is originates.

Specified by:

getFlushMode in interface Mutiny.SelectionQuery<R>

See Also:

• Mutiny.Session.getFlushMode()

setFlushMode

public Mutiny.Query<R> setFlushMode(org.hibernate.FlushMode flushMode)

Description copied from interface: Mutiny.SelectionQuery

Set the current FlushMode in effect while this query is being executed.

Specified by:

setFlushMode in interface Mutiny.Query<R>

Specified by:

setFlushMode in interface Mutiny.SelectionQuery<R>

setLockMode

public Mutiny.Query<R> setLockMode(org.hibernate.LockMode lockMode)

Description copied from interface: Mutiny.SelectionQuery

Set the LockMode to use for the whole query.

Specified by:

setLockMode in interface Mutiny.Query<R>

Specified by:

setLockMode in interface Mutiny.SelectionQuery<R>

setPlan

public Mutiny.Query<R> setPlan(jakarta.persistence.EntityGraph<R> entityGraph)

Description copied from interface: Mutiny.SelectionQuery

Set the EntityGraph that will be used as a fetch plan for the root entity returned by this query.

Specified by:

setPlan in interface Mutiny.Query<R>

Specified by:

setPlan in interface Mutiny.SelectionQuery<R>

enableFetchProfile

public Mutiny.Query<R> enableFetchProfile(String profileName)

Description copied from interface: Mutiny.SelectionQuery

Enable a fetch profile which will be in effect during execution of this query.

Specified by:

enableFetchProfile in interface Mutiny.Query<R>

Specified by:

enableFetchProfile in interface Mutiny.SelectionQuery<R>

getSingleResult

public io.smallrye.mutiny.Uni<R> getSingleResult()

Description copied from interface: Mutiny.SelectionQuery

Asynchronously execute this query, returning a single row that matches the query, throwing an exception if the query returns zero rows or more than one matching row. If the query has multiple results per row, the results are returned in an instance of Object[].

Specified by:

getSingleResult in interface Mutiny.SelectionQuery<R>

Returns:

the single resulting row

See Also:

• Query.getSingleResult()

getSingleResultOrNull

public io.smallrye.mutiny.Uni<R> getSingleResultOrNull()

Description copied from interface: Mutiny.SelectionQuery

Asynchronously execute this query, returning a single row that matches the query, or null if the query returns no results, throwing an exception if the query returns more than one matching row. If the query has multiple results per row, the results are returned in an instance of Object[].

Specified by:

getSingleResultOrNull in interface Mutiny.SelectionQuery<R>

Returns:

the single resulting row or null

See Also:

• Mutiny.SelectionQuery.getSingleResult()

setFlushMode

public Mutiny.Query<R> setFlushMode(jakarta.persistence.FlushModeType flushMode)

Description copied from interface: Mutiny.SelectionQuery

Set the current FlushModeType in effect while this query is being executed.

Specified by:

setFlushMode in interface Mutiny.Query<R>

Specified by:

setFlushMode in interface Mutiny.SelectionQuery<R>

isReadOnly

public boolean isReadOnly()

Specified by:

isReadOnly in interface Mutiny.SelectionQuery<R>

Returns:

the read-only/modifiable mode

See Also:

• Mutiny.Session.isDefaultReadOnly()

setReadOnly

public Mutiny.Query<R> setReadOnly(boolean readOnly)

Description copied from interface: Mutiny.SelectionQuery

Set the read-only/modifiable mode for entities and proxies loaded by this Query. This setting overrides the default setting for the persistence context.

Specified by:

setReadOnly in interface Mutiny.Query<R>

Specified by:

setReadOnly in interface Mutiny.SelectionQuery<R>

See Also:

• Mutiny.Session.setDefaultReadOnly(boolean)

setMaxResults

public Mutiny.Query<R> setMaxResults(int maxResult)

Description copied from interface: Mutiny.SelectionQuery

Set the maximum number of results that may be returned by this query when executed.

Specified by:

setMaxResults in interface Mutiny.Query<R>

Specified by:

setMaxResults in interface Mutiny.SelectionQuery<R>

getFirstResult

public int getFirstResult()

Specified by:

getFirstResult in interface Mutiny.SelectionQuery<R>

Returns:

the first result, or 0 if not set

setFirstResult

public Mutiny.Query<R> setFirstResult(int startPosition)

Description copied from interface: Mutiny.SelectionQuery

Set the position of the first result that may be returned by this query when executed, where the results are numbered from 0.

Specified by:

setFirstResult in interface Mutiny.Query<R>

Specified by:

setFirstResult in interface Mutiny.SelectionQuery<R>

setPage

public Mutiny.SelectionQuery<R> setPage(org.hibernate.query.Page page)

Description copied from interface: Mutiny.SelectionQuery

Set the page of results to return.

Specified by:

setPage in interface Mutiny.SelectionQuery<R>

See Also:

• Page

getCacheMode

public org.hibernate.CacheMode getCacheMode()

Description copied from interface: Mutiny.SelectionQuery

Obtain the CacheMode in effect for this query. By default, the query inherits the CacheMode of the Mutiny.Session from which is originates.

Specified by:

getCacheMode in interface Mutiny.SelectionQuery<R>

See Also:

• Mutiny.Session.getCacheMode()

getCacheStoreMode

public jakarta.persistence.CacheStoreMode getCacheStoreMode()

Specified by:

getCacheStoreMode in interface Mutiny.SelectionQuery<R>

getCacheRetrieveMode

public jakarta.persistence.CacheRetrieveMode getCacheRetrieveMode()

Specified by:

getCacheRetrieveMode in interface Mutiny.SelectionQuery<R>

setCacheMode

public Mutiny.Query<R> setCacheMode(org.hibernate.CacheMode cacheMode)

Description copied from interface: Mutiny.SelectionQuery

Set the current CacheMode in effect while this query is being executed.

Specified by:

setCacheMode in interface Mutiny.Query<R>

Specified by:

setCacheMode in interface Mutiny.SelectionQuery<R>

setCacheStoreMode

public Mutiny.Query<R> setCacheStoreMode(jakarta.persistence.CacheStoreMode cacheStoreMode)

Description copied from interface: Mutiny.SelectionQuery

Set the current CacheStoreMode in effect while this query is being executed.

Specified by:

setCacheStoreMode in interface Mutiny.Query<R>

Specified by:

setCacheStoreMode in interface Mutiny.SelectionQuery<R>

setCacheRetrieveMode

public Mutiny.Query<R> setCacheRetrieveMode(jakarta.persistence.CacheRetrieveMode cacheRetrieveMode)

Description copied from interface: Mutiny.SelectionQuery

Set the current CacheRetrieveMode in effect while this query is being executed.

Specified by:

setCacheRetrieveMode in interface Mutiny.Query<R>

Specified by:

setCacheRetrieveMode in interface Mutiny.SelectionQuery<R>

isCacheable

public boolean isCacheable()

Specified by:

isCacheable in interface Mutiny.SelectionQuery<R>

Returns:

true if this query is cacheable

See Also:

• Mutiny.SelectionQuery.setCacheable(boolean)

setCacheable

public Mutiny.Query<R> setCacheable(boolean cacheable)

Description copied from interface: Mutiny.SelectionQuery

Enable or disable caching of this query result set in the second-level query cache.

Specified by:

setCacheable in interface Mutiny.Query<R>

Specified by:

setCacheable in interface Mutiny.SelectionQuery<R>

Parameters:

cacheable - true if this query is cacheable

getCacheRegion

public String getCacheRegion()

Specified by:

getCacheRegion in interface Mutiny.SelectionQuery<R>

Returns:

the name of the cache region

See Also:

• Mutiny.SelectionQuery.setCacheRegion(String)

setCacheRegion

public Mutiny.Query<R> setCacheRegion(String cacheRegion)

Description copied from interface: Mutiny.SelectionQuery

Set the name of the cache region in which to store this query result set if caching is enabled.

Specified by:

setCacheRegion in interface Mutiny.Query<R>

Specified by:

setCacheRegion in interface Mutiny.SelectionQuery<R>

Parameters:

cacheRegion - the name of the cache region

setLockMode

public Mutiny.Query<R> setLockMode(jakarta.persistence.LockModeType lockMode)

Description copied from interface: Mutiny.SelectionQuery

Set the LockModeType to use for the whole query.

Specified by:

setLockMode in interface Mutiny.Query<R>

Specified by:

setLockMode in interface Mutiny.SelectionQuery<R>

setLockMode

public Mutiny.Query<R> setLockMode(String alias,
 org.hibernate.LockMode lockMode)

Description copied from interface: Mutiny.SelectionQuery

Set the LockMode to use for specified alias (as defined in the query's from clause).

Specified by:

setLockMode in interface Mutiny.Query<R>

Specified by:

setLockMode in interface Mutiny.SelectionQuery<R>

Parameters:

alias - the from clause alias

lockMode - the requested LockMode

See Also:

• SelectionQuery.setLockMode(String,LockMode)

setParameter

public Mutiny.Query<R> setParameter(String name,
 Object value)

Description copied from interface: Mutiny.AbstractQuery

Set the value of a named parameter. Named parameters are specified in the query using placeholder tokens of form :name.

Specified by:

setParameter in interface Mutiny.AbstractQuery

Specified by:

setParameter in interface Mutiny.MutationQuery

Specified by:

setParameter in interface Mutiny.Query<R>

Specified by:

setParameter in interface Mutiny.SelectionQuery<R>

Parameters:

name - the name of the parameter

value - the argument to set

setParameter

public Mutiny.Query<R> setParameter(int position,
 Object value)

Description copied from interface: Mutiny.AbstractQuery

Set the value of an ordinal parameter. Ordinal parameters are numbered from 1, and are specified in the query using placeholder tokens of form ?1, ?2, etc.

Specified by:

setParameter in interface Mutiny.AbstractQuery

Specified by:

setParameter in interface Mutiny.MutationQuery

Specified by:

setParameter in interface Mutiny.Query<R>

Specified by:

setParameter in interface Mutiny.SelectionQuery<R>

Parameters:

position - an integer identifying the ordinal parameter

value - the argument to set

setParameter

public <T1> Mutiny.Query<R> setParameter(jakarta.persistence.Parameter<T1> param,
 T1 value)

Description copied from interface: Mutiny.AbstractQuery

Set the value of a typed parameter. Typed parameters are obtained from the JPA CriteriaBuilder, which may itself be obtained by calling Mutiny.SessionFactory.getCriteriaBuilder().

Specified by:

setParameter in interface Mutiny.AbstractQuery

Specified by:

setParameter in interface Mutiny.MutationQuery

Specified by:

setParameter in interface Mutiny.Query<R>

Specified by:

setParameter in interface Mutiny.SelectionQuery<R>

Parameters:

param - the parameter

value - the argument to set

See Also:

• CriteriaBuilder.parameter(Class)

getComment

public String getComment()

Specified by:

getComment in interface Mutiny.AbstractQuery

setComment

public Mutiny.Query<R> setComment(String comment)

Description copied from interface: Mutiny.AbstractQuery

Set the comment for this query. This comment will be prepended to the SQL query sent to the database.

Specified by:

setComment in interface Mutiny.AbstractQuery

Specified by:

setComment in interface Mutiny.MutationQuery

Specified by:

setComment in interface Mutiny.Query<R>

Specified by:

setComment in interface Mutiny.SelectionQuery<R>

Parameters:

comment - The human-readable comment

executeUpdate

public io.smallrye.mutiny.Uni<Integer> executeUpdate()

Description copied from interface: Mutiny.MutationQuery

Asynchronously execute this delete, update, or insert query, returning the updated row count.

Specified by:

executeUpdate in interface Mutiny.MutationQuery

Returns:

the row count as an integer

See Also:

• Query.executeUpdate()