Package io.quarkus.hibernate.reactive.panache.common.runtime

Class CommonAbstractPanacheQueryImpl<Entity,SessionType extends org.hibernate.reactive.mutiny.Mutiny.QueryProducer>

java.lang.Object

io.quarkus.hibernate.reactive.panache.common.runtime.CommonAbstractPanacheQueryImpl<Entity,SessionType>

Direct Known Subclasses:

CommonManagedPanacheQueryImpl, CommonStatelessPanacheQueryImpl

public abstract class CommonAbstractPanacheQueryImpl<Entity,SessionType extends org.hibernate.reactive.mutiny.Mutiny.QueryProducer>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	customCountQueryForSpring	This is only used by the Spring Data JPA extension, due to Spring's Query annotation allowing a custom count query See https://docs.spring.io/spring-data/jpa/reference/jpa/query-methods.html#jpa.query-methods.at-query.native Otherwise we do not use this, and rely on ORM to generate count queries
protected io.smallrye.mutiny.Uni<SessionType>	em

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CommonAbstractPanacheQueryImpl(CommonAbstractPanacheQueryImpl<?,SessionType> previousQuery, String newQueryString, String customCountQueryForSpring, Class<?> projectionType)
	CommonAbstractPanacheQueryImpl(io.smallrye.mutiny.Uni<SessionType> em, String query, String originalQuery, String orderBy, Object paramsArrayOrMap)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Long>	count()
protected abstract void	disableFilter(SessionType session, String filter)
protected abstract org.hibernate.Filter	enableFilter(SessionType session, String filter)
void	filter(String filterName, Map<String,Object> parameters)
void	firstPage()
<T extends Entity> io.smallrye.mutiny.Uni<T>	firstResult()
io.smallrye.mutiny.Uni<Boolean>	hasNextPage()
boolean	hasPreviousPage()
io.smallrye.mutiny.Uni<Void>	lastPage()
<T extends Entity> io.smallrye.mutiny.Uni<List<T>>	list()
protected abstract <T> CommonAbstractPanacheQueryImpl<T,SessionType>	newQuery(String query, String customCountQueryForSpring, Class<T> type)
void	nextPage()
io.quarkus.panache.common.Page	page()
void	page(int pageIndex, int pageSize)
void	page(io.quarkus.panache.common.Page page)
io.smallrye.mutiny.Uni<Integer>	pageCount()
void	previousPage()
<T> CommonAbstractPanacheQueryImpl<T,SessionType>	project(Class<T> type)
void	range(int startIndex, int lastIndex)
<T extends Entity> io.smallrye.mutiny.Uni<T>	singleResult()
<T extends Entity> io.smallrye.mutiny.Multi<T>	stream()
void	withHint(String hintName, Object value)
void	withLock(jakarta.persistence.LockModeType lockModeType)

Methods inherited from class java.lang.Object

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

Field Details

customCountQueryForSpring

protected String customCountQueryForSpring

This is only used by the Spring Data JPA extension, due to Spring's Query annotation allowing a custom count query See https://docs.spring.io/spring-data/jpa/reference/jpa/query-methods.html#jpa.query-methods.at-query.native Otherwise we do not use this, and rely on ORM to generate count queries

em

protected io.smallrye.mutiny.Uni<SessionType extends org.hibernate.reactive.mutiny.Mutiny.QueryProducer> em

Constructor Details

CommonAbstractPanacheQueryImpl

public CommonAbstractPanacheQueryImpl(io.smallrye.mutiny.Uni<SessionType> em,
 String query,
 String originalQuery,
 String orderBy,
 Object paramsArrayOrMap)

CommonAbstractPanacheQueryImpl

protected CommonAbstractPanacheQueryImpl(CommonAbstractPanacheQueryImpl<?,SessionType> previousQuery,
 String newQueryString,
 String customCountQueryForSpring,
 Class<?> projectionType)

Method Details

newQuery

protected abstract <T>
CommonAbstractPanacheQueryImpl<T,SessionType> newQuery(String query,
 String customCountQueryForSpring,
 Class<T> type)

enableFilter

protected abstract org.hibernate.Filter enableFilter(SessionType session,
 String filter)

disableFilter

protected abstract void disableFilter(SessionType session,
 String filter)

project

public <T>
CommonAbstractPanacheQueryImpl<T,SessionType> project(Class<T> type)

filter

public void filter(String filterName,
 Map<String,Object> parameters)

page

public void page(io.quarkus.panache.common.Page page)

page

public void page(int pageIndex,
 int pageSize)

nextPage

public void nextPage()

previousPage

public void previousPage()

firstPage

public void firstPage()

lastPage

public io.smallrye.mutiny.Uni<Void> lastPage()

hasNextPage

public io.smallrye.mutiny.Uni<Boolean> hasNextPage()

hasPreviousPage

public boolean hasPreviousPage()

pageCount

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

page

public io.quarkus.panache.common.Page page()

range

public void range(int startIndex,
 int lastIndex)

withLock

public void withLock(jakarta.persistence.LockModeType lockModeType)

withHint

public void withHint(String hintName,
 Object value)

count

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

list

public <T extends Entity>
io.smallrye.mutiny.Uni<List<T>> list()

stream

public <T extends Entity>
io.smallrye.mutiny.Multi<T> stream()

firstResult

public <T extends Entity> io.smallrye.mutiny.Uni<T> firstResult()

singleResult

public <T extends Entity> io.smallrye.mutiny.Uni<T> singleResult()