Package org.hibernate.reactive.mutiny.impl

Class MutinySessionFactoryImpl

java.lang.Object

org.hibernate.reactive.mutiny.impl.MutinySessionFactoryImpl

All Implemented Interfaces:

AutoCloseable, Implementor, Mutiny.SessionFactory

public class MutinySessionFactoryImpl
extends Object
implements Mutiny.SessionFactory, Implementor

Implementation of Mutiny.SessionFactory.

Obtained by calling EntityManagerFactory.unwrap(Class).

Constructor Summary

Constructors

Constructor	Description
MutinySessionFactoryImpl(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()
Mutiny.Session	getCurrentSession()	Return the current instance of Mutiny.Session, if any.
Mutiny.StatelessSession	getCurrentStatelessSession()	Return the current instance of Mutiny.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()
io.smallrye.mutiny.Uni<Mutiny.Session>	openSession()	Obtain a new reactive session Uni, the main interaction point between the user's program and Hibernate Reactive.
io.smallrye.mutiny.Uni<Mutiny.Session>	openSession(String tenantId)	Obtain a new reactive session Uni for a specified tenant.
io.smallrye.mutiny.Uni<Mutiny.StatelessSession>	openStatelessSession()	Obtain a reactive stateless session Uni.
io.smallrye.mutiny.Uni<Mutiny.StatelessSession>	openStatelessSession(String tenantId)	Obtain a reactive stateless session Uni.
<T> io.smallrye.mutiny.Uni<T>	withSession(String tenantId, Function<Mutiny.Session,io.smallrye.mutiny.Uni<T>> work)	Perform work using a reactive session for a specified tenant.
<T> io.smallrye.mutiny.Uni<T>	withSession(Function<Mutiny.Session,io.smallrye.mutiny.Uni<T>> work)	Perform work using a reactive session.
<T> io.smallrye.mutiny.Uni<T>	withStatelessSession(String tenantId, Function<Mutiny.StatelessSession,io.smallrye.mutiny.Uni<T>> work)	Perform work using a stateless session.
<T> io.smallrye.mutiny.Uni<T>	withStatelessSession(Function<Mutiny.StatelessSession,io.smallrye.mutiny.Uni<T>> work)	Perform work using a stateless session.
<T> io.smallrye.mutiny.Uni<T>	withStatelessTransaction(String tenantId, BiFunction<Mutiny.StatelessSession,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)	Perform work using a reactive session for the tenant with the specified tenant id within an associated transaction.
<T> io.smallrye.mutiny.Uni<T>	withStatelessTransaction(BiFunction<Mutiny.StatelessSession,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)	Perform work using a reactive session within an associated transaction.
<T> io.smallrye.mutiny.Uni<T>	withTransaction(String tenantId, BiFunction<Mutiny.Session,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)	Perform work using a reactive session for the tenant with the specified tenant id within an associated transaction.
<T> io.smallrye.mutiny.Uni<T>	withTransaction(BiFunction<Mutiny.Session,Mutiny.Transaction,io.smallrye.mutiny.Uni<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.mutiny.Mutiny.SessionFactory

withStatelessTransaction, withTransaction

Constructor Details

MutinySessionFactoryImpl

public MutinySessionFactoryImpl(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 io.smallrye.mutiny.Uni<Mutiny.Session> openSession()

Description copied from interface: Mutiny.SessionFactory

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

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

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

Specified by:

openSession in interface Mutiny.SessionFactory

See Also:

• Mutiny.SessionFactory.withSession(Function)

openSession

public io.smallrye.mutiny.Uni<Mutiny.Session> openSession(String tenantId)

Description copied from interface: Mutiny.SessionFactory

Obtain a new reactive session Uni for a specified tenant.

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

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

Specified by:

openSession in interface Mutiny.SessionFactory

Parameters:

tenantId - the id of the tenant

See Also:

• Mutiny.SessionFactory.withSession(Function)

openStatelessSession

public io.smallrye.mutiny.Uni<Mutiny.StatelessSession> openStatelessSession()

Description copied from interface: Mutiny.SessionFactory

Obtain a reactive stateless session Uni.

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

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

Specified by:

openStatelessSession in interface Mutiny.SessionFactory

See Also:

• Mutiny.SessionFactory.withStatelessSession(Function)

openStatelessSession

public io.smallrye.mutiny.Uni<Mutiny.StatelessSession> openStatelessSession(String tenantId)

Description copied from interface: Mutiny.SessionFactory

Obtain a reactive stateless session Uni.

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

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

Specified by:

openStatelessSession in interface Mutiny.SessionFactory

Parameters:

tenantId - the id of the tenant

See Also:

• Mutiny.SessionFactory.withStatelessSession(String, Function)

getCurrentSession

public Mutiny.Session getCurrentSession()

Description copied from interface: Mutiny.SessionFactory

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

Specified by:

getCurrentSession in interface Mutiny.SessionFactory

Returns:

the current instance, if any, or null

getCurrentStatelessSession

public Mutiny.StatelessSession getCurrentStatelessSession()

Description copied from interface: Mutiny.SessionFactory

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

Specified by:

getCurrentStatelessSession in interface Mutiny.SessionFactory

Returns:

the current instance, if any, or null

withSession

public <T> io.smallrye.mutiny.Uni<T> withSession(Function<Mutiny.Session,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.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 Mutiny.SessionFactory

Parameters:

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

withSession

public <T> io.smallrye.mutiny.Uni<T> withSession(String tenantId,
 Function<Mutiny.Session,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.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 Mutiny.SessionFactory

Parameters:

tenantId - the id of the tenant

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

withStatelessSession

public <T> io.smallrye.mutiny.Uni<T> withStatelessSession(Function<Mutiny.StatelessSession,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.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 Mutiny.SessionFactory

Parameters:

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

withStatelessSession

public <T> io.smallrye.mutiny.Uni<T> withStatelessSession(String tenantId,
 Function<Mutiny.StatelessSession,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.SessionFactory

Perform work using a stateless session.

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.

Specified by:

withStatelessSession in interface Mutiny.SessionFactory

Parameters:

tenantId - the id of the tenant

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

withTransaction

public <T> io.smallrye.mutiny.Uni<T> withTransaction(BiFunction<Mutiny.Session,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.SessionFactory

Perform work using a reactive session within an associated transaction.

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 flushed and closed automatically, and the transaction committed automatically.

Specified by:

withTransaction in interface Mutiny.SessionFactory

Parameters:

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

See Also:

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

withStatelessTransaction

public <T> io.smallrye.mutiny.Uni<T> withStatelessTransaction(BiFunction<Mutiny.StatelessSession,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.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 Mutiny.SessionFactory

Parameters:

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

See Also:

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

withTransaction

public <T> io.smallrye.mutiny.Uni<T> withTransaction(String tenantId,
 BiFunction<Mutiny.Session,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.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 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 Mutiny.SessionFactory

Parameters:

tenantId - the id of the tenant

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

See Also:

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

withStatelessTransaction

public <T> io.smallrye.mutiny.Uni<T> withStatelessTransaction(String tenantId,
 BiFunction<Mutiny.StatelessSession,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work)

Description copied from interface: Mutiny.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 Mutiny.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 Uni.

See Also:

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

getCriteriaBuilder

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

Specified by:

getCriteriaBuilder in interface Mutiny.SessionFactory

Returns:

an instance of CriteriaBuilder for creating criteria queries.

getMetamodel

public jakarta.persistence.metamodel.Metamodel getMetamodel()

Description copied from interface: Mutiny.SessionFactory

Obtain the JPA Metamodel for the persistence unit.

Specified by:

getMetamodel in interface Mutiny.SessionFactory

getCache

public org.hibernate.Cache getCache()

Description copied from interface: Mutiny.SessionFactory

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

Specified by:

getCache in interface Mutiny.SessionFactory

getStatistics

public org.hibernate.stat.Statistics getStatistics()

Description copied from interface: Mutiny.SessionFactory

Obtain the Statistics object exposing factory-level metrics.

Specified by:

getStatistics in interface Mutiny.SessionFactory

close

public void close()

Description copied from interface: Mutiny.SessionFactory

Destroy the session factory and clean up its connection pool.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Mutiny.SessionFactory

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Mutiny.SessionFactory

Returns:

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