Package org.hibernate.reactive.stage.impl

Class StageSessionFactoryImpl

java.lang.Object

org.hibernate.reactive.stage.impl.StageSessionFactoryImpl

All Implemented Interfaces:

AutoCloseable, Implementor, Stage.SessionFactory

public class StageSessionFactoryImpl
extends Object
implements Stage.SessionFactory, Implementor

Implementation of Stage.SessionFactory.

Obtained by calling EntityManagerFactory.unwrap(Class).

Constructor Summary

Constructors

Constructor	Description
StageSessionFactoryImpl(org.hibernate.internal.SessionFactoryImpl delegate)

Method Summary

Modifier and Type	Method	Description
void	close()	Destroy the session factory and clean up its connection pool.
org.hibernate.Cache	getCache()	Obtain the Cache object for managing the second-level cache.
Context	getContext()
org.hibernate.query.criteria.HibernateCriteriaBuilder	getCriteriaBuilder()
Stage.Session	getCurrentSession()	Return the current instance of Stage.Session, if any.
Stage.StatelessSession	getCurrentStatelessSession()	Return the current instance of Stage.Session, if any.
jakarta.persistence.metamodel.Metamodel	getMetamodel()	Obtain the JPA Metamodel for the persistence unit.
org.hibernate.service.ServiceRegistry	getServiceRegistry()
org.hibernate.stat.Statistics	getStatistics()	Obtain the Statistics object exposing factory-level metrics.
String	getUuid()
boolean	isOpen()
CompletionStage<Stage.Session>	openSession()	Obtain a new reactive session CompletionStage, the main interaction point between the user's program and Hibernate Reactive.
CompletionStage<Stage.Session>	openSession(String tenantId)	Obtain a new reactive session CompletionStage for a specified tenant.
CompletionStage<Stage.StatelessSession>	openStatelessSession()	Obtain a reactive stateless session CompletionStage.
CompletionStage<Stage.StatelessSession>	openStatelessSession(String tenantId)	Obtain a reactive stateless session CompletionStage.
<T> CompletionStage<T>	withSession(String tenantId, Function<Stage.Session,CompletionStage<T>> work)	Perform work using a reactive session for a specified tenant.
<T> CompletionStage<T>	withSession(Function<Stage.Session,CompletionStage<T>> work)	Perform work using a reactive session.
<T> CompletionStage<T>	withStatelessSession(String tenantId, Function<Stage.StatelessSession,CompletionStage<T>> work)	Perform work using a stateless session.
<T> CompletionStage<T>	withStatelessSession(Function<Stage.StatelessSession,CompletionStage<T>> work)	Perform work using a stateless session.
<T> CompletionStage<T>	withStatelessTransaction(String tenantId, BiFunction<Stage.StatelessSession,Stage.Transaction,CompletionStage<T>> work)	Perform work using a reactive session for the tenant with the specified tenant id within an associated transaction.
<T> CompletionStage<T>	withStatelessTransaction(BiFunction<Stage.StatelessSession,Stage.Transaction,CompletionStage<T>> work)	Perform work using a reactive session within an associated transaction.
<T> CompletionStage<T>	withTransaction(String tenantId, BiFunction<Stage.Session,Stage.Transaction,CompletionStage<T>> work)	Perform work using a reactive session for the tenant with the specified tenant id within an associated transaction.
<T> CompletionStage<T>	withTransaction(BiFunction<Stage.Session,Stage.Transaction,CompletionStage<T>> work)	Perform work using a reactive session within an associated transaction.

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.SessionFactory

withStatelessTransaction, withTransaction

Constructor Details

StageSessionFactoryImpl

public StageSessionFactoryImpl(org.hibernate.internal.SessionFactoryImpl delegate)

Method Details

getUuid

public String getUuid()

Specified by:

getUuid in interface Implementor

getServiceRegistry

public org.hibernate.service.ServiceRegistry getServiceRegistry()

Specified by:

getServiceRegistry in interface Implementor

getContext

public Context getContext()

Specified by:

getContext in interface Implementor

openSession

public CompletionStage<Stage.Session> openSession()

