Spring —— 事务控制

一、前言

本文需要先学习MySQl的事务管理，下面通过几张图来进行回顾：

脏读：

解决脏读：

不可重复读：

幻读：

解决幻读：

这里罗列了几个并发事务的问题，并且通过设置事务隔离等级解决了这些问题。

本文需要使用的坐标：主要是Spring和mvc的框架坐标，几个AOP需要的坐标，几个关于数据库连接（jdbc、数据源）的坐标。

    <dependency><groupId>org.springframework</groupId><artifactId>spring-web</artifactId><version>5.1.9.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>5.1.9.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.1.9.RELEASE</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.9.24</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>5.1.9.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.1.9.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>5.1.9.RELEASE</version></dependency><dependency><groupId>c3p0</groupId><artifactId>c3p0</artifactId><version>0.9.1.2</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.32</version></dependency>

二、xml配置事务控制

1.模拟账户转账功能

我们这里通过模拟账户转账的功能来测试事务控制。

首先先创建一个domain类，用于存储每一个账户的基本信息。

public class Account {private String name;private double money;public String getName() {return name;}public void setName(String name) {this.name = name;}public double getMoney() {return money;}public void setMoney(double money) {this.money = money;}
}

这里需要设计dao层和service层，实现两个方法（转账和进账）：

dao层：

public interface AccountDao {public void out(String outMan, double money);public void in(String inMan,double money);
}

public class AccountDaoImpl implements AccountDao {private JdbcTemplate jdbcTemplate;public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}@Overridepublic void out(String outMan, double money) {jdbcTemplate.update("update account set money=money-? where name=?",money,outMan);}@Overridepublic void in(String inMan, double money) {jdbcTemplate.update("update account set money=money+? where name=?",money,inMan);}
}

service层：

public interface AccountService {public void transfer(String outMan,String inMan,double money);
}

public class AccountServiceImpl implements AccountService {private AccountDao accountDao;public void setAccountDao(AccountDao accountDao) {this.accountDao = accountDao;}@Overridepublic void transfer(String outMan, String inMan, double money) {//开启事务accountDao.out(outMan,money);accountDao.in(inMan,money);//提交事务}
}

由于使用了jdbc模板类，并且dao层和service层具备依赖关系，所以我们当然需要配置Spring的xml文件，进行依赖注入：

    <bean id="accountDao" class="com.yds.dao.impl.AccountDaoImpl"><property name="jdbcTemplate" ref="jdbcTemplate"/></bean><!--目标对象  内部的方法是切点--><bean id="accountService" class="com.yds.service.Impl.AccountServiceImpl"><property name="accountDao" ref="accountDao"/></bean><!--使用spring表达式创建数据源--><bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"><property name="driverClass" value="${jdbc.driver}"></property><property name="jdbcUrl" value="${jdbc.url}"></property><property name="user" value="${jdbc.username}"></property><property name="password" value="${jdbc.password}"></property></bean><!--jdbc模板对象--><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean>

所以我们的Controller如下（模拟tom给lucy转账500）：

public class AccountController {public static void main(String[] args) {ApplicationContext app = new ClassPathXmlApplicationContext("applicationContext.xml");AccountService accountService = app.getBean(AccountService.class);accountService.transfer("tom","lucy",500);}
}

同时我们这里创建一个表，里面设置两个字段，分别是用户和金额。

运行Controller后可以得到：

这里说明我们的转账是成功的。

但是我们并没有使用事务控制，这样会导致如果转账过程中出现异常，转出去的钱将会转不到目标账户，同时钱又转出去了，将会凭空消失，这是个大问题，我们可以通过开启事务来解决这个问题，如果遇到问题将会回滚事务，钱就不会凭空消失了，而是会回到执行转账操作前的状态了。

我们进行测试：

修改service层（在钱转出去后增加一个异常）：

public class AccountServiceImpl implements AccountService {private AccountDao accountDao;public void setAccountDao(AccountDao accountDao) {this.accountDao = accountDao;}@Overridepublic void transfer(String outMan, String inMan, double money) {//开启事务accountDao.out(outMan,money);int i = 1/0;accountDao.in(inMan,money);//提交事务}
}

执行后可以看到控制台抛出了异常：

而数据库中的500确实凭空消失了：

这样是不行的，接下来我们尝试使用事务控制来解决这个问题：

2.事务控制

首先我们要明确我们使用事务控制的方法，这里我们使用AOP，通过增强来达到开启/提交事务的效果。

首先配置平台事务管理器：

