Package org.hibernate.reactive.stage.impl

Class StageStatelessSessionImpl

java.lang.Object

org.hibernate.reactive.stage.impl.StageStatelessSessionImpl

All Implemented Interfaces:

Stage.Closeable, Stage.QueryProducer, Stage.StatelessSession

public class StageStatelessSessionImpl
extends Object
implements Stage.StatelessSession

Implements the Stage.StatelessSession API. This delegating class is needed to avoid name clashes when implementing both StatelessSession and StatelessSession.

Constructor Summary

Constructors

Constructor	Description
StageStatelessSessionImpl(ReactiveStatelessSession delegate)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	close()	Close the reactive session and release the underlying database connection.
<T> jakarta.persistence.EntityGraph<T>	createEntityGraph(Class<T> rootType)	Create a new mutable EntityGraph
<T> jakarta.persistence.EntityGraph<T>	createEntityGraph(Class<T> rootType, String graphName)	Create a new mutable copy of a named EntityGraph
Stage.MutationQuery	createMutationQuery(jakarta.persistence.criteria.CriteriaDelete<?> deleteQuery)	Create an instance of Stage.MutationQuery for the given delete tree.
Stage.MutationQuery	createMutationQuery(jakarta.persistence.criteria.CriteriaUpdate<?> updateQuery)	Create an instance of Stage.MutationQuery for the given update tree.
Stage.MutationQuery	createMutationQuery(String queryString)	Create an instance of Stage.MutationQuery for the given HQL/JPQL update or delete statement.
Stage.MutationQuery	createMutationQuery(org.hibernate.query.criteria.JpaCriteriaInsert<?> insert)	Create a Stage.MutationQuery from the given insert select criteria tree
<R> Stage.Query<R>	createNamedQuery(String queryName)	Create an instance of Stage.Query for the named query.
<R> Stage.SelectionQuery<R>	createNamedQuery(String queryName, Class<R> resultType)	Create an instance of Stage.SelectionQuery for the named query.
<R> Stage.Query<R>	createNativeQuery(String queryString)	Create an instance of Stage.Query for the given SQL query string, or SQL update, insert, or delete statement.
<R> Stage.SelectionQuery<R>	createNativeQuery(String queryString, Class<R> resultType)	Create an instance of Stage.Query for the given SQL query string, using the given resultType to interpret the results.
<R> Stage.SelectionQuery<R>	createNativeQuery(String queryString, Class<R> resultType, AffectedEntities affectedEntities)	Create an instance of Stage.SelectionQuery for the given SQL query string, using the given resultType to interpret the results.
<R> Stage.Query<R>	createNativeQuery(String queryString, AffectedEntities affectedEntities)	Create an instance of Stage.Query for the given SQL query string, or SQL update, insert, or delete statement.
<R> Stage.SelectionQuery<R>	createNativeQuery(String queryString, ResultSetMapping<R> resultSetMapping)	Create an instance of Stage.SelectionQuery for the given SQL query string, using the given ResultSetMapping to interpret the result set.
<R> Stage.SelectionQuery<R>	createNativeQuery(String queryString, ResultSetMapping<R> resultSetMapping, AffectedEntities affectedEntities)	Create an instance of Stage.SelectionQuery for the given SQL query string, using the given ResultSetMapping to interpret the result set.
<R> Stage.MutationQuery	createQuery(jakarta.persistence.criteria.CriteriaDelete<R> criteriaDelete)	Create an instance of Stage.MutationQuery for the given criteria delete.
<R> Stage.SelectionQuery<R>	createQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteriaQuery)	Create an instance of Stage.SelectionQuery for the given criteria query.
<R> Stage.MutationQuery	createQuery(jakarta.persistence.criteria.CriteriaUpdate<R> criteriaUpdate)	Create an instance of Stage.MutationQuery for the given criteria update.
<R> Stage.Query<R>	createQuery(jakarta.persistence.TypedQueryReference<R> typedQueryReference)	Create a typed Stage.Query instance for the given typed query reference.
<R> Stage.Query<R>	createQuery(String queryString)	Deprecated.
<R> Stage.SelectionQuery<R>	createQuery(String queryString, Class<R> resultType)	Create an instance of Stage.SelectionQuery for the given HQL/JPQL query string and query result type.
<R> Stage.SelectionQuery<R>	createSelectionQuery(String queryString, Class<R> resultType)	Create an instance of Stage.SelectionQuery for the given HQL/JPQL query string.
Stage.Transaction	currentTransaction()	Obtain the transaction currently associated with this session, if any.
CompletionStage<Void>	delete(int batchSize, Object... entities)	Delete multiple rows.
CompletionStage<Void>	delete(Object entity)	Delete a row.
CompletionStage<Void>	delete(Object... entities)	Delete multiple rows, using the number of the given entities as the batch size.
CompletionStage<Void>	deleteMultiple(List<?> entities)	Delete multiple rows, using the size of the given list as the batch size.
<T> CompletionStage<T>	fetch(T association)	Asynchronously fetch an association that's configured for lazy loading.
<T> CompletionStage<T>	get(jakarta.persistence.EntityGraph<T> entityGraph, Object id)	Retrieve a row, using the given EntityGraph as a fetch plan.
<T> CompletionStage<T>	get(Class<T> entityClass, Object id)	Retrieve a row.
<T> CompletionStage<List<T>>	get(Class<T> entityClass, Object... ids)	Retrieve multiple rows.
<T> CompletionStage<T>	get(Class<T> entityClass, Object id, org.hibernate.LockMode lockMode)	Retrieve a row, obtaining the specified lock mode.
jakarta.persistence.criteria.CriteriaBuilder	getCriteriaBuilder()	Convenience method to obtain the CriteriaBuilder.
<T> jakarta.persistence.EntityGraph<T>	getEntityGraph(Class<T> rootType, String graphName)	Obtain a named EntityGraph
Stage.SessionFactory	getFactory()	The Stage.SessionFactory which created this session.
Object	getIdentifier(Object entity)	Return the identifier value of the given entity, which may be detached.
ReactiveConnection	getReactiveConnection()
<T> ResultSetMapping<T>	getResultSetMapping(Class<T> resultType, String mappingName)	Obtain a native SQL result set mapping defined via the annotation SqlResultSetMapping.
CompletionStage<Void>	insert(int batchSize, Object... entities)	Insert multiple rows.
CompletionStage<Void>	insert(Object entity)	Insert a row.
CompletionStage<Void>	insert(Object... entities)	Insert multiple rows, using the number of the given entities as the batch size.
CompletionStage<Void>	insertMultiple(List<?> entities)	Insert multiple rows, using the size of the given list as the batch size.
boolean	isOpen()
CompletionStage<Void>	refresh(int batchSize, Object... entities)	Refresh the entity instance state from the database.
CompletionStage<Void>	refresh(Object entity)	Refresh the entity instance state from the database.
CompletionStage<Void>	refresh(Object... entities)	Refresh the entity instance state from the database, using the number of the given entities as the batch size.
CompletionStage<Void>	refresh(Object entity, org.hibernate.LockMode lockMode)	Refresh the entity instance state from the database.
CompletionStage<Void>	refreshMultiple(List<?> entities)	Refresh the entity instance state from the database, using the size of the given list as the batch size.
CompletionStage<Void>	update(int batchSize, Object... entities)	Update multiple rows.
CompletionStage<Void>	update(Object entity)	Update a row.
CompletionStage<Void>	update(Object... entities)	Update multiple rows, using the number of the given entities as the batch size.
CompletionStage<Void>	updateMultiple(List<?> entities)	Update multiple rows, using the size of the given list as the batch size.
CompletionStage<Void>	upsert(Object entity)
CompletionStage<Void>	upsertAll(int batchSize, Object... entities)	Use a SQL merge into statement to perform an upsert on multiple rows using the specified batch size.
CompletionStage<Void>	upsertAll(Object... entities)	Use a SQL merge into statement to perform an upsert on multiple rows using the size of the given array as batch size.
CompletionStage<Void>	upsertMultiple(List<?> entities)	Use a SQL merge into statement to perform an upsert on multiple rows using the size of the given list as batch size.
<T> CompletionStage<T>	withTransaction(Function<Stage.Transaction,CompletionStage<T>> work)	Performs the given work within the scope of a database transaction, automatically flushing the session.

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.stage.Stage.StatelessSession

