Spring框架：第八章：声明式事务-阿里云开发者社区

10、声明式事务

事务分为声明式和编程式两种:

声明式事务：声明式事务是指通过注解的形式对事务的各种特性进行控制和管理。

编码式（编程式）事务：指的是通过编码的方式实现事务的声明。

11.1、编码方式实现事务：

11.2、声明式事务环境搭建

11.2.1、准备测试数据库

##创建tx数据库
drop database if exists `tx`;
CREATE database `tx`;
##切换tx数据库
USE `tx`;
##删除用户表
DROP TABLE IF EXISTS `user`;
##创建用户表
CREATE TABLE `user` (
  `id` int primary key auto_increment,  
  `username` varchar(50) NOT NULL,
  `money` int(11) DEFAULT NULL
);
##插入数据
insert  into `user`(`username`,`money`) values ('张三',1000),('李四',1000);
##删除图书表
drop table if exists `book`;
##创建图书表
create table `book`(
    `id` int primary key auto_increment,
    `name` varchar(500) not null,
    `stock` int
);
##插入数据
insert into book(`name`,`stock`) values('java编程思想',100),('C++编程思想',100);
##查看数据
select * from book;
select * from user;

11.2.2、创建一个Java工程，导入Jar包

导入jar包：

com.springsource.org.aspectj.weaver-1.6.8.RELEASE.jar
commons-logging-1.1.3.jar
druid-1.1.9.jar
mysql-connector-java-5.1.37-bin.jar
spring-aop-4.3.18.RELEASE.jar
spring-beans-4.3.18.RELEASE.jar
spring-context-4.3.18.RELEASE.jar
spring-core-4.3.18.RELEASE.jar
spring-expression-4.3.18.RELEASE.jar
spring-jdbc-4.3.18.RELEASE.jar
spring-orm-4.3.18.RELEASE.jar
spring-test-4.3.18.RELEASE.jar
spring-tx-4.3.18.RELEASE.jar

配置jdbc.properties属性配置文件：

url=jdbc:mysql://localhost:3306/tx
user=root
password=root
driverClassName=com.mysql.jdbc.Driver
initialSize=5
maxActive=10

配置Spring的配置文件：

<?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 http://www.springframework.org/schema/context/spring-context-4.3.xsd">
  <!-- 配置包扫描 -->
  <context:component-scan base-package="com"></context:component-scan>
  <!-- 加载jdbc.properties属性配置文件 -->
  <context:property-placeholder location="classpath:jdbc.properties"/>
  <!-- 配置数据库连接池 -->
  <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <property name="username" value="${user}"/>
    <property name="password" value="${password}"/>
    <property name="url" value="${url}"/>
    <property name="driverClassName" value="${driverClassName}"/>
    <property name="initialSize" value="${initialSize}" />
    <property name="maxActive" value="${maxActive}"/>
  </bean>
  <!-- 配置jdbcTemplate工具类 -->
  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource" />
  </bean> 
</beans>

11.3、测试Service的默认事务

实验1：测试service服务层的默认事务

@Repository
public class BookDao {
  @Autowired
  JdbcTemplate jdbcTemplate;      
  public void updateBook() {
    jdbcTemplate.update("update book set name = '图书表被修改了'");
  }     
}
@Repository
public class UserDao {
  @Autowired
  JdbcTemplate jdbcTemplate;      
  public void updateUser() {
    jdbcTemplate.update("update user set username = '用户表被修改了'");
  }     
}
@Service
public class TransactionService {
  @Autowired
  private UserDao userDao;    
  @Autowired
  private BookDao bookDao;      
  public void multiUpdate() {
    userDao.updateUser();
    bookDao.updateBook();
  } 
}

异常的演示

@Service
public class TransactionService {
  @Autowired
  private UserDao userDao;
  @Autowired
  private BookDao bookDao;
  public void multiUpdate() {
    userDao.updateUser();
    int i = 12 / 0 ;
    bookDao.updateBook();
  }
}

