org.hibernate.testing.transaction

Class TransactionUtil

java.lang.Object

org.hibernate.testing.transaction.TransactionUtil

public class TransactionUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TransactionUtil.HibernateTransactionConsumer Hibernate transaction function without return value
static interface	TransactionUtil.HibernateTransactionFunction<T> Hibernate transaction function
static interface	TransactionUtil.JDBCTransactionFunction<T> JDBC transaction function
static interface	TransactionUtil.JDBCTransactionVoidFunction JDBC transaction function without return value
static interface	TransactionUtil.JPATransactionFunction<T> JPA transaction function
static interface	TransactionUtil.JPATransactionVoidFunction JPA transaction function without return value

Constructor Summary

Constructors

Constructor and Description
TransactionUtil()

Method Summary

Modifier and Type	Method and Description
static void	doInAutoCommit(Consumer<Statement> consumer) Use the default settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode.
static void	doInAutoCommit(Consumer<Statement> consumer, Map settings) Use the supplied settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode.
static void	doInAutoCommit(Map settings, String... statements) Use the supplied settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode.
static void	doInAutoCommit(String... statements) Use the default settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode.
static void	doInHibernate(Supplier<SessionFactory> factorySupplier, Consumer<Session> function)
static void	doInHibernate(Supplier<SessionFactory> factorySupplier, String tenant, Consumer<Session> function) Execute function in a Hibernate transaction without return value and for a given tenant
static <R> R	doInHibernate(Supplier<SessionFactory> factorySupplier, String tenant, Function<Session,R> function) Execute function in a Hibernate transaction for a given tenant and return a value
static void	doInHibernate(Supplier<SessionFactory> factorySupplier, TransactionUtil.HibernateTransactionConsumer function) Execute function in a Hibernate transaction without return value
static <T> T	doInHibernate(Supplier<SessionFactory> factorySupplier, TransactionUtil.HibernateTransactionFunction<T> function) Execute function in a Hibernate transaction
static void	doInHibernateSessionBuilder(Supplier<SessionBuilder> sessionBuilderSupplier, TransactionUtil.HibernateTransactionConsumer function) Execute function in a Hibernate transaction without return value
static <T> T	doInHibernateSessionBuilder(Supplier<SessionBuilder> sessionBuilderSupplier, TransactionUtil.HibernateTransactionFunction<T> function) Execute function in a Hibernate transaction
static <T> T	doInJPA(Supplier<EntityManagerFactory> factorySupplier, TransactionUtil.JPATransactionFunction<T> function) Execute function in a JPA transaction
static <T> T	doInJPA(Supplier<EntityManagerFactory> factorySupplier, TransactionUtil.JPATransactionFunction<T> function, Map properties) Execute function in a JPA transaction
static void	doInJPA(Supplier<EntityManagerFactory> factorySupplier, TransactionUtil.JPATransactionVoidFunction function) Execute function in a JPA transaction without return value
static void	doInJPA(Supplier<EntityManagerFactory> factorySupplier, TransactionUtil.JPATransactionVoidFunction function, Map properties) Execute function in a JPA transaction without return value
static <T> T	doWithJDBC(ServiceRegistry serviceRegistry, TransactionUtil.JDBCTransactionFunction<T> function)
static void	doWithJDBC(ServiceRegistry serviceRegistry, TransactionUtil.JDBCTransactionVoidFunction function)
static void	setJdbcTimeout(Session session) Set Session or Statement timeout
static void	setJdbcTimeout(Session session, long millis) Set Session or Statement timeout

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionUtil

public TransactionUtil()

Method Detail

doInHibernate

public static void doInHibernate(Supplier<SessionFactory> factorySupplier,
                                 Consumer<Session> function)

doInJPA

public static <T> T doInJPA(Supplier<EntityManagerFactory> factorySupplier,
                            TransactionUtil.JPATransactionFunction<T> function,
                            Map properties)

Execute function in a JPA transaction

Type Parameters:

T - result type

Parameters:

factorySupplier - EntityManagerFactory supplier

function - function

properties - properties for entity manager bootstrapping

Returns:

result

doInJPA

public static <T> T doInJPA(Supplier<EntityManagerFactory> factorySupplier,
                            TransactionUtil.JPATransactionFunction<T> function)

Execute function in a JPA transaction

Type Parameters:

T - result type

Parameters:

factorySupplier - EntityManagerFactory supplier

function - function

