org.hibernate.reactive.mutiny

Interface Mutiny.SessionFactory

All Superinterfaces:

AutoCloseable

Enclosing interface:

Mutiny

public static interface Mutiny.SessionFactory
extends AutoCloseable

Factory for reactive sessions.

A Mutiny.SessionFactory may be obtained from an instance of EntityManagerFactory as follows:

 Mutiny.SessionFactory sessionFactory =
                        createEntityManagerFactory("example")
                                .unwrap(Mutiny.SessionFactory.class);
 

Here, configuration properties must be specified in persistence.xml.

Alternatively, a Mutiny.SessionFactory may be obtained via programmatic configuration of Hibernate using:

 Configuration configuration = new Configuration();
 ...
 Mutiny.SessionFactory sessionFactory =
                configuration.buildSessionFactory(
                        new ReactiveServiceRegistryBuilder()
                                .applySettings( configuration.getProperties() )
                                .build()
                )
                .unwrap(Mutiny.SessionFactory.class);
 

Method Summary

Modifier and Type	Method and 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.
CriteriaBuilder	getCriteriaBuilder()
Metamodel	getMetamodel() Obtain the JPA Metamodel for the persistence unit.
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(Function<Mutiny.Session,io.smallrye.mutiny.Uni<T>> work) Perform work using a reactive session.
<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>	withStatelessSession(Function<Mutiny.StatelessSession,io.smallrye.mutiny.Uni<T>> work) Perform work using a stateless 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>	withStatelessTransaction(BiFunction<Mutiny.StatelessSession,Mutiny.Transaction,io.smallrye.mutiny.Uni<T>> work) Perform work using a reactive session within an associated transaction.
default <T> io.smallrye.mutiny.Uni<T>	withStatelessTransaction(Function<Mutiny.StatelessSession,io.smallrye.mutiny.Uni<T>> work) Perform work using a reactive session within an associated transaction.
<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 a specified tenant 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.
default <T> io.smallrye.mutiny.Uni<T>	withTransaction(Function<Mutiny.Session,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 a specified tenant within an associated transaction.

Method Detail

openSession

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.

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

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

See Also:

withSession(Function)

openSession

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

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().

Parameters:

tenantId - the id of the tenant

See Also:

withSession(Function)

openStatelessSession

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

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().

See Also:

withStatelessSession(Function)

openStatelessSession

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

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().

Parameters:

tenantId - the id of the tenant

See Also:

withStatelessSession(String, Function)

withSession

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

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.

Parameters:

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

withSession

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

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.