xyz.zhouxy.jdbc

Class TransactionTemplate

java.lang.Object

xyz.zhouxy.jdbc.TransactionTemplate

public class TransactionTemplate
extends Object

事务模板，提供事务执行能力。

负责管理事务的生命周期：开启、提交、回滚、恢复自动提交。 事务内的 JDBC 操作通过 JdbcOperations 接口进行， 所有操作共享同一个数据库连接。

使用示例：

 TransactionTemplate tx = new TransactionTemplate(dataSource);

 // 消费者模式：无异常自动提交
 tx.execute(ops -> {
     ops.update("INSERT INTO ...", buildParams(...));
     ops.update("UPDATE ...", buildParams(...));
 });

 // 谓词模式：返回 true 提交，false 回滚
 tx.commitIfTrue(ops -> {
     ops.update("UPDATE ...", buildParams(...));
     return ops.queryBoolean("SELECT ...", buildParams(...));
 });
 

Since:

1.1.0

Author:

ZhouXY

Constructor Summary

Constructors

Constructor and Description
TransactionTemplate(DataSource dataSource) 构造一个 TransactionTemplate 实例

Method Summary

Modifier and Type	Method and Description
<E extends Exception> void	commitIfTrue(ThrowingPredicate<JdbcOperations,E> operations) 执行事务。
<E extends Exception> void	execute(ThrowingConsumer<JdbcOperations,E> operations) 执行事务。

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionTemplate

public TransactionTemplate(DataSource dataSource)

构造一个 TransactionTemplate 实例

Parameters:

dataSource - 数据源，用于获取数据库连接；不可为 null

Method Detail

execute

public <E extends Exception> void execute(@Nonnull
                                          ThrowingConsumer<JdbcOperations,E> operations)
                                   throws TransactionException,
                                          SQLException

执行事务。如果未发生异常，则提交事务；当有异常发生时，回滚事务

operations 中使用 JdbcExecutor 实参进行 JDBC 操作，这些操作在一个连接中

Type Parameters:

E - 异常类型

Parameters:

operations - 事务操作

Throws:

SQLException - SQL 异常

TransactionException - 事务异常。事务中的异常会包装在该异常中。

commitIfTrue

public <E extends Exception> void commitIfTrue(@Nonnull
                                               ThrowingPredicate<JdbcOperations,E> operations)
                                        throws SQLException,
                                               TransactionException

执行事务。 如果 operations 返回 true，则提交事务； 如果抛出异常，或返回 false，则回滚事务

Type Parameters:

E - 事务中的异常

Parameters:

operations - 事务操作

Throws:

SQLException - 数据库异常

TransactionException - 事务异常。事务中的异常会包装在该异常中。