前情回顾
已经学习了Spring基础入门知识 和Spring AOP知识，在上一节内容中我们还将Spring 和 MyBatis结合起来使用，熟悉开发模式。这节学习 Spring 中的事务，同样是重要内容。
事务概念
其实和我们前面学习 MySql 时，了解到的事务是同一概念，指的是一组或多条 SQL 语句的执行结果要么全部成功，要么全部失败，不会有其他结果，这就叫事务。事务的出现也是为了很好的解决现实生活中的问题。
Spring 事务管理器
使用 Spring 的事务管理器，管理不同数据库访问技术的事务处理。开发者只需要掌握 Spring 事务处理这一个方案，就可以实现使用不用数据库访问技术的事务管理。
事务管理面向的是 Spring，由 Spring 管理事务，做事务提交，事务回滚。
事务管理器接口：PlatformTransactionManager，其有很多实现类，基本上不同数据库访问技术都有对应的实现类，我们要学习的是 DataSourceTransactionManager ，该实现类适合 jdbc 方式和 MyBatis 方式。
Spring 事务定义接口
接口 TransactionDefinition定义了三类常量，说明有关事务控制的属性。
事务属性：
Spring 事务隔离级别与传播
隔离级别：控制不同事务之间的影响程度。和学习 MySQL 中的事务隔离是一个意思。
5 个值，只有四个隔离级别：
DEFAULT：采用数据库默认的事务隔离级别，MySQL 默认REPEATABLE_READ，Oracle 默认READ_UNCOMMITTED
READ_UNCOMMITTED：读未提交，未解决任何并发问题。
READ_COMMITTED：读已提交，解决脏读，存在不可重复读与幻读
REPEATABLE_READ：可重复读，解决了脏读、不可重复读，存在幻读
SERIALIZABLE：串行化，不存在并发问题。
Spring 事务传播行为，标识方法有无事务：
PROPAGATION_REQUIRED：Spring 默认传播行为，调用方法是，如果有事务则使用当前事务，如果没有事务，则会新建事务，方法在新建的事务中执行。
PROPAGATION_SUPPORTS：支持，方法有无事务都可正常执行。
PROPAGATION_SUPPORTS_NEW：新建，在调用方法时如果存在事务，则先暂停，直到新建事务执行结束；如果不存在事务，还是新建事务执行方法。
PROPAGATION_MANDATORY：
PROPAGATION_NESTED：
PROPAGATION_NEVER：
PROPAGATION_NOT_SUPPORTED：
其中前三个必须掌握。
Spring 添加事务
Spring 提供了两种方式添加事务：
Spring 事务应用案例
场景需求
出售商品简单流程，每当出售一件商品，那么销售记录表应该增加一条该商品的记录，同时，应该更新商品表中该商品的库存，而这两者应该是同时成功，或者同时失败，才是正确的业务逻辑，而要保证这一结果，就需要使用事务。
实现流程分析
除了业务分析和添加事务外，其他的流程和上一节内容是相同的，再来温习一下具体步骤：
创建数据库、数据表
这里小编还用上节内容中的数据库，表需要新建两张：sale 和 goods .
sale 表字段：id(自动增长、int、主键、销售记录ID)；gid(int、商品ID)；num(int、购买数量);
goods 表字段：id(自动增长、int、主键、商品ID)；name(varchar(255)、商品名称)；account(int、商品库存)；price(float、商品单价)；
其中，goods 表中可以先维护两条数据，小编这里的数据如下：
1001，50，手机5G，5299 1002，10，显示屏4K，2299
复制代码
创建实体类
这个操作估计各位已经轻车熟路了，废话不多说，上代码：
sale 实体类代码：
public class Sale { private Integer id; private Integer gid; private Integer num; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public Integer getGid() { return gid; } public void setGid(Integer gid) { this.gid = gid; } public Integer getNum() { return num; } public void setNum(Integer num) { this.num = num; } }
复制代码
goods 实体类代码：
public class Goods { private Integer id; private String name; private Float price; private Integer account; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Float getPrice() { return price; } public void setPrice(Float price) { this.price = price; } public Integer getAccount() { return account; } public void setAccount(Integer account) { this.account = account; } }
复制代码
创建 Dao 和对应的 Mapper
SaleDao 代码如下：
public interface SaleDao { int insertSale(Sale sale); }
复制代码
这里是新增销售记录，所以只需要一个添加记录的接口即可。
SaleDaoMapper.xml如下：
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.javafirst.dao.SaleDao"> <insert id="insertSale"> insert into sale(gid,num) values (#{gid},#{num}) </insert> </mapper>
复制代码
GoodsDao 代码如下：
public interface GoodsDao { int updateAccount(Goods goods); Goods selectById(Integer gid); }
复制代码
提供两个方法，一个是我们要更新库存使用，另一个我们需要根据给定的 ID 查询商品库存，避免更新后出现库存为负的情况。
GoodsDaoMapper.xml代码如下：
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.javafirst.dao.GoodsDao"> <update id="updateAccount"> update goods set account = account - #{account} where id = #{id} </update> <select id="selectById" resultType="com.javafirst.daomain.Goods"> select * from goods where id = #{id} </select> </mapper>
复制代码
MyBatis 核心配置
这都是老规矩了，上代码：
mybatis-config.xml代码如下：
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <!-- 日志 --> <settings> <setting name="logImpl" value="STDOUT_LOGGING"/> </settings> <typeAliases> <typeAlias type="com.javafirst.daomain.Sale"/> <typeAlias type="com.javafirst.daomain.Goods"/> </typeAliases> <mappers> <mapper resource="mapper/SaleDaoMapper.xml"/> <mapper resource="mapper/GoodsDaoMapper.xml"/> </mappers> </configuration>
复制代码
创建 Service 和其实现类
其实这里才是我们的真正业务逻辑处理，前面的都是支撑，这个整体流程需要多些案例，慢慢感受。
public interface BuyGoodsService { void buyGoods(Integer gid, Integer num); }
复制代码
其实现类代码如下：
/** * desc: * author: 推荐学java * <p> * weChat: studyingJava */ public class BuyGoodsImpl implements BuyGoodsService { SaleDao saleDao; GoodsDao goodsDao; public void setSaleDao(SaleDao saleDao) { this.saleDao = saleDao; } public void setGoodsDao(GoodsDao goodsDao) { this.goodsDao = goodsDao; } @Override public void buyGoods(Integer gid, Integer num) { System.out.println("buyGoods方法开始执行了..."); // 先插入记录 再减掉库存 Sale sale = new Sale(); sale.setGid(gid); sale.setNum(num); saleDao.insertSale(sale); // 减掉库存之前 先判断库存数是否大于等于购买数量，避免更新后出现负库存 Goods goods = goodsDao.selectById(gid); if (null == goods || gid > 1002 || gid < 1001) { throw new NullPointerException("商品不存在"); } if (goods.getAccount() < num) { throw new IndexOutOfBoundsException("库存不足"); } // 更新库存 Goods buyGoods = new Goods(); buyGoods.setId(gid); buyGoods.setAccount(num); goodsDao.updateAccount(buyGoods); } }
复制代码
这里的逻辑是能跑通整个流程就行，还没有加入事务前的逻辑。
Spring 核心配置文件
applicationContext.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" 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/context https://www.springframework.org/schema/context/spring-context.xsd"> <!-- 使用属性文件 配置数据源中数据库链接信息 --> <context:property-placeholder location="jdbc.properties"/> <!-- 声明数据源--> <bean id="myDataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <property name="url" value="${jdbc.url}"/> <property name="username" value="${jdbc.username}"/> <property name="password" value="${jdbc.password}"/> </bean> <!-- 声明 SQLSessionFactoryBean --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="myDataSource"/> <property name="configLocation" value="classpath:mybatis-config.xml"/> </bean> <!-- 声明 MapperScannerConfigurer --> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> <property name="basePackage" value="com.javafirst.dao"/> </bean> <!-- 注册自定义Service --> <bean id="buyGoods" class="com.javafirst.service.impl.BuyGoodsImpl"> <property name="saleDao" ref="saleDao"/> <property name="goodsDao" ref="goodsDao"/> </bean> </beans>
复制代码
上节内容提到过，这里的基本都是流程性的，我们只需要注册自己业务相关的Service 就行。
测试
这都是固定代码了，贴一下：
@Test public void spring_transaction() { String config = "applicationContext.xml"; ApplicationContext context = new ClassPathXmlApplicationContext(config); BuyGoodsService buyGoods = (BuyGoodsService) context.getBean("buyGoods"); buyGoods.buyGoods(1001, 10); System.out.println("测试方法执行完成了!"); }
复制代码
结果大家可以通过改变参数验证结果，通过查看两张表中的数据变更来对比存在的问题，解决方案是通过 Spring 事务来控制整体流程的最终结果，下面就来学习事务的使用。
使用 Transactional 注解添加事务
使用步骤：
在 Spring 配置文件中声明事务的内容（声明事务管理器，指定使用的哪个事务管理器对象；声明使用哪个注解管理事务，开启事务注解驱动）
在类的源代码中加入 @Transactional 注解（可添加在类上面，有可添加在方法上面，推荐后者）
Spring 配置文件中新增如下代码：
<!-- 声明事务管理器 --><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <!-- 给事务管理器指定 要管理哪里的数据源 --> <property name="dataSource" ref="myDataSource"/></bean>
<!-- 声明事务管理器驱动 --><tx:annotation-driven transaction-manager="transactionManager"/>
复制代码
然后在业务代码方法上面添加注解：
@Transactional( propagation = Propagation.REQUIRED, // REQUIRED默认值 isolation = Isolation.DEFAULT, // 一般选择默认选项 timeout = 12, // 超时，单位秒，默认-1 readOnly = false, // 返回异常类的class数组 在该数组中声明的异常，程序都会回滚，不在该数组中声明的运行时异常也都会回滚 rollbackFor = {NullPointerException.class, IndexOutOfBoundsException.class})@Overridepublic void buyGoods(Integer gid, Integer num) { System.out.println("buyGoods方法开始执行了...");
// 先插入记录 再减掉库存 Sale sale = new Sale(); sale.setGid(gid); sale.setNum(num);
saleDao.insertSale(sale);
// 减掉库存之前 先判断库存数是否大于等于购买数量，避免更新后出现负库存 Goods goods = goodsDao.selectById(gid);
if (null == goods) { throw new NullPointerException("商品不存在"); } if (goods.getAccount() < num) { throw new IndexOutOfBoundsException("库存不足"); }
// 更新库存 Goods buyGoods = new Goods(); buyGoods.setId(gid); buyGoods.setAccount(num);
goodsDao.updateAccount(buyGoods);}
复制代码
接着同样是通过修改参数来做测试，证明加了事务之后，能保证我们在错误操作的情况下，不会多插入销售记录，也就保证了业务方法内的 SQL 逻辑要么全部成功，要么全部失败。
使用 AspectJ 框架声明事务控制
这是另一种方式使用 Spring 的事务。
使用 AspectJ 的 AOP 声明事务控制叫做声明式事务。使用步骤如下：
在pom.xml中加入 spring-aspects依赖；
在 spring 的配置文件中声明事务的内容（声明事务管理器，业务方法需要的事务属性，声明切入点表达式）
下面就通过这种方式来做测试事务使用，在这之前，先把我们前面添加事务的方式注释掉，在进行下面的配置。
pom.xml文件添加如下代码：
<!-- AspectJ aop实现注解 --><dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>5.3.14</version></dependency>
复制代码
applicationContext.xml文件添加如下代码：
<!-- 声明事务管理器 --><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <!-- 给事务管理器指定 要管理哪里的数据源 --> <property name="dataSource" ref="myDataSource"/></bean>
<!-- 通过使用AspectJ框架AOP方式实现 Spring事务配置管理 --><tx:advice id="buyServiceAdvice" transaction-manager="transactionManager"> <tx:attributes> <tx:method name="buyGoods" propagation="REQUIRED" isolation="DEFAULT" rollback-for="java.lang.NullPointerException,java.lang.IndexOutOfBoundsException"/>
<!-- 有多个方法需要添加事务 可以在这里意义列举出来， 也可以把方法的命名起的有规则，然后通过通配符*来批量添加
通配符举例：add*、*（直接用一个*表示的意思是除了这里添加的方法外，应用于剩下的其他方法） --> </tx:attributes></tx:advice>
<!-- 切入点表达式，说明事务管理器是在哪个包下的哪个类需要使用--><aop:config> <!-- id:切入点ID，唯一值 expression：切入点表达式，指定要执行的方法 --> <aop:pointcut id="servicePointcut" expression="execution(* *..service..*.*(..))"/> <!-- 将切入点表达式和声明的事务管理器关联起来 --> <aop:advisor advice-ref="buyServiceAdvice" pointcut-ref="servicePointcut"/></aop:config>
复制代码
声明事务管理器是固定不变的，其他的其实也都是固定代码，以后当做模板使用即可。
最后是测试，同样通过改变参数，验证结果的正确性。
两种方式对比
前者适合中小型项目，流程比较清晰，容易理解；后者这种配置的方式理解起来难度比较大，不容易读懂，适合大型项目，一般配置好就不会动了。
总结
本文介绍的 Spring 事务管理器体系结构和用法，还是新东西，重点掌握事务的应用场景，因为实际开发中是需要用的
代码这块必须掌握事务的使用流程，自己会配置，能让事务起到作用
结合上一节内容，现在需要掌握从头开始搭建一个 Spring 项目，包括 Dao 层和业务层以及简单的配置
《推荐学 java》系列干到这里，小编似乎也有一种豁然开朗的感觉，并没有开始学习前的恐惧了，而是开轻松，大家加油~
学编程，推荐首选 Java 语言，小编创建了一个专注 Java 的原创公众号推荐学java，各位可以在微信搜索javaFirst 关注，一起开启 Java 旅途！
评论