Spring 的声明式事务控制

1. 前言

各位同学大家好，long time no see.

本小节，我给大家带来 Spring 对于事务的另外一种支持方式，也就是声明式事务的配置。其实声明式配置和 xml 文件的配置，孰优孰劣并不是重点。

Spring 框架设计两种模式的初衷更多是体现技术的多样性，毕竟条条大路通罗马。您说呢？所以本小节重点就看如果使用注解来对事务做支持，那么我们应该如何做，又有哪些需要注意点地方。

各位看官，随我来，不要掉队哦…

课程回顾：

老套路，首先我们回顾一下 xml 对于事务支持的实现：

1. 在 Spring 的 xml 配置文件中，使用 bean 标签初始化配置事务的管理器类 DataSourceTransactionManager；

2. 在 Spring 的 xml 配置文件中，通过 tx:advice 节点配置事务使用的通知方式，已经支持的事务级别；

3. 在 Spring 的 xml 配置文件中，通过 aop:config 节点指定切入点，说明哪些类的哪些方法需要支持事务，同时将配置的切入点和通知整合到一起。

xml 的方式回顾之后，就看我们使用注解如何替换掉上面的必要配置吧…

2. 实例演示

2.1 工程搭建

1. 创建工程

2. 引入依赖

<dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>
		<!-- Spring jdbc 使用的依赖-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
     	<dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.8.7</version>
   		 </dependency>
    </dependencies>

3. 准备代码
实体类代码

/**
 * 账户的实体类
 */
public class Account implements Serializable {
    //数据id
    private Integer id;
    //账号编码
    private String accountNum;
    //账号金额
    private Float money;
}

持久层接口代码

/**
 * 账户的持久层接口
 */
public interface IAccountDao {

    /**
     * 根据Id查询账户
     * @param accountId
     * @return
     */
    Account findAccountById(Integer accountId);

    /**
     * 保存账户
     * @param account
     */
    void saveAccount(Account account);

    /**
     * 更新账户
     * @param account
     */
    void updateAccount(Account account);


}

持久层实现类代码

/**
 * 账户的持久层实现类
 */
@Repository
public class AccountDaoImpl implements IAccountDao {
    //jdbc模板类属性
    @Autowired
    private JdbcTemplate jdbcTemplate;

    //根据id查找
    public Account findAccountById(Integer accountId) {
        List<Account> accounts = jdbcTemplate.query("select * from account where id = ?",new BeanPropertyRowMapper<Account>(Account.class),accountId);
        return accounts.isEmpty()?null:accounts.get(0);
    }

    public void saveAccount(Account account) {
        jdbcTemplate.update("insert into account  values(?,?,?)",
                account.getId(),account.getAccountNum(),account.getMoney());
    }

    public void updateAccount(Account account) {
        jdbcTemplate.update("update account set accountnum=?,money=? where id=?",account.getAccountNum(),account.getMoney(),account.getId());
    }
}

业务层接口代码

/**
 * @Auther: wyan
 */
public interface UserService {

    /**
     * 账户转账
     * @param fromId toId
     */
    public void transMoney(Integer fromId, Integer toId, Integer money);

}

业务层实现类代码

/**
 * @Auther: wyan
 * @Description:
 */
@Service
@Transactional
public class UserServiceImpl implements UserService {

    @Autowired
    private IAccountDao accountDao;

    public void transMoney(Integer fromId, Integer toId, Integer money) {
        Account fromAccount = accountDao.findAccountById(fromId);
        Account toAccount = accountDao.findAccountById(toId);
        //原始账号减钱
        fromAccount.setMoney(fromAccount.getMoney()-money);
        accountDao.updateAccount(fromAccount);
        //抛出异常
        int i=1/0;
        //转账账号加钱
        toAccount.setMoney(toAccount.getMoney()+money);
        accountDao.updateAccount(toAccount);
    }
}

Tips： 此时需要注意注解 @Transactional 的含义。

Transactional 就是表示事务，那么在此类上面加入注解，说明需要 Spring 框架针对此类的方法做事务的增强行为，也就是说此注解其实是相当于我们在配置文件中配置的节点 tx:advice。

那么这时候有的细心的同学可能会有些疑问：

1. 我们在 xml 文件中可以配置事务的传播行为与隔离级别，那么这一个注解如何制定事务的传播行为与隔离级别呢？
2. 一个类中如果定义方法过多，而实际上需要增强控制事务的方法只有一部分，如何缩小粒度，只控制需要事务的方法呢？

ok，大家。这里有必要跟大家解释下此注解的其余使用方式：

问题一答疑：

在注解后面可以通过括号内的参数设置隔离级别与传播行为。比如：

@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED) 此表达式的含义是事务一定需要，并且是读已提交。

问题二答疑:

在方法上使用注解。类上面可以不使用 @Transactional 注解，而是将注解写在需要用到事务的方法之上。

4. 配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--配置JdbcTemplate-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- 配置数据源-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
        <property name="url" value="jdbc:mysql:///transmoney"></property>
        <property name="username" value="root"></property>
        <property name="password" value="root"></property>
    </bean>
    <!--包路径扫描-->
    <context:component-scan base-package="com.offcn"></context:component-scan>
    <!--事务管理器-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!-- 配置数据源-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
        <property name="url" value="jdbc:mysql:///transmoney"></property>
        <property name="username" value="root"></property>
        <property name="password" value="root"></property>
    </bean>
    <!--包路径扫描-->
    <context:component-scan base-package="com.offcn"></context:component-scan>
    <!--事务管理器-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--注解事务驱动-->
    <tx:annotation-driven/>

</beans>

Tips: 此处需要注意 tx:annotation-driven 节点

无需配置通知节点与切面节点，而是使用 tx:annotation-driven 节点表示，事务的支持方式为声明式事务。

5. 测试代码

public class AccountServiceTest {

    public static void main(String[] args) {
        //1.获取容器
        ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
        //2.获取业务对象
        UserService userService = ac.getBean(UserService.class);
        //3.从id为1的账号转成1000到2账号
        userService.transMoney(1,2,1000);
        System.out.println("转账完成..");
    }
}

6. 测试结果：

ok, 大家，我们继续测试之前的转账代码，依然得到错误的异常信息。同时数据库的金额并没有发生改变，因为事务的控制，保证了数据的一致性原子性。那么也证明我们声明式事务的案例测试成功。

3. 总结

Spring 的声明式事务，我们今天就到这里。通过本小节，我们知道声明式事务实现一样很简单：

1. xml 文件中开启注解驱动 tx:annotation-driven;
2. 在实现类上使用 @Transactional 注解。

上面两个步骤即可实现声明式事务的控制，配置更为简洁，代码可读性也更强。你学会了吗？

如果你问我，什么是达到成功最有效的方法，我会告诉你 —— 坚持！