 <!--配置平台事务管理器--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean>

然后配置通切面（事务的增强）：

使用<tx:attributres>来配置事务属性（设置某个方法的隔离级别、事务传播行为，是否只读...）

<!--通知 事务的增强--><tx:advice id="txAdvice" transaction-manager="transactionManager"><!--设置事务的属性信息的--><tx:attributes><tx:method name="transfer" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/></tx:attributes></tx:advice>

最后将切面txAdvice织入：

<!--配置事务aop织入--><aop:config><aop:advisor advice-ref="txAdvice" pointcut="execution(* com.yds.service.Impl.*.*(..))"/></aop:config>

将两人的金额恢复到5000，重新测试（转账后入账前有异常）：效果如下：

三、注解配置事务控制

我们希望通过注解来简化开发，所以这里我们需要修改部分代码：

dao层注解：

@Repository("accountDao")
public class AccountDaoImpl implements AccountDao {@Autowiredprivate JdbcTemplate jdbcTemplate;@Overridepublic void out(String outMan, double money) {jdbcTemplate.update("update account set money=money-? where name=?",money,outMan);}@Overridepublic void in(String inMan, double money) {jdbcTemplate.update("update account set money=money+? where name=?",money,inMan);}
}

service层注解：

同时配置事务注解，类上的注解表示这个类中默认使用的事务属性配置，如果在类中的具体方法中设置了注解，实际属性将按照方法上的注解配置（方法的配置优先），并且不同的方法可以有不同的配置。

@Service("accountService")
@Transactional(isolation = Isolation.DEFAULT)
public class AccountServiceImpl implements AccountService {@Autowiredprivate AccountDao accountDao;@Override//如果类和方法上面都有注解，方法上的优先@Transactional(isolation = Isolation.READ_COMMITTED,propagation = Propagation.REQUIRED)public void transfer(String outMan, String inMan, double money) {//开启事务accountDao.out(outMan,money);int i = 1/0;accountDao.in(inMan,money);//提交事务}@Transactional(isolation = Isolation.DEFAULT)public void save(){}
}

但是使用注解并不代表不使用xml，我们仍然需要使用xml来配置扫描组件（当然，如果使用全注解开发，我们可以创建一个配置类，在配置类中使用不同的注解来达到同样的效果），我们这里使用xml，更加直观：

<!--    加载外部的properties文件--><context:property-placeholder location="classpath:jdbc.properties"/><!--组件扫描--><context:component-scan base-package="com.yds"/><!--事务的注解驱动--><tx:annotation-driven transaction-manager="transactionManager"/><!--配置平台事务管理器--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!--    使用spring表达式--><bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"><property name="driverClass" value="${jdbc.driver}"></property><property name="jdbcUrl" value="${jdbc.url}"></property><property name="user" value="${jdbc.username}"></property><property name="password" value="${jdbc.password}"></property></bean><!--    jdbc模板对象--><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean>

再次测试，事务会回滚：

而去掉异常，数据库依然可以通过提交事务来达到转账的功能：

注意：默认情况下，事务遇到运行期异常（RuntimeException 的子类）时才会回滚。如果需要回滚特定的异常类型，可以使用 rollbackFor 参数：

@Transactional(rollbackFor = MyException.class)
public void aMethod() {
// 业务代码
}