Spring JDBC 事务

一、项目背景与技术选型

在企业级应用开发中，涉及资金操作的场景必须保证数据的一致性和完整性，事务管理是实现这一目标的核心机制。本文将通过一个基于 Spring 框架的支付宝转账功能案例，详细解析如何使用 Spring 的事务管理（包括 XML 配置和注解配置）确保转账操作的原子性，并提供完整的代码实现与优化建议。

二、项目结构与核心配置文件

2.1 Spring.xml配置解析

2.1.1 数据源配置

<!-- 配置数据库连接池 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/> <!-- MySQL 8+驱动类 -->
    <property name="url" value="jdbc:mysql://localhost:3306/test1?useUnicode=true&amp;characterEncoding=UTF-8&amp;serverTimezone=UTC"/>
    <property name="username" value="root"/>
    <property name="password" value="root"/>
</bean>

• 说明：使用DriverManagerDataSource创建基础数据源，连接 MySQL 8.0 + 数据库时需注意驱动类改为com.mysql.cj.jdbc.Driver，并添加时区参数serverTimezone=UTC避免时间解析异常。

2.1.2 JdbcTemplate 配置

<!-- 配置Spring JDBC操作模板 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource"/>
</bean>

• 作用：通过依赖注入数据源，简化 JDBC 操作，提供update()、query()等便捷方法。

2.1.3 事务管理器配置

<!-- 定义事务管理器，基于数据源 -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>

• 核心逻辑：Spring 通过DataSourceTransactionManager管理数据库事务，确保事务与数据源绑定。

  2.1.4 事务通知配置

<tx:advice id="txAdvice" transaction-manager="txManager">
    <tx:attributes>
        <tx:method name="*" propagation="REQUIRED" isolation="DEFAULT" read-only="false" />
    </tx:attributes>
</tx:advice>

定义了一个事务通知，所有方法默认使用 REQUIRED 传播行为，即如果当前没有事务，就创建一个新事务；如果已经存在一个事务，则加入这个事务。

 标签结构与核心参数

• <tx:advice>：定义一个事务通知，相当于一个拦截器，会在目标方法执行前后添加事务管理逻辑。

  • id="txAdvice"：为这个通知指定唯一标识，后续会通过这个 ID 将通知应用到具体方法。
  • transaction-manager="txManager"：引用之前配置的事务管理器（如 DataSourceTransactionManager），用于实际管理事务。

• <tx:attributes>：配置事务属性的容器，内部可定义多个 <tx:method> 规则。

• <tx:method>：定义具体的事务规则，支持通配符匹配方法名。

  • name="*"：匹配所有方法名（* 是通配符）。
  • propagation="REQUIRED"：传播行为设置为 REQUIRED，表示 “如果当前没有事务，就创建一个新事务；如果已有事务，就加入该事务”。这是最常用的传播行为，确保方法在事务环境中执行。
  • isolation="DEFAULT"：隔离级别使用数据库的默认设置（如 MySQL 默认是 REPEATABLE READ）。
  • read-only="false"：声明该方法不是只读操作，可能会修改数据。

2.1.5 AOP 配置

<aop:config>
    <aop:pointcut id="txPointcut"
                  expression="execution(public void com.qcby.dao.DaoImpl.AliPayDaoImpl.transfer(..))"/>
    <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointcut" />
</aop:config>

定义了一个切入点，匹配AliPayDaoImpl类中的transfer方法，并将上面定义的事务通知应用到这个切入点。这意味着transfer方法将被事务管理。

三、事务配置的两种方式对比

3.1 XML 方式配置事务（AOP 切面）

<!-- 事务通知（Advice）：定义事务属性 -->
<tx:advice id="txAdvice" transaction-manager="txManager">
    <tx:attributes>
        <!-- 所有方法应用事务，传播行为为REQUIRED -->
        <tx:method name="*" propagation="REQUIRED" isolation="DEFAULT" read-only="false"/>
    </tx:attributes>
</tx:advice>

<!-- AOP配置：将事务通知织入指定方法 -->
<aop:config>
    <aop:pointcut id="txPointcut" 
                  expression="execution(public void com.qcby.dao.DaoImpl.AliPayDaoImpl.transfer(..))"/>
    <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointcut"/>
</aop:config>

• 关键步骤：
  1. 定义txAdvice事务通知，指定事务管理器和默认属性（如传播行为REQUIRED表示 “必须在事务中执行，若无则创建新事务”）。
  2. 通过 AOP 的pointcut匹配transfer()方法，使用advisor将事务通知与切入点绑定。

3.2 注解方式配置事务（推荐）

3.2.1 启用注解驱动

在Spring.xml中添加：

<!-- 启用@Transactional注解驱动 -->
<tx:annotation-driven transaction-manager="txManager"/>

3.2.2 在方法上添加注解

@Override
@Transactional(
    propagation = Propagation.REQUIRED, 
    isolation = Isolation.DEFAULT, 
    rollbackFor = Exception.class // 自定义回滚异常
)
public void transfer(String fromA, String toB, int amount) {
    jdbcTemplate.update("update alipay set amount = amount-? where aliname = ?", amount, fromA);
    jdbcTemplate.update("update alipay set amount = amount+? where aliname = ?", amount, toB);
}

• 优势：代码侵入性低，逻辑更清晰，推荐优先使用注解方式。

四、代码实现与测试

4.1 DAO 接口与实现类

4.1.1 接口定义

// AlipayDao.java
public interface AlipayDao {
    void transfer(String fromA, String toB, int amount); // 转账方法
}

4.1.2 实现类（含事务注解）

// AliPayDaoImpl.java
public class AliPayDaoImpl implements AlipayDao {
    private JdbcTemplate jdbcTemplate;

    // 依赖注入
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    @Override
    @Transactional // 使用默认事务属性
    public void transfer(String fromA, String toB, int amount) {
        // 扣减转出方余额
        jdbcTemplate.update("UPDATE alipay SET amount = amount - ? WHERE aliname = ?", amount, fromA);
        // 模拟异常（取消注释可测试事务回滚）
        // int i = 10 / 0; 
        // 增加转入方余额
        jdbcTemplate.update("UPDATE alipay SET amount = amount + ? WHERE aliname = ?", amount, toB);
    }
}

4.2 测试类（JUnit）

// SpringTest.java
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class SpringTest {
    @Test
    public void testTransfer() {
        ApplicationContext ctx = new ClassPathXmlApplicationContext("Spring.xml");
        AlipayDao alipayDao = ctx.getBean("AliPayDaoImpl", AlipayDao.class);
        alipayDao.transfer("张三", "李四", 100); // 执行转账
        System.out.println("转账完成");
    }
}