Spring中的事务控制

时间：2021-02-08 10:49:12 阅读：22 评论：0 收藏：0 [点我收藏+]

在之前的两篇文章《基于XML配置的方式实现Spring中的AOP》和《基于注解的方式实现Spring中的AOP》中我们分别通过XML配置和注解配置的方式实现了自定义的事务控制，其实Spring框架已经为我们提供了事务管理功能。本文将继续使用之前的案例来介绍Spring中的事务控制。

一、Spring事务控制的API

在介绍如何使用Spring为我们提供的事务控制之前，我们先来了解一下Spring事务控制的相关API

1、PlatformTransactionManager

PlatformTransactionManager接口提供事务操作的方法，包含有3个具体的操作，下面通过一张表格来说明：

方法名	说明
TransactionStatus getTransaction(TransactionDefinition definition)	获取事务状态信息
void commit(TransactionStatus status)	提交事务
void rollback(TransactionStatus status)	回滚事务

在实际开发中都是使用该接口的实现类，下面列出两个常用的实现类：

org.springframework.jdbc.datasource.DataSourceTransactionManager：当使用Spring JDBC 或 iBatis 进行持久化数据时使用
org.springframework.orm.hibernate5.HibernateTransactionManager：当使用hibernate 进行持久化数据时使用

2、TransactionDefinition

TransactionDefinition是事务的定义信息对象，其中有如下方法：

方法名	说明
String getName()	获取事务对象名称
int getIsolationLevel()	获取事务隔离级别
int getPropagationBehavior()	获取事务传播行为
int getTimeout()	获取事务超时时间
boolean isReadOnly()	获取事务是否只读

下面将对其中的一些细节进行介绍：

（1）事务的隔离级别

事务的隔离级别反映了事务提交并发访问时的处理态度

事务的四种隔离级别分别为：未提交读（Read Uncommitted）、已提交读（Read Committed）、可重复读（Repeatable Read）和可串行化（Serializable），下面将通过一张表格来说明这四种隔离级别的区别：

隔离级别	脏读（Dirty Read）	幻读（Phantom Read）
未提交读	可能	可能
已提交读	不可能	可能
可重复读	不可能	可能
可串行化	不可能	不可能

更多关于事务隔离级别的内容，请参阅：《彻底搞懂 MySQL 事务的隔离级别》和《MySQL 事务隔离级别和锁》。

在TransactionDefinition接口中提供了几种事务隔离级别，下面将通过表格进行说明：

隔离级别	值	说明
`ISOLATION_DEFAULT`	-1	默认级别，和数据库保持一致
`ISOLATION_READ_UNCOMMITTED`	1	未提交读
`ISOLATION_READ_COMMITTED`	2	已提交读（Oracle默认级别）
`ISOLATION_REPEATABLE_READ`	4	可重复读（MySQL默认级别）
`ISOLATION_SERIALIZABLE`	8	可串行化

（2）事务的传播行为

事务传播行为用来描述由某一个事务传播行为修饰的方法被嵌套进另一个方法的时事务如何传播

Spring 在TransactionDefinition接口中规定了7种类型的事务传播行为。事务传播行为是Spring框架独有的事务增强特性，他不属于的事务实际提供方数据库行为。下面将通过表格来对事务传播行为进行说明：

事务传播行为类型	值	说明
`PROPAGATION_REQUIRED`	0	如果当前没有事务，就新建一个事务，如果已经存在一个事务中，加入到这个事务中（默认值）
`PROPAGATION_SUPPORTS`	1	支持当前事务，如果当前没有事务，就以非事务方式执行
`PROPAGATION_MANDATORY`	2	使用当前的事务，如果当前没有事务，就抛出异常
`PROPAGATION_REQUIRES_NEW`	3	新建事务，如果当前存在事务，把当前事务挂起
`PROPAGATION_NOT_SUPPORTED`	4	以非事务方式执行操作，如果当前存在事务，就把当前事务挂起
`PROPAGATION_NEVER`	5	以非事务方式执行，如果当前存在事务，则抛出异常
`PROPAGATION_NESTED`	6	如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则执行与`PROPAGATION_REQUIRED`类似的操作