Description copied from interface: Stage.SessionFactory

Obtain a new reactive session CompletionStage, the main interaction point between the user's program and Hibernate Reactive.

When the CompletionStage completes successfully it returns a newly created session.

The client must explicitly close the session by calling Stage.Closeable.close().

Specified by:

openSession in interface Stage.SessionFactory

See Also:

• Stage.SessionFactory.withSession(Function)

openSession

public CompletionStage<Stage.Session> openSession(String tenantId)

Description copied from interface: Stage.SessionFactory

Obtain a new reactive session CompletionStage for a specified tenant.

When the CompletionStage completes successfully it returns a newly created session.

The client must explicitly close the session by calling Stage.Closeable.close().

Specified by:

openSession in interface Stage.SessionFactory

Parameters:

tenantId - the id of the tenant

See Also:

• Stage.SessionFactory.withSession(Function)

openStatelessSession

public CompletionStage<Stage.StatelessSession> openStatelessSession()

Description copied from interface: Stage.SessionFactory

Obtain a reactive stateless session CompletionStage.

When the CompletionStage completes successfully it returns a newly created session.

The client must explicitly close the session by calling Stage.StatelessSession.close().

Specified by:

openStatelessSession in interface Stage.SessionFactory

openStatelessSession

public CompletionStage<Stage.StatelessSession> openStatelessSession(String tenantId)

Description copied from interface: Stage.SessionFactory

Obtain a reactive stateless session CompletionStage.

When the CompletionStage completes successfully it returns a newly created session.

The client must explicitly close the session by calling Stage.StatelessSession.close().

Specified by:

openStatelessSession in interface Stage.SessionFactory

Parameters:

tenantId - the id of the tenant

getCurrentSession

public Stage.Session getCurrentSession()

Description copied from interface: Stage.SessionFactory

Return the current instance of Stage.Session, if any. A current session exists only when this method is called from within an invocation of Stage.SessionFactory.withSession(Function) or Stage.SessionFactory.withTransaction(Function).

Specified by:

getCurrentSession in interface Stage.SessionFactory

Returns:

the current instance, if any, or null

getCurrentStatelessSession

public Stage.StatelessSession getCurrentStatelessSession()

Description copied from interface: Stage.SessionFactory

Return the current instance of Stage.Session, if any. A current session exists only when this method is called from within an invocation of Stage.SessionFactory.withStatelessSession(Function) or Stage.SessionFactory.withStatelessTransaction(Function).

Specified by:

getCurrentStatelessSession in interface Stage.SessionFactory

Returns:

the current instance, if any, or null

withSession