Spring事务引入的分析------PlatformTransactionManager类简单介绍

事务管理器实现类

由于我们使用的是数据库连接池访问数据库，所以事务管理器使用的是DataSourceTransactionManager。

11.4、使用Spring的注解声明事务管制

实验2：测试Spring的声明式事务

1、在需要事务的方法上加入注解。

/**
 * @Transactional 表示当前方法有事务
 */
@Transactional
public void multiUpdate() {
  userDao.updateUser();
  int i = 12 / 0 ;
  bookDao.updateBook();
}

2、配置事务管理器驱动

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

3、配置事务注解驱动

<!-- 
  <tx:annotation-driven/> 开启注解的事务驱动 启用代理
    transaction-manager="transactionManager" 配置事务管理器
    如果事务管理器的id值是transactionManager，则事务管理器属性可以省略
 -->
<tx:annotation-driven />

11.5、noRollbackFor和noRollbackForClassName测试不回滚的异常

实验3：noRollbackFor和noRollbackForClassName测试不回滚的异常

  /**
   * @Transactional 表示当前方法有事务<br/>
   *  默认情况下。RuntimeException运行时异常和运行时子异常。都会回滚事务<br/>
   * noRollbackFor=java.lang.ArithmeticException.class 表示算术异常不回滚事务<br/>
   * noRollbackFor= {java.lang.ArithmeticException.class,java.lang.NullPointerException.class}<br/>
   * noRollbackForClassName="java.lang.NullPointerException" 设置哪些类名的异常不回滚事务<br/>
   */
  @Transactional(noRollbackForClassName="java.lang.NullPointerException")
  public void multiUpdate() {
    userDao.updateUser();
//    int i = 12 / 0 ;
    Object object = null;
    System.out.println( object.toString() );
    bookDao.updateBook();
  }

11.6、自定义设置回滚异常

实验5：rollbackFor和rollbackForClassName回滚的异常

/**
 * @throws FileNotFoundException 
 * @Transactional 表示当前方法有事务<br/>
 *  默认情况下。RuntimeException运行时异常和运行时子异常。都会回滚事务<br/>
 * rollbackFor=FileNotFoundException.class 设置当抛出FileNotFoundException异常时，回滚事务<br/>
 * rollbackForClassName="java.io.FileNotFoundException" 设置当抛出FileNotFoundException异常时就会回滚事务<br/>
 */
@Transactional(rollbackForClassName="java.io.FileNotFoundException")
public void multiUpdate() throws FileNotFoundException {
  userDao.updateUser();
  int i = 12 ;
  if (i == 12) {
    throw new FileNotFoundException();
  }
  bookDao.updateBook();
}

11.7、事务的只读属性

实验4：测试readOnly只读属性

/**
 * @throws FileNotFoundException 
 * @Transactional 表示当前方法有事务<br/>
 *  默认情况下。RuntimeException运行时异常和运行时子异常。都会回滚事务<br/>
 * readOnly=false 表示当前方法可以执行读操作。也可以执行写操作（指的是sql语句）。<br/>
 * 修改、添加、删除、是写操作、select查询语句是读操作。<br/>
 * readOnly=true 表示当前方法只能执行查询操作<br/>
 */
@Transactional(readOnly=true)
public void multiUpdate() throws FileNotFoundException {
  userDao.updateUser();
  bookDao.updateBook();
}

只读的方法执行修改语句报错。

11.8、事务超时属性timeout(秒为单位)

/**
 * @throws FileNotFoundException 
 * @Transactional 表示当前方法有事务<br/>
 *  默认情况下。RuntimeException运行时异常和运行时子异常。都会回滚事务<br/>
 * timeout=3 表示3秒之后就超时，不允许再执行sql语句
 */