（3）超时时间

默认值为-1，即没有超时限制。如果有，则以秒为单位进行设置。

（4）是否为只读事务

建议在查询时设置为只读。

3、TransactionStatus

TransactionStatus接口描述了某个时间点上事务对象的状态信息，包含6个具体的操作，下面将通过表格来介绍这些操作：

方法名	说明
void flush()	刷新事务
boolean hasSavePoint()	是否存在存储点
boolean isCompleted()	事务是否已经完成
boolean isNewTransaction()	事务是否为新的事务
boolean isRollbackOnly()	事务是否回滚
void setRollbackOnly()	设置事务回滚

二、基于XML声明式事务控制

下面我们将通过一个案例来介绍如何基于XML的方式来实现事务控制。在之前案例的不同之处在于，这次我们采用Spring JDBC来进行数据库相关操作。下面给出相关代码：

（1）数据访问层的实现类AccountDaoImpl

package cn.frankfang.dao.impl;

import cn.frankfang.dao.IAccountDao;
import cn.frankfang.pojo.Account;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

import java.util.List;

/**
 * 数据访问层实现类
 */
public class AccountDaoImpl extends JdbcDaoSupport implements IAccountDao {

    public AccountDaoImpl(JdbcTemplate jdbcTemplate) {
        super.setJdbcTemplate(jdbcTemplate);
    }

    @Override
    public int saveAccount(Account account) {
        try{
            return super.getJdbcTemplate().update("insert into account(id,name,money)values(?,?,?)",
                    account.getId(),
                    account.getName(),
                    account.getMoney());
        }catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public Account selectById(Integer id) {
        try {
            List<Account> accounts = super.getJdbcTemplate().query("select * from account where id = ? ",
                    new BeanPropertyRowMapper<>(Account.class), id);
            return accounts.isEmpty() ? null : accounts.get(0);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public List<Account> getAll() {
        try{
            return super.getJdbcTemplate().query("select * from account",
                    new BeanPropertyRowMapper<>(Account.class));
        }catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public int updateAccount(Account account) {
        try{
            return super.getJdbcTemplate().update("update account set name=?,money=? where id=?",
                    account.getName(),
                    account.getMoney(),
                    account.getId());
        }catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public int deleteAccount(Integer id) {
        try{
            return super.getJdbcTemplate().update("delete from account where id=?", id);
        }catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}

（2）XML配置文件spring-config.xml

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

    <!-- 配置数据访问层 -->
    <bean id="accountDao" class="cn.frankfang.dao.impl.AccountDaoImpl">
        <constructor-arg name="jdbcTemplate" ref="jdbcTemplate"/>
    </bean>

    <!-- 配置业务层 -->
    <bean id="accountService" class="cn.frankfang.service.impl.AccountServiceImpl">
        <property name="accountDao" ref="accountDao"/>
    </bean>

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

    <!-- 配置数据源 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.cj.jdbc.Driver"/>
        <property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/test?useAffectedRows=true"/>
        <property name="user" value="root"/>
        <property name="password" value="123456"/>
    </bean>
</beans>

1、导入依赖

在项目的pom.xml文件中添加以下内容：

<dependencies>
    <!-- spring-context -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.2.2.RELEASE</version>
    </dependency>
    <!-- spring tx -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-tx</artifactId>
        <version>5.2.2.RELEASE</version>
    </dependency>
    <!-- spring jdbc -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>5.2.2.RELEASE</version>
    </dependency>
    <!-- spring aop -->
    <dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
        <version>1.9.5</version>
    </dependency>
    <!-- c3p0 datasource -->
    <dependency>
        <groupId>com.mchange</groupId>
        <artifactId>c3p0</artifactId>
        <version>0.9.5.5</version>
    </dependency>
    <!-- mysql driver -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.18</version>
    </dependency>
</dependencies>