public <T> CompletionStage<T> withSession(Function<Stage.Session,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a reactive session.

If there is already a session associated with the current reactive stream, then the work will be executed using that session.

Otherwise, if there is no session associated with the current stream, a new session will be created.

The session will be closed automatically, but must be flushed explicitly if necessary.

Specified by:

withSession in interface Stage.SessionFactory

Parameters:

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

withSession

public <T> CompletionStage<T> withSession(String tenantId,
 Function<Stage.Session,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a reactive session for a specified tenant.

If there is already a session associated with the current reactive stream, and the given tenant, then the work will be executed using that session.

Otherwise, a new session will be created.

The session will be closed automatically, but must be flushed explicitly if necessary.

Specified by:

withSession in interface Stage.SessionFactory

Parameters:

tenantId - the id of the tenant

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

withStatelessSession

public <T> CompletionStage<T> withStatelessSession(Function<Stage.StatelessSession,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a stateless session.

If there is already a stateless session associated with the current reactive stream, then the work will be executed using that session.

Otherwise, if there is no stateless session associated with the current stream, a new stateless session will be created.

The session will be closed automatically.

Specified by:

withStatelessSession in interface Stage.SessionFactory

Parameters:

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

withStatelessSession

public <T> CompletionStage<T> withStatelessSession(String tenantId,
 Function<Stage.StatelessSession,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a stateless session.

If there is already a stateless session associated with the current reactive stream, then the work will be executed using that session.

Otherwise, if there is no stateless session associated with the current stream, a new stateless session will be created.

The session will be closed automatically.

Specified by:

withStatelessSession in interface Stage.SessionFactory

Parameters:

tenantId - the id of the tenant

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

withTransaction

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

Description copied from interface: Stage.SessionFactory

Perform work using a reactive session within an associated transaction.

If there is already a stateless session associated with the current reactive stream, then the work will be executed using that session.

Otherwise, if there is no stateless session associated with the current stream, a new stateless session will be created.

The session will be flushed and closed automatically, and the transaction committed automatically.

Specified by:

withTransaction in interface Stage.SessionFactory

Parameters:

work - a function which accepts the session and transaction and returns the result of the work as a CompletionStage.

See Also:

• Stage.SessionFactory.withSession(Function)
• Stage.Session.withTransaction(Function)

withStatelessTransaction

public <T> CompletionStage<T> withStatelessTransaction(BiFunction<Stage.StatelessSession,Stage.Transaction,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a reactive session within an associated transaction.

If there is already a stateless session associated with the current reactive stream, then the work will be executed using that session.

Otherwise, if there is no stateless session associated with the current stream, a new stateless session will be created.

The session will be closed automatically, and the transaction committed automatically.

Specified by:

withStatelessTransaction in interface Stage.SessionFactory

Parameters:

work - a function which accepts the stateless session and returns the result of the work as a CompletionStage.

See Also:

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

withTransaction

public <T> CompletionStage<T> withTransaction(String tenantId,
 BiFunction<Stage.Session,Stage.Transaction,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a reactive session for the tenant with the specified tenant id within an associated transaction.

If there is already a session associated with the current reactive stream and given tenant id, then the work will be executed using that session.

Otherwise, if there is no stateless session associated with the current stream and given tenant id, a new stateless session will be created.

The session will be flushed and closed automatically, and the transaction committed automatically.

Specified by:

withTransaction in interface Stage.SessionFactory

Parameters:

tenantId - the id of the tenant

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

See Also:

• Stage.SessionFactory.withSession(String, Function)
• Stage.Session.withTransaction(Function)

withStatelessTransaction

public <T> CompletionStage<T> withStatelessTransaction(String tenantId,
 BiFunction<Stage.StatelessSession,Stage.Transaction,CompletionStage<T>> work)

Description copied from interface: Stage.SessionFactory

Perform work using a reactive session for the tenant with the specified tenant id within an associated transaction.

If there is already a stateless session associated with the current reactive stream and given tenant id, then the work will be executed using that session.

Otherwise, if there is no stateless session associated with the current stream and given tenant id, a new stateless session will be created.

The session will be closed automatically and the transaction committed automatically.

Specified by:

withStatelessTransaction in interface Stage.SessionFactory

Parameters:

tenantId - the id of the tenant

work - a function which accepts the stateless session and returns the result of the work as a CompletionStage.

See Also:

• Stage.SessionFactory.withStatelessSession(String, Function)
• Stage.StatelessSession.withTransaction(Function)

getMetamodel

public jakarta.persistence.metamodel.Metamodel getMetamodel()

Description copied from interface: Stage.SessionFactory

Obtain the JPA Metamodel for the persistence unit.

Specified by:

getMetamodel in interface Stage.SessionFactory

getCache

public org.hibernate.Cache getCache()

Description copied from interface: Stage.SessionFactory

Obtain the Cache object for managing the second-level cache.

Specified by:

getCache in interface Stage.SessionFactory

getStatistics

public org.hibernate.stat.Statistics getStatistics()

Description copied from interface: Stage.SessionFactory

Obtain the Statistics object exposing factory-level metrics.

Specified by:

getStatistics in interface Stage.SessionFactory

close

public void close()

Description copied from interface: Stage.SessionFactory

Destroy the session factory and clean up its connection pool.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Stage.SessionFactory

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Stage.SessionFactory

Returns:

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

getCriteriaBuilder

public org.hibernate.query.criteria.HibernateCriteriaBuilder getCriteriaBuilder()

Specified by:

getCriteriaBuilder in interface Stage.SessionFactory

Returns:

an instance of CriteriaBuilder for creating criteria queries.