get, refresh

Constructor Details

StageStatelessSessionImpl

public StageStatelessSessionImpl(ReactiveStatelessSession delegate)

Method Details

getReactiveConnection

public ReactiveConnection getReactiveConnection()

get

public <T> CompletionStage<T> get(Class<T> entityClass,
 Object id)

Description copied from interface: Stage.StatelessSession

Retrieve a row.

Specified by:

get in interface Stage.StatelessSession

Parameters:

entityClass - The class of the entity to retrieve

id - The id of the entity to retrieve

Returns:

a detached entity instance, via a CompletionStage

See Also:

• StatelessSession.get(Class, Object)

get

public <T> CompletionStage<List<T>> get(Class<T> entityClass,
 Object... ids)

Description copied from interface: Stage.StatelessSession

Retrieve multiple rows.

Specified by:

get in interface Stage.StatelessSession

Parameters:

entityClass - The class of the entity to retrieve

ids - The ids of the entities to retrieve

Returns:

a list of detached entity instances, via a Uni

See Also:

• StatelessSession.getMultiple(Class, List)

get

public <T> CompletionStage<T> get(Class<T> entityClass,
 Object id,
 org.hibernate.LockMode lockMode)

Description copied from interface: Stage.StatelessSession

Retrieve a row, obtaining the specified lock mode.