Returns:

result

doInJPA

public static void doInJPA(Supplier<EntityManagerFactory> factorySupplier,
                           TransactionUtil.JPATransactionVoidFunction function,
                           Map properties)

Execute function in a JPA transaction without return value

Parameters:

factorySupplier - EntityManagerFactory supplier

function - function

properties - properties for entity manager bootstrapping

doInJPA

public static void doInJPA(Supplier<EntityManagerFactory> factorySupplier,
                           TransactionUtil.JPATransactionVoidFunction function)

Execute function in a JPA transaction without return value

Parameters:

factorySupplier - EntityManagerFactory supplier

function - function

doInHibernate

public static <T> T doInHibernate(Supplier<SessionFactory> factorySupplier,
                                  TransactionUtil.HibernateTransactionFunction<T> function)

Execute function in a Hibernate transaction

Type Parameters:

T - result type

Parameters:

factorySupplier - SessionFactory supplier

function - function

Returns:

result

doInHibernate

public static void doInHibernate(Supplier<SessionFactory> factorySupplier,
                                 TransactionUtil.HibernateTransactionConsumer function)

Execute function in a Hibernate transaction without return value

Parameters:

factorySupplier - SessionFactory supplier

function - function

doInHibernate

public static void doInHibernate(Supplier<SessionFactory> factorySupplier,
                                 String tenant,
                                 Consumer<Session> function)

Execute function in a Hibernate transaction without return value and for a given tenant

Parameters:

factorySupplier - SessionFactory supplier

tenant - tenant

function - function

doInHibernate

public static <R> R doInHibernate(Supplier<SessionFactory> factorySupplier,
                                  String tenant,
                                  Function<Session,R> function)

Execute function in a Hibernate transaction for a given tenant and return a value

Parameters:

factorySupplier - SessionFactory supplier

tenant - tenant

function - function

Returns:

result

doInHibernateSessionBuilder

public static <T> T doInHibernateSessionBuilder(Supplier<SessionBuilder> sessionBuilderSupplier,
                                                TransactionUtil.HibernateTransactionFunction<T> function)

Execute function in a Hibernate transaction

Type Parameters:

T - result type

Parameters:

sessionBuilderSupplier - SessionFactory supplier

function - function

Returns:

result

doInHibernateSessionBuilder

public static void doInHibernateSessionBuilder(Supplier<SessionBuilder> sessionBuilderSupplier,
                                               TransactionUtil.HibernateTransactionConsumer function)

Execute function in a Hibernate transaction without return value

Parameters:

sessionBuilderSupplier - SessionFactory supplier

function - function

setJdbcTimeout

public static void setJdbcTimeout(Session session)

Set Session or Statement timeout

Parameters:

session - Hibernate Session

setJdbcTimeout

public static void setJdbcTimeout(Session session,
                                  long millis)

Set Session or Statement timeout

Parameters:

session - Hibernate Session

doInAutoCommit

public static void doInAutoCommit(Consumer<Statement> consumer,
                                  Map settings)

Use the supplied settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode. A new JDBC Statement is created and passed to the supplied callback.

Parameters:

consumer - Statement callback to execute statements in auto-commit mode

settings - Settings to build a new ServiceRegistry

doInAutoCommit

public static void doInAutoCommit(Consumer<Statement> consumer)

Use the default settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode. A new JDBC Statement is created and passed to the supplied callback.

Parameters:

consumer - Statement callback to execute statements in auto-commit mode

doInAutoCommit

public static void doInAutoCommit(Map settings,
                                  String... statements)

Use the supplied settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode. The supplied statements will be executed using the previously created connection

Parameters:

settings - Settings to build a new ServiceRegistry

statements - statements to be executed in auto-commit mode

doInAutoCommit

public static void doInAutoCommit(String... statements)

Use the default settings for building a new ServiceRegistry and create a new JDBC Connection in auto-commit mode. The supplied statements will be executed using the previously created connection

Parameters:

statements - statements to be executed in auto-commit mode

doWithJDBC

public static void doWithJDBC(ServiceRegistry serviceRegistry,
                              TransactionUtil.JDBCTransactionVoidFunction function)
                       throws SQLException

Throws:

SQLException

doWithJDBC

public static <T> T doWithJDBC(ServiceRegistry serviceRegistry,
                               TransactionUtil.JDBCTransactionFunction<T> function)
                        throws SQLException

Throws:

SQLException