@Transactional(timeout=3)
public void multiUpdate() throws FileNotFoundException {
  userDao.updateUser();
  try {
    Thread.sleep(5000);
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
  bookDao.updateBook();
}

当执行时间超过指定的秒钟后就会超时：

11.10、事务的传播特性propagation

什么是事务的传播行为：

当事务方法被另一个事务方法调用时，必须指定事务应该如何传播。例如：方法可能继续在现有事务中运行，也可能开启一个新事务，并在自己的事务中运行。

事务的传播行为可以由传播属性指定。Spring定义了7种类传播行为。

事务的传播特性，有以下几种类型：

11.11、注解演示事物传播特性

UserService

BookService

TransactionService

实验1：大小事务传播特性都是REQUIRED

  @Transactional(propagation = Propagation.REQUIRED)
  public void multlTransaction() {
  @Transactional(propagation = Propagation.REQUIRED)
  public void updateBook() {
@Transactional(propagation=Propagation.REQUIRED)
public void updateUser() {

实验2：大小事务传播特性都是REQUIRES_NEW

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void multiUpdate()
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateBook()
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateUser()

实验3：大事务是REQUIRED，小事务都是REQUIRES_NEW

@Transactional(propagation = Propagation.REQUIRED)
public void multiUpdate()
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateBook()
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateUser()

实验4：大事务是REQUIRED，小1REQUIRED，小2REQUIRES_NEW

@Transactional(propagation = Propagation.REQUIRED)
public void multiUpdate()
@Transactional(propagation = Propagation.REQUIRED)
public void updateBook()
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateUser()

实验5：大事务是REQUIRED，小1REQUIRES_NEW，小2REQUIRED

@Transactional(propagation = Propagation.REQUIRED)
public void multiUpdate()
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateBook()
@Transactional(propagation = Propagation.REQUIRED)
public void updateUser()

12、xml配置式事务声明

复制原来注解事务管理的工程。去掉里面所有@Transactional的注解。

<?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"
  xmlns:aop="http://www.springframework.org/schema/aop"
  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.3.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd">
  <!-- 配置包扫描 -->
  <context:component-scan base-package="com"></context:component-scan>
  <!-- 加载jdbc.properties属性配置文件 -->
  <context:property-placeholder location="classpath:jdbc.properties"/>
  <!-- 配置数据库连接池 -->
  <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <property name="username" value="${user}"/>
    <property name="password" value="${password}"/>
    <property name="url" value="${url}"/>
    <property name="driverClassName" value="${driverClassName}"/>
    <property name="initialSize" value="${initialSize}" />
    <property name="maxActive" value="${maxActive}"/>
  </bean>
  <!-- 配置jdbcTemplate工具类 -->
  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource" />
  </bean>
  <!-- 
    配置事务管理器
   -->
  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource" />
  </bean>
  <!-- 
    配置事务属性
   -->
  <tx:advice id="tx_advice" transaction-manager="transactionManager">
    <tx:attributes>
      <!-- 
        tx:method 给某个方法配置事务属性
          name就是方法的匹配规则（方法名）
          精确匹配
       -->
      <tx:method name="updateUser" propagation="REQUIRED"/>
      <!-- 
        给save*方法配置事务属性
          name="save*"  表示给save字符串打头的方法配置事务属性
       -->
      <tx:method name="save*" propagation="REQUIRED"/>
      <tx:method name="update*" propagation="REQUIRES_NEW"/>
      <tx:method name="delete*" propagation="REQUIRED"/>
      <tx:method name="multlTransaction" propagation="REQUIRES_NEW"/>
      <!-- 
        <tx:method name="*"/> 所有的方法
          read-only="true" 剩下的方法都是查询操作。
       -->
      <tx:method name="*" read-only="true"/>
    </tx:attributes>
  </tx:advice>
  <aop:config>
    <!-- 
      aop:advisor 配置通知
     -->
    <aop:advisor advice-ref="tx_advice" 
      pointcut="execution(public * com.service..*Service*.*(..))"/>
  </aop:config>
</beans>

Spring框架：第八章：声明式事务

热门文章

最新文章

相关课程

相关电子书

相关实验场景