Specified by:

get in interface Stage.StatelessSession

Parameters:

entityClass - The class of the entity to retrieve

id - The id of the entity to retrieve

lockMode - The lock mode to apply to the entity

Returns:

a detached entity instance, via a CompletionStage

See Also:

• StatelessSession.get(Class, Object, LockMode)

insert

public CompletionStage<Void> insert(Object entity)

Description copied from interface: Stage.StatelessSession

Insert a row.

Specified by:

insert in interface Stage.StatelessSession

Parameters:

entity - a new transient instance

See Also:

• StatelessSession.insert(Object)

insert

public CompletionStage<Void> insert(Object... entities)

Description copied from interface: Stage.StatelessSession

Insert multiple rows, using the number of the given entities as the batch size.

Specified by:

insert in interface Stage.StatelessSession

Parameters:

entities - new transient instances

See Also:

• StatelessSession.insert(Object)

insert

public CompletionStage<Void> insert(int batchSize,
 Object... entities)

Description copied from interface: Stage.StatelessSession

Insert multiple rows.

Specified by:

insert in interface Stage.StatelessSession

Parameters:

batchSize - the batch size

entities - new transient instances

See Also:

• StatelessSession.insert(Object)

insertMultiple

public CompletionStage<Void> insertMultiple(List<?> entities)

Description copied from interface: Stage.StatelessSession

Insert multiple rows, using the size of the given list as the batch size.

Specified by:

insertMultiple in interface Stage.StatelessSession

Parameters:

entities - new transient instances

See Also:

• StatelessSession.insert(Object)

delete

public CompletionStage<Void> delete(Object entity)

Description copied from interface: Stage.StatelessSession

Delete a row.

Specified by:

delete in interface Stage.StatelessSession

Parameters:

entity - a detached entity instance

See Also:

• StatelessSession.delete(Object)

delete

public CompletionStage<Void> delete(Object... entities)

Description copied from interface: Stage.StatelessSession

Delete multiple rows, using the number of the given entities as the batch size.

Specified by:

delete in interface Stage.StatelessSession

