😀前言
本篇是Spring 声明式事务系列的第一篇介绍了什么是Spring 声明式事务
🧑个人简介：大家好，我是尘觉，希望我的文章可以帮助到大家，您的满意是我的动力😉😉
🤓什么是Spring 声明式事务详细讲解
😋事务分类
编程式事务:
示意代码, 传统方式
Connection connection = JdbcUtils.getConnection(); try { //1. 先设置事务不要自动提交 connection.setAutoCommint(false); //2. 进行各种 crud //多个表的修改，添加 ，删除 //3. 提交 connection.commit(); } catch (Exception e) { //4. 回滚 conection.rollback(); }
🤗声明式事务-使用实例
需求说明-用户购买商品
我们需要去处理用户购买商品的业务逻辑:分析: 当一个用户要去购买商品应该包含三个步骤
1. 通过商品 id 获取价格. 2. 购买商品(某人购买商品，修改用户的余额)
3. 修改库存量
4. 其实大家可以看到，这时，我们需要涉及到三张表商品表，用户表，商品存量表。 应该使用事务处理
😃解决方案分析
1. 使用传统的编程事务来处理，将代码写到一起[缺点: 代码冗余，效率低，不利于扩展, 优点是简单，好理解]
Connection connection = JdbcUtils.getConnection(); try { //1. 先设置事务不要自动提交 connection.setAutoCommit(false); //2. 进行各种 crud //多个表的修改，添加 ，删除 select from 商品表 => 获取价格 修改用户余额 update ... 修改库存量 update //3. 提交 connection.commit(); } catch (Exception e) { //4. 回滚 conection.rollback(); }
2. 使用 Spring 的声明式事务处理，
可以将上面三个子步骤分别写成一个方法，然后统一管理.
[这个是 Spring 很牛的地方，在开发使用的很多，优点是无代码冗余，效率高，扩展方便，缺点是理解较困难]==> 底层使用 AOP (动态代理+动态绑定+反射+注解)
😍声明式事务使用-代码实现
先创建商品系统的数据库和表
-- 演示声明式事务创建的表 CREATE TABLE `user_account`( user_id INT UNSIGNED PRIMARY KEY AUTO_INCREMENT, user_name VARCHAR(32) NOT NULL DEFAULT '', money DOUBLE NOT NULL DEFAULT 0.0 )CHARSET=utf8; INSERT INTO `user_account` VALUES(NULL,'张三', 1000); INSERT INTO `user_account` VALUES(NULL,'李四', 2000); CREATE TABLE `goods`( goods_id INT UNSIGNED PRIMARY KEY AUTO_INCREMENT, goods_name VARCHAR(32) NOT NULL DEFAULT '', price DOUBLE NOT NULL DEFAULT 0.0 )CHARSET=utf8 ; INSERT INTO `goods` VALUES(NULL,'小风扇', 10.00); INSERT INTO `goods` VALUES(NULL,'小台灯', 12.00); INSERT INTO `goods` VALUES(NULL,'可口可乐', 3.00); CREATE TABLE `goods_amount`( goods_id INT UNSIGNED PRIMARY KEY AUTO_INCREMENT, goods_num INT UNSIGNED DEFAULT 0 )CHARSET=utf8 ; INSERT INTO `goods_amount` VALUES(1,200); INSERT INTO `goods_amount` VALUES(2,20); INSERT INTO `goods_amount` VALUES(3,15);
创建GoodsDao类
@Repository //将 GoodsDao-对象 注入到spring容器 public class GoodsDao { @Resource private JdbcTemplate jdbcTemplate; /** * 根据商品id,返回对应的价格 * @param id * @return */ public Float queryPriceById(Integer id) { String sql = "SELECT price From goods Where goods_id=?"; Float price = jdbcTemplate.queryForObject(sql, Float.class, id); return price; } /** * 修改用户的余额 [减少用户余额] * @param user_id * @param money */ public void updateBalance(Integer user_id, Float money) { String sql = "UPDATE user_account SET money=money-? Where user_id=?"; jdbcTemplate.update(sql, money, user_id); } /** * 修改商品库存 [减少] * @param goods_id * @param amount */ public void updateAmount(Integer goods_id, int amount){ String sql = "UPDATE goods_amount SET goods_num=goods_num-? Where goods_id=?"; jdbcTemplate.update(sql, amount , goods_id); } }
创建 src\tx_ioc.xm
<?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" xmlns:tx="http://www.springframework.org/schema/tx" 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 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"> <!--配置要扫描的包--> <context:component-scan base-package="com.spring.tx.dao"/> <!--引入外部的jdbc.properties文件--> <context:property-placeholder location="classpath:jdbc.properties"/> <!--配置数据源对象-DataSoruce--> <bean class="com.mchange.v2.c3p0.ComboPooledDataSource" id="dataSource"> <!--给数据源对象配置属性值--> <property name="user" value="${jdbc.user}"/> <property name="password" value="${jdbc.pwd}"/> <property name="driverClass" value="${jdbc.driver}"/> <property name="jdbcUrl" value="${jdbc.url}"/> </bean> <!--配置JdbcTemplate对象--> <bean class="org.springframework.jdbc.core.JdbcTemplate" id="jdbcTemplate"> <!--给JdbcTemplate对象配置dataSource--> <property name="dataSource" ref="dataSource"/> </bean> <!--配置事务管理器-对象 1. DataSourceTransactionManager 这个对象是进行事务管理-debug源码 2. 一定要配置数据源属性，这样指定该事务管理器 是对哪个数据源进行事务控制 --> <bean class="org.springframework.jdbc.datasource.DataSourceTransactionManager" id="transactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!--配置启动基于注解的声明式事务管理功能--> <tx:annotation-driven transaction-manager="transactionManager"/> </beans>
创建TxTest类
public class TxTest { @Test public void queryPriceByIdTest() { //获取到容器 ApplicationContext ioc = new ClassPathXmlApplicationContext("tx_ioc.xml"); GoodsDao goodsDao = ioc.getBean(GoodsDao.class); Float price = goodsDao.queryPriceById(1); System.out.println("id=100 的price=" + price); } @Test public void updateBalance() { //获取到容器 ApplicationContext ioc = new ClassPathXmlApplicationContext("tx_ioc.xml"); GoodsDao goodsDao = ioc.getBean(GoodsDao.class); goodsDao.updateBalance(1, 1.0F); System.out.println("减少用户余额成功~"); } @Test public void updateAmount() { //获取到容器 ApplicationContext ioc = new ClassPathXmlApplicationContext("tx_ioc.xml"); GoodsDao goodsDao = ioc.getBean(GoodsDao.class); goodsDao.updateAmount(1, 1); System.out.println("减少库存成功..."); } }
创建GoodsService类
编写方法，验证不使用事务就会出现数据不一致现象.
@Service public class GoodsService { @Autowired private GoodsDao goodsDao; /** * 购买商品[没有使用事务] * @param user_id * @param goods_id * @param num */ public void buyGoods(int user_id, int goods_id, int num) { //查询到商品价格 Float goods_price = goodsDao.queryPriceById(goods_id); //购买商品，减去余额 goodsDao.updateBalance(user_id, goods_price * num); // //: 模拟一个异常, 会发生数据库数据不一致现象 // int i = 10 / 0; //更新库存 goodsDao.updateAmount(goods_id, num); } }
修改tx_ioc.xml, 加入对 Service 的扫描
<?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" xmlns:tx="http://www.springframework.org/schema/tx" 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 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"> <!--配置要扫描的包--> <context:component-scan base-package="com.spring.tx.dao"/> <context:component-scan base-package="com.spring.tx.service"/> <!--引入外部的jdbc.properties文件--> <context:property-placeholder location="classpath:jdbc.properties"/> <!--配置数据源对象-DataSoruce--> <bean class="com.mchange.v2.c3p0.ComboPooledDataSource" id="dataSource"> <!--给数据源对象配置属性值--> <property name="user" value="${jdbc.user}"/> <property name="password" value="${jdbc.pwd}"/> <property name="driverClass" value="${jdbc.driver}"/> <property name="jdbcUrl" value="${jdbc.url}"/> </bean> <!--配置JdbcTemplate对象--> <bean class="org.springframework.jdbc.core.JdbcTemplate" id="jdbcTemplate"> <!--给JdbcTemplate对象配置dataSource--> <property name="dataSource" ref="dataSource"/> </bean> <!--配置事务管理器-对象 1. DataSourceTransactionManager 这个对象是进行事务管理-debug源码 2. 一定要配置数据源属性，这样指定该事务管理器 是对哪个数据源进行事务控制 --> <bean class="org.springframework.jdbc.datasource.DataSourceTransactionManager" id="transactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!--配置启动基于注解的声明式事务管理功能--> <tx:annotation-driven transaction-manager="transactionManager"/> </beans>
测试 TxTest类
@Test public void buyGoodsTest() { ApplicationContext ioc = new ClassPathXmlApplicationContext("tx_ioc.xml"); GoodsService bean = ioc.getBean(GoodsService.class); bean.buyGoods(1, 2, 1); System.out.println("====购买商品成功===="); }
修改 GoodsService.java, 增加测试方法，加入声明式事务注解
@Transactional public void buyGoodsByTx(int user_id, int goods_id, int num) { //查询到商品价格 Float goods_price = goodsDao.queryPriceById(goods_id); //购买商品，减去余额 goodsDao.updateBalance(user_id, goods_price * num); // // 模拟一个异常, 会发生数据库数据不一致现象 // int i = 10 / 0; //更新库存 goodsDao.updateAmount(goods_id, num); }
修改 TxTest.java, 增加测试方法, 对声明式事务进行测试，看看是否保证了数据一致性
/** * 测试购买商品(使用了声明式事务) */ @Test public void buyGoodsByTxTest() { ApplicationContext ioc = new ClassPathXmlApplicationContext("tx_ioc.xml"); GoodsService bean = ioc.getBean(GoodsService.class); //使用 buyGoodsByTx() bean.buyGoodsByTx(1, 2, 1); System.out.println("====购买商品成功===="); }
😄总结
本文讲解了什么是Spring 声明式事务详以及代码实现
小提示 系列文章一般是连起来的哦建议系列学习
精彩继续请看下一篇
😘本篇是Spring 声明式事务系列
第二篇->
(https://bbs.csdn.net/forums/58c2ca9b8de344c69384b471dd4bd744)
文章到这里就结束了，如果有什么疑问的地方请指出，诸佬们一起来评论区一起讨论😁
希望能和诸佬们一起努力，今后我们一起观看感谢您的阅读🍻
如果帮助到您不妨3连支持一下，创造不易您们的支持是我的动力🤞
