Spring_事务(基于注解的方式)
Spring 中的事务管理
作为企业级应用程序框架, Spring 在不同的事务管理 API 之上定义了一个抽象层.
而应用程序开发人员不必了解底层的事务管理 API, 就可以使用 Spring 的事务管理机制.
Spring 既支持编程式事务管理, 也支持声明式的事务管理.
编程式事务管理: 将事务管理代码嵌入到业务方法中来控制事务的提交和回滚. 在编程式管理事务时, 必须在每个事务操作中包含额外的事务管理代码.
声明式事务管理: 大多数情况下比编程式事务管理更好用. 它将事务管理代码从业务方法中分离出来, 以声明的方式来实现事务管理.
事务管理作为一种横切关注点, 可以通过 AOP 方法模块化. Spring 通过 Spring AOP 框架支持声明式事务管理.
1.Spring 声明式事务
数据表
account
book
book_stock
departments
employees
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" 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 http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd"> <!-- <context:component-scan base-package="com.aff.spring.jdbc"></context:component-scan> --> <context:component-scan base-package="com.aff.spring.tx"></context:component-scan> <!-- 导入资源文件 --> <context:property-placeholder location="classpath:db.properties" /> <!--配置c3p0数据源 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="user" value="${jdbc.user}"></property> <property name="password" value="${jdbc.password}"></property> <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property> <property name="driverClass" value="${jdbc.driverClass}"></property> <property name="initialPoolSize" value="${jdbc.initPoolSize}"></property> <property name="maxPoolSize" value="${jdbc.maxPoolSize}"></property> </bean> <!--配置Spring 的JdbcTemplate --> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dataSource"></property> </bean> <!--配置 NamedParameterJdbcTemplate ,该对象可以使用具名参数, 其没有无参数的构造器,所以必须为其构造器指定参数--> <bean id="namedParameterJdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate"> <constructor-arg ref="dataSource"></constructor-arg> </bean> <!-- 配置事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"></property> </bean> <!-- 把事务命名空间加进来。也就是tx: 加进来 --> <!-- 启用事务注解--> <tx:annotation-driven transaction-manager="transactionManager"/> </beans>
db.properties
jdbc.user=root
jdbc.password=123456
jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.jdbcUrl=jdbc:mysql:///spring
jdbc.initPoolSize=5
jdbc.maxPoolSize=20
BookShopDao.java
package com.aff.spring.tx; public interface BookShopDao { //根据书号获取书的单价 public int findBookPriceByIsBn(String isbn); //跟新书的库存,使书号对应书的库存 -1 public void updateBookStock(String isbn); //跟新用户的账户余额: 使username 的balance -price public void updateUserAcount(String username,int price); }
BookShopDaoImpl.java
package com.aff.spring.tx; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository; @Repository("bookShopDao") public class BookShopDaoImpl implements BookShopDao { @Autowired private JdbcTemplate jdbcTemplate; @Override public int findBookPriceByIsBn(String isbn) { String sql = "select price from book where isbn = ?"; return jdbcTemplate.queryForObject(sql, Integer.class,isbn); } @Override public void updateBookStock(String isbn) { //检查书的库存是否足够, 若不够抛出异常 String sql2= "select stock from book_stock where isbn = ?"; int stock =jdbcTemplate.queryForObject(sql2, Integer.class,isbn); if (stock == 0) { throw new BookStockException("库存不足"); } String sql = "update book_stock set stock = stock -1 where isbn = ?"; jdbcTemplate.update(sql,isbn); } @Override public void updateUserAcount(String username, int price) { //验证余额是否足够, 若不足则抛出异常 String sql2= "select balance from account where username = ?"; int balance =jdbcTemplate.queryForObject(sql2, Integer.class,username); if (balance <price ) { throw new UserAccountException("余额不足"); } String sql = "update account set balance = balance-? where username = ?"; jdbcTemplate.update(sql, price,username); } }
BookShopService.java
package com.aff.spring.tx; public interface BookShopService { public void purchase(String username,String isbn); }
BookShopServiceImpl.java
package com.aff.spring.tx; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @Service("bookShopService") public class BookShopServiceImpl implements BookShopService { @Autowired private BookShopDao bookShopDao; //添加事务注解 @Transactional @Override public void purchase(String username, String isbn) { // 1.获取书的单价 int price = bookShopDao.findBookPriceByIsBn(isbn); // 2.跟新书的库存 bookShopDao.updateBookStock(isbn); // 3. 跟新用户余额 bookShopDao.updateUserAcount(username, price); } }
BookStockException.java
package com.aff.spring.tx; public class BookStockException extends RuntimeException { /** * */ private static final long serialVersionUID = 1L; public BookStockException() { super(); // TODO Auto-generated constructor stub } public BookStockException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) { super(message, cause, enableSuppression, writableStackTrace); // TODO Auto-generated constructor stub } public BookStockException(String message, Throwable cause) { super(message, cause); // TODO Auto-generated constructor stub } public BookStockException(String message) { super(message); // TODO Auto-generated constructor stub } public BookStockException(Throwable cause) { super(cause); // TODO Auto-generated constructor stub } }
UserAccountException.java
package com.aff.spring.tx; public class UserAccountException extends RuntimeException{ /** * */ private static final long serialVersionUID = 1L; public UserAccountException() { super(); // TODO Auto-generated constructor stub } public UserAccountException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) { super(message, cause, enableSuppression, writableStackTrace); // TODO Auto-generated constructor stub } public UserAccountException(String message, Throwable cause) { super(message, cause); // TODO Auto-generated constructor stub } public UserAccountException(String message) { super(message); // TODO Auto-generated constructor stub } public UserAccountException(Throwable cause) { super(cause); // TODO Auto-generated constructor stub } }
SpringTransactionTest.java
package com.aff.spring.tx; import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; public class SpringTransactionTest { private ApplicationContext ctx = null; private BookShopDao bookShopDao = null; private BookShopService bookShopService =null; { ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); bookShopDao = ctx.getBean(BookShopDao.class); bookShopService = ctx.getBean(BookShopService.class); } @Test public void testBookShopService(){ bookShopService.purchase("AA", "1001"); } @Test public void testupdateUserAcount() { bookShopDao.updateUserAcount("AA", 150); } @Test public void testupdateBookStock() { bookShopDao.updateBookStock("1002"); } @Test public void testfindBookPriceByIsBn() { System.out.println(bookShopDao.findBookPriceByIsBn("1001")); } }
2.Spring 支持的事务传播行为
需求
新定义 Cashier 接口: 表示客户的结账操作
修改数据表信息如下, 目的是用户 Tom 在结账时, 余额只能支付第一本书, 不够支付第二本书:
①REQUIRED 传播行为
当 bookService 的 purchase() 方法被另一个事务方法 checkout() 调用时, 它默认会在现有的事务内运行. 这个默认的传播行为就是 REQUIRED.
因此在 checkout() 方法的开始和终止边界内只有一个事务. 这个事务只在 checkout() 方法结束的时候被提交, 结果用户一本书都买不了
事务传播属性可以在 @Transactional 注解的 propagation 属性中定义
②REQUIRES_NEW 传播行为
另一种常见的传播行为是 REQUIRES_NEW. 它表示该方法必须启动一个新事务, 并在自己的事务内运行. 如果有事务在运行, 就应该先挂起它.
@Transactional(propagation=Propagation.REQUIRES_NEW)
@Override
public void purchase(String username, String isbn)
Cashier.java
package com.aff.spring.tx; import java.util.List; public interface Cashier { public void checkout(String username, List<String> isbns); }
CashierImpl.java
package com.aff.spring.tx; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @Service("cashier") public class CashierImpl implements Cashier { @Autowired private BookShopService bookShopService; @Transactional @Override public void checkout(String username, List<String> isbns) { for (String isbn : isbns) { bookShopService.purchase(username, isbn); } } }
SpringTransactionTest.java
public class SpringTransactionTest { private ApplicationContext ctx = null; private BookShopDao bookShopDao = null; private BookShopService bookShopService = null; private Cashier cashier = null; { ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); bookShopDao = ctx.getBean(BookShopDao.class); bookShopService = ctx.getBean(BookShopService.class); cashier = ctx.getBean(Cashier.class); } // 事务的传播 @Test public void testTransactionlPropagetion() { cashier.checkout("AA", Arrays.asList("1001","1002")); }
}
BookShopServiceImpl.java
package com.aff.spring.tx; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; @Service("bookShopService") public class BookShopServiceImpl implements BookShopService { @Autowired private BookShopDao bookShopDao; //添加事务注解 //1.使用propagation 指定 事务的传播行为,即当前的事务方法被另一事务方法调用时 // 如果 使用事务, 默认取值为REQUIRED, 即使用调用方法的事务 //REQUIRES_NEW:事务自己的事务,调用事务方法的事务被挂起 //2.使用isolation 指定事务的隔离级别,最常用的READ_COMMITTED 读已提交 //3.默认情况下Spring 的声明式事务对所有的运行时异常进行回滚,也可以通过对应的属性进行设置 //4.使用readOnly 指定事务是否为只读, 表示这个事务只读取数据但不更新数据 // 这样可以帮助数据库引擎优化事务, 只读取数据库值的方法,应设置readOnly = true //5.使用timeout, 指定强制回滚之前事务可以占用的时间 @Transactional(propagation=Propagation.REQUIRES_NEW ,isolation=Isolation.READ_COMMITTED,readOnly = false,timeout = 3) @Override public void purchase(String username, String isbn) { // 1.获取书的单价 int price = bookShopDao.findBookPriceByIsBn(isbn); // 2.跟新书的库存 bookShopDao.updateBookStock(isbn); // 3. 跟新用户余额 bookShopDao.updateUserAcount(username, price); } }
目录
原文地址:https://www.cnblogs.com/afangfang/p/12992120.html
- 通过Snapshot Standby来精确评估SQL性能 (r9笔记第73天)
- mongodb11天之屠龙宝刀(三)基本操作:增删改查与mysql对比
- Go语言 实现bitmap
- 最近的几个技术问题总结和答疑(八) (r9笔记第72天)
- Java基础-day05-代码题
- MySQL级联复制的同步问题(一) (r9笔记第71天)
- GO语言 TCP传输实例
- JavaScript 性能优化技巧分享
- 一个拷贝操作导致的潜在监听类问题(r9笔记第70天)
- Java基础-day05-基础题
- 【Go 语言社区算法课程 第一季 第3节 hash算法实现
- mongodb11天之屠龙宝刀(四)高级查询:MongoDB内嵌字段查询
- merge语句导致的ORA错误分析(r9笔记第67天)
- Go语言的单例模式(Singleton)
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- nginx快速入门
- R语言中进行期权定价的Heston模型
- 使用R语言随机波动模型SV处理时间序列中的随机波动率
- 20个ES6面试高频问题
- i++和++i傻傻分不清楚?这里给你最清楚的解答
- android APT 使用
- Flutter异步编程async与await的基本使用
- 教大家一个万能PPT图片排版技巧,太赞了!
- 重复读取 HttpServletRequest 中 InputStream 的方法
- 测试面试题集锦(三)| 计算机网络和数据库篇(附答案)
- 关于Scikit-Learn你(也许)不知道的10件事
- 技术天地 | CSS-in-JS:一个充满争议的技术方案
- 安全研究 | 通过域名劫持实现Azure DevOps账户劫持
- 一款针对DLL劫持的恶意DLL生成器
- AuthMatrix:一款针对Web应用和服务的认证安全检测BurpSuite工具