Parameters:

entities - detached entity instances

See Also:

• StatelessSession.delete(Object)

delete

public CompletionStage<Void> delete(int batchSize,
 Object... entities)

Description copied from interface: Stage.StatelessSession

Delete multiple rows.

Specified by:

delete in interface Stage.StatelessSession

Parameters:

batchSize - the batch size

entities - detached entity instances

See Also:

• StatelessSession.delete(Object)

deleteMultiple

public CompletionStage<Void> deleteMultiple(List<?> entities)

Description copied from interface: Stage.StatelessSession

Delete multiple rows, using the size of the given list as the batch size.

Specified by:

deleteMultiple in interface Stage.StatelessSession

Parameters:

entities - detached entity instances

See Also:

• StatelessSession.delete(Object)

update

public CompletionStage<Void> update(Object entity)

Description copied from interface: Stage.StatelessSession

Update a row.

Specified by:

update in interface Stage.StatelessSession

Parameters:

entity - a detached entity instance

See Also:

• StatelessSession.update(Object)

update

public CompletionStage<Void> update(Object... entities)

Description copied from interface: Stage.StatelessSession

Update multiple rows, using the number of the given entities as the batch size.

Specified by:

update in interface Stage.StatelessSession

Parameters:

entities - a detached entity instance

See Also:

• StatelessSession.update(Object)

update

public CompletionStage<Void> update(int batchSize,
 Object... entities)

Description copied from interface: Stage.StatelessSession

Update multiple rows.

Specified by:

update in interface Stage.StatelessSession

Parameters:

batchSize - the batch size

entities - a detached entity instance

See Also:

• StatelessSession.update(Object)

updateMultiple

public CompletionStage<Void> updateMultiple(List<?> entities)

Description copied from interface: Stage.StatelessSession

Update multiple rows, using the size of the given list as the batch size.

Specified by:

updateMultiple in interface Stage.StatelessSession

Parameters:

entities - a detached entity instance

See Also:

• StatelessSession.update(Object)

refresh

public CompletionStage<Void> refresh(Object entity)

Description copied from interface: Stage.StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface Stage.StatelessSession

Parameters:

entity - The entity to be refreshed.

See Also:

• StatelessSession.refresh(Object)

refresh

public CompletionStage<Void> refresh(Object... entities)

Description copied from interface: Stage.StatelessSession

Refresh the entity instance state from the database, using the number of the given entities as the batch size.

Specified by:

refresh in interface Stage.StatelessSession

Parameters:

entities - The entities to be refreshed.

See Also:

• StatelessSession.refresh(Object)

refresh

public CompletionStage<Void> refresh(int batchSize,
 Object... entities)

Description copied from interface: Stage.StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface Stage.StatelessSession

Parameters:

batchSize - the batch size

entities - The entities to be refreshed.

See Also:

• StatelessSession.refresh(Object)

refreshMultiple

public CompletionStage<Void> refreshMultiple(List<?> entities)

Description copied from interface: Stage.StatelessSession

Refresh the entity instance state from the database, using the size of the given list as the batch size.

Specified by:

refreshMultiple in interface Stage.StatelessSession

Parameters:

entities - The entities to be refreshed.

See Also:

• StatelessSession.refresh(Object)

refresh

public CompletionStage<Void> refresh(Object entity,
 org.hibernate.LockMode lockMode)

Description copied from interface: Stage.StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface Stage.StatelessSession

Parameters:

entity - The entity to be refreshed.

lockMode - The LockMode to be applied.

See Also:

• StatelessSession.refresh(Object, LockMode)

upsert

public CompletionStage<Void> upsert(Object entity)

Specified by:

upsert in interface Stage.StatelessSession

Parameters:

entity - a detached entity instance

See Also:

• StatelessSession.upsert(Object)

upsertAll

public CompletionStage<Void> upsertAll(Object... entities)

Description copied from interface: Stage.StatelessSession

Use a SQL merge into statement to perform an upsert on multiple rows using the size of the given array as batch size.

Specified by:

upsertAll in interface Stage.StatelessSession

Parameters:

entities - the entities to upsert

See Also:

• StatelessSession.upsert(Object)

upsertAll

public CompletionStage<Void> upsertAll(int batchSize,
 Object... entities)

Description copied from interface: Stage.StatelessSession

Use a SQL merge into statement to perform an upsert on multiple rows using the specified batch size.

Specified by:

upsertAll in interface Stage.StatelessSession

Parameters:

batchSize - the batch size

entities - the list of entities to upsert

See Also:

• StatelessSession.upsert(Object)

upsertMultiple

public CompletionStage<Void> upsertMultiple(List<?> entities)

Description copied from interface: Stage.StatelessSession

Use a SQL merge into statement to perform an upsert on multiple rows using the size of the given list as batch size.

Specified by:

upsertMultiple in interface Stage.StatelessSession

Parameters:

entities - the entities to upsert

See Also:

• StatelessSession.upsert(Object)

fetch

public <T> CompletionStage<T> fetch(T association)

Description copied from interface: Stage.StatelessSession

Asynchronously fetch an association that's configured for lazy loading.

 session.fetch(author.getBook()).thenAccept(book -> print(book.getTitle()))
 

Warning: this operation in a stateless session is quite sensitive to data aliasing effects and should be used with great care.

Specified by:

fetch in interface Stage.StatelessSession

Parameters:

association - a lazy-loaded association

Returns:

the fetched association, via a CompletionStage

See Also:

• Hibernate.initialize(Object)

getIdentifier

public Object getIdentifier(Object entity)

Description copied from interface: Stage.StatelessSession

Return the identifier value of the given entity, which may be detached.

Specified by:

getIdentifier in interface Stage.StatelessSession

Parameters:

entity - a persistent instance associated with this session

Returns:

the identifier

withTransaction

public <T> CompletionStage<T> withTransaction(Function<Stage.Transaction,CompletionStage<T>> work)

Description copied from interface: Stage.StatelessSession

Performs the given work within the scope of a database transaction, automatically flushing the session. The transaction will be rolled back if the work completes with an uncaught exception, or if Stage.Transaction.markForRollback() is called.

If there is already a transaction associated with this session, the work is executed in the context of the existing transaction, and no new transaction is initiated.

If there is no transaction associated with this session, a new transaction is started, and the work is executed in the context of the new transaction.

Specified by:

withTransaction in interface Stage.StatelessSession

Parameters:

work - a function which accepts Stage.Transaction and returns the result of the work as a CompletionStage.

See Also:

• Stage.SessionFactory.withTransaction(BiFunction)

close

public CompletionStage<Void> close()

Description copied from interface: Stage.StatelessSession

Close the reactive session and release the underlying database connection.

Specified by:

close in interface Stage.Closeable

Specified by:

close in interface Stage.StatelessSession

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Stage.StatelessSession

Returns:

false if Stage.StatelessSession.close() has been called

getFactory

public Stage.SessionFactory getFactory()

Description copied from interface: Stage.StatelessSession

The Stage.SessionFactory which created this session.

Specified by:

getFactory in interface Stage.StatelessSession

getCriteriaBuilder

public jakarta.persistence.criteria.CriteriaBuilder getCriteriaBuilder()

Description copied from interface: Stage.StatelessSession

Convenience method to obtain the CriteriaBuilder.

Specified by:

getCriteriaBuilder in interface Stage.QueryProducer

Specified by:

getCriteriaBuilder in interface Stage.StatelessSession

currentTransaction

public Stage.Transaction currentTransaction()

Description copied from interface: Stage.StatelessSession

Obtain the transaction currently associated with this session, if any.

Specified by:

currentTransaction in interface Stage.StatelessSession

Returns:

the Stage.Transaction, or null if no transaction was started using Stage.StatelessSession.withTransaction(Function).

See Also:

• Stage.StatelessSession.withTransaction(Function)
• Stage.SessionFactory.withTransaction(BiFunction)

get

public <T> CompletionStage<T> get(jakarta.persistence.EntityGraph<T> entityGraph,
 Object id)

Description copied from interface: Stage.StatelessSession

Retrieve a row, using the given EntityGraph as a fetch plan.

Specified by:

get in interface Stage.StatelessSession

Parameters:

entityGraph - an EntityGraph specifying the entity and associations to be fetched

id - The id of the entity to retrieve

Returns:

a detached entity instance, via a CompletionStage

createQuery

@Deprecated
public <R> Stage.Query<R> createQuery(String queryString)

Deprecated.

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.Query for the given HQL/JPQL query string or HQL/JPQL update or delete statement. In the case of an update or delete, the returned Stage.Query must be executed using Stage.MutationQuery.executeUpdate() which returns an affected row count.

Specified by:

createQuery in interface Stage.QueryProducer

Parameters:

queryString - The HQL/JPQL query, update or delete statement

Returns:

The Stage.Query instance for manipulation and execution

See Also:

• EntityManager.createQuery(String)

createQuery

public <R> Stage.Query<R> createQuery(jakarta.persistence.TypedQueryReference<R> typedQueryReference)

Description copied from interface: Stage.QueryProducer

Create a typed Stage.Query instance for the given typed query reference.

Specified by:

createQuery in interface Stage.QueryProducer

Parameters:

typedQueryReference - the type query reference

Returns:

The Stage.Query instance for execution

See Also:

• QueryProducer.createQuery(TypedQueryReference)

createSelectionQuery

public <R> Stage.SelectionQuery<R> createSelectionQuery(String queryString,
 Class<R> resultType)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the given HQL/JPQL query string.

Specified by:

createSelectionQuery in interface Stage.QueryProducer

Parameters:

queryString - The HQL/JPQL query

Returns:

The Stage.SelectionQuery instance for manipulation and execution

See Also:

• EntityManager.createQuery(String, Class)

createMutationQuery

public Stage.MutationQuery createMutationQuery(String queryString)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.MutationQuery for the given HQL/JPQL update or delete statement.

Specified by:

createMutationQuery in interface Stage.QueryProducer

Parameters:

queryString - The HQL/JPQL query, update or delete statement

Returns:

The Stage.MutationQuery instance for manipulation and execution

See Also:

• EntityManager.createQuery(String)

createMutationQuery

public Stage.MutationQuery createMutationQuery(jakarta.persistence.criteria.CriteriaUpdate<?> updateQuery)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.MutationQuery for the given update tree.

Specified by:

createMutationQuery in interface Stage.QueryProducer

Parameters:

updateQuery - the update criteria query

Returns:

The Stage.MutationQuery instance for manipulation and execution

See Also:

• QueryProducer.createMutationQuery(CriteriaUpdate)

createMutationQuery

public Stage.MutationQuery createMutationQuery(jakarta.persistence.criteria.CriteriaDelete<?> deleteQuery)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.MutationQuery for the given delete tree.

Specified by:

createMutationQuery in interface Stage.QueryProducer

Parameters:

deleteQuery - the delete criteria query

Returns:

The Stage.MutationQuery instance for manipulation and execution

See Also:

• QueryProducer.createMutationQuery(CriteriaDelete)

createMutationQuery

public Stage.MutationQuery createMutationQuery(org.hibernate.query.criteria.JpaCriteriaInsert<?> insert)

Description copied from interface: Stage.QueryProducer

Create a Stage.MutationQuery from the given insert select criteria tree

Specified by:

createMutationQuery in interface Stage.QueryProducer

Parameters:

insert - the insert select criteria query

Returns:

The Stage.MutationQuery instance for manipulation and execution

See Also:

• QueryProducer.createMutationQuery(JpaCriteriaInsert)

createQuery

public <R> Stage.SelectionQuery<R> createQuery(String queryString,
 Class<R> resultType)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the given HQL/JPQL query string and query result type.

Specified by:

createQuery in interface Stage.QueryProducer

Parameters:

queryString - The HQL/JPQL query

resultType - the Java type returned in each row of query results

Returns:

The Stage.Query instance for manipulation and execution

See Also:

• EntityManager.createQuery(String, Class)

createNativeQuery

public <R> Stage.Query<R> createNativeQuery(String queryString)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.Query for the given SQL query string, or SQL update, insert, or delete statement. In the case of an update, insert, or delete, the returned Stage.Query must be executed using Stage.MutationQuery.executeUpdate() which returns an affected row count. In the case of a query:

• If the result set has a single column, the results will be returned as scalars.
• Otherwise, if the result set has multiple columns, the results will be returned as elements of arrays of type Object[].

Specified by:

createNativeQuery in interface Stage.QueryProducer

Parameters:

queryString - The SQL select, update, insert, or delete statement

createNativeQuery

public <R> Stage.Query<R> createNativeQuery(String queryString,
 AffectedEntities affectedEntities)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.Query for the given SQL query string, or SQL update, insert, or delete statement. In the case of an update, insert, or delete, the returned Stage.Query must be executed using Stage.MutationQuery.executeUpdate() which returns an affected row count. In the case of a query:

• If the result set has a single column, the results will be returned as scalars.
• Otherwise, if the result set has multiple columns, the results will be returned as elements of arrays of type Object[].

Any affected entities are synchronized with the database before execution of the statement.

Specified by:

createNativeQuery in interface Stage.QueryProducer

Parameters:

queryString - The SQL select, update, insert, or delete statement

affectedEntities - The entities which are affected by the statement

createNamedQuery

public <R> Stage.Query<R> createNamedQuery(String queryName)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.Query for the named query.

Specified by:

createNamedQuery in interface Stage.QueryProducer

Parameters:

queryName - The name of the query

Returns:

The Stage.Query instance for manipulation and execution

See Also:

• EntityManager.createQuery(String)

createNamedQuery

public <R> Stage.SelectionQuery<R> createNamedQuery(String queryName,
 Class<R> resultType)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the named query.

Specified by:

createNamedQuery in interface Stage.QueryProducer

Parameters:

queryName - The name of the query

resultType - the Java type returned in each row of query results

Returns:

The Stage.SelectionQuery instance for manipulation and execution

See Also:

• EntityManager.createQuery(String, Class)

createNativeQuery

public <R> Stage.SelectionQuery<R> createNativeQuery(String queryString,
 Class<R> resultType)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.Query for the given SQL query string, using the given resultType to interpret the results.

• If the given result type is Object, or a built-in type such as String or Integer, the result set must have a single column, which will be returned as a scalar.
• If the given result type is Object[], then the result set must have multiple columns, which will be returned as elements of arrays of type Object[].
• Otherwise, the given result type must be an entity class, in which case the result set column aliases must map to the fields of the entity, and the query will return instances of the entity.

Specified by:

createNativeQuery in interface Stage.QueryProducer

Parameters:

queryString - The SQL query

resultType - the Java type returned in each row of query results

Returns:

The Stage.SelectionQuery instance for manipulation and execution

See Also:

• EntityManager.createNativeQuery(String, Class)

createNativeQuery

public <R> Stage.SelectionQuery<R> createNativeQuery(String queryString,
 Class<R> resultType,
 AffectedEntities affectedEntities)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the given SQL query string, using the given resultType to interpret the results.

• If the given result type is Object, or a built-in type such as String or Integer, the result set must have a single column, which will be returned as a scalar.
• If the given result type is Object[], then the result set must have multiple columns, which will be returned as elements of arrays of type Object[].
• Otherwise, the given result type must be an entity class, in which case the result set column aliases must map to the fields of the entity, and the query will return instances of the entity.

Any affected entities are synchronized with the database before execution of the query.

Specified by:

createNativeQuery in interface Stage.QueryProducer

Parameters:

queryString - The SQL query

resultType - the Java type returned in each row of query results

affectedEntities - The entities which are affected by the query

Returns:

The Stage.Query instance for manipulation and execution

See Also:

• EntityManager.createNativeQuery(String, Class)

createNativeQuery

public <R> Stage.SelectionQuery<R> createNativeQuery(String queryString,
 ResultSetMapping<R> resultSetMapping)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the given SQL query string, using the given ResultSetMapping to interpret the result set.

Specified by:

createNativeQuery in interface Stage.QueryProducer

Parameters:

queryString - The SQL query

resultSetMapping - the result set mapping

Returns:

The Stage.Query instance for manipulation and execution

See Also:

• Stage.QueryProducer.getResultSetMapping(Class, String)
• EntityManager.createNativeQuery(String, String)

createNativeQuery

public <R> Stage.SelectionQuery<R> createNativeQuery(String queryString,
 ResultSetMapping<R> resultSetMapping,
 AffectedEntities affectedEntities)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the given SQL query string, using the given ResultSetMapping to interpret the result set.

Any affected entities are synchronized with the database before execution of the query.

Specified by:

createNativeQuery in interface Stage.QueryProducer

Parameters:

queryString - The SQL query

resultSetMapping - the result set mapping

affectedEntities - The entities which are affected by the query

Returns:

The Stage.Query instance for manipulation and execution

See Also:

• Stage.QueryProducer.getResultSetMapping(Class, String)
• EntityManager.createNativeQuery(String, String)

createQuery

public <R> Stage.SelectionQuery<R> createQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteriaQuery)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.SelectionQuery for the given criteria query.

Specified by:

createQuery in interface Stage.QueryProducer

Parameters:

criteriaQuery - The CriteriaQuery

Returns:

The Stage.SelectionQuery instance for manipulation and execution

See Also:

• EntityManager.createQuery(String)

createQuery

public <R> Stage.MutationQuery createQuery(jakarta.persistence.criteria.CriteriaUpdate<R> criteriaUpdate)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.MutationQuery for the given criteria update.

Specified by:

createQuery in interface Stage.QueryProducer

Parameters:

criteriaUpdate - The CriteriaUpdate

Returns:

The Stage.MutationQuery instance for manipulation and execution

createQuery

public <R> Stage.MutationQuery createQuery(jakarta.persistence.criteria.CriteriaDelete<R> criteriaDelete)

Description copied from interface: Stage.QueryProducer

Create an instance of Stage.MutationQuery for the given criteria delete.

Specified by:

createQuery in interface Stage.QueryProducer

Parameters:

criteriaDelete - The CriteriaDelete

Returns:

The Stage.MutationQuery instance for manipulation and execution

getResultSetMapping

public <T> ResultSetMapping<T> getResultSetMapping(Class<T> resultType,
 String mappingName)

Description copied from interface: Stage.QueryProducer

Obtain a native SQL result set mapping defined via the annotation SqlResultSetMapping.

Specified by:

getResultSetMapping in interface Stage.QueryProducer

getEntityGraph

public <T> jakarta.persistence.EntityGraph<T> getEntityGraph(Class<T> rootType,
 String graphName)

Description copied from interface: Stage.QueryProducer

Obtain a named EntityGraph

Specified by:

getEntityGraph in interface Stage.QueryProducer

createEntityGraph

public <T> jakarta.persistence.EntityGraph<T> createEntityGraph(Class<T> rootType)

Description copied from interface: Stage.QueryProducer

Create a new mutable EntityGraph

Specified by:

createEntityGraph in interface Stage.QueryProducer

createEntityGraph

public <T> jakarta.persistence.EntityGraph<T> createEntityGraph(Class<T> rootType,
 String graphName)

Description copied from interface: Stage.QueryProducer

Create a new mutable copy of a named EntityGraph

Specified by:

createEntityGraph in interface Stage.QueryProducer