7.1 事务概述

在JavaEE企业级开发的应用领域，为了保证数据的完整性和一致性，必须引入数据库事务的概念，所以事务管理是企业级应用程序开发中必不可少的技术。
事务就是一组由于逻辑上紧密关联而合并成一个整体(工作单元)的多个数据库操作，这些操作要么都执行，要么都不执行。
事务的四个关键属性(ACID)
○原子性(atomicity)：“原子”的本意是“不可再分”，事务的原子性表现为一个事务中涉及到的多个操作在逻辑上缺一不可。事务的原子性要求事务中的所有操作要么都执行，要么都不执行。
○一致性(consistency)：“一致”指的是数据的一致，具体是指：所有数据都处于满足业务规则的一致性状态。一致性原则要求：一个事务中不管涉及到多少个操作，都必须保证事务执行之前数据是正确的，事务执行之后数据仍然是正确的。如果一个事务在执行的过程中，其中某一个或某几个操作失败了，则必须将其他所有操作撤销，将数据恢复到事务执行之前的状态，这就是回滚。
○隔离性(isolation)：在应用程序实际运行过程中，事务往往是并发执行的，所以很有可能有许多事务同时处理相同的数据，因此每个事务都应该与其他事务隔离开来，防止数据损坏。隔离性原则要求多个事务在并发执行过程中不会互相干扰。
○持久性(durability)：持久性原则要求事务执行完成后，对数据的修改永久的保存下来，不会因各种系统错误或其他意外情况而受到影响。通常情况下，事务对数据的修改应该被写入到持久化存储器中。

7.2 Spring事务管理

image.png

7.2.1 编程式事务管理

①使用原生的JDBC API进行事务管理
[1]获取数据库连接Connection对象
[2]取消事务的自动提交
[3]执行操作
[4]正常完成操作时手动提交事务
[5]执行失败时回滚事务
[6]关闭相关资源
②评价
使用原生的JDBC API实现事务管理是所有事务管理方式的基石，同时也是最典型的编程式事务管理。编程式事务管理需要将事务管理代码嵌入到业务方法中来控制事务的提交和回滚。在使用编程的方式管理事务时，必须在每个事务操作中包含额外的事务管理代码。相对于核心业务而言，事务管理的代码显然属于非核心业务，如果多个模块都使用同样模式的代码进行事务管理，显然会造成较大程度的代码冗余。

7.2.2 声明式事务管理

image.png
大多数情况下声明式事务比编程式事务管理更好：它将事务管理代码从业务方法中分离出来，以声明的方式来实现事务管理。
事务管理代码的固定模式作为一种横切关注点，可以通过AOP方法模块化，进而借助Spring AOP框架实现声明式事务管理。
Spring在不同的事务管理API之上定义了一个抽象层，通过配置的方式使其生效，从而让应用程序开发人员不必了解事务管理API的底层实现细节，就可以使用Spring的事务管理机制。
Spring既支持编程式事务管理，也支持声明式的事务管理。

7.2.3 Spring提供的事务管理器

Spring从不同的事务管理API中抽象出了一整套事务管理机制，让事务管理代码从特定的事务技术中独立出来。开发人员通过配置的方式进行事务管理，而不必了解其底层是如何实现的。
Spring的核心事务管理抽象是PlatformTransactionManager。它为事务管理封装了一组独立于技术的方法。无论使用Spring的哪种事务管理策略(编程式或声明式)，事务管理器都是必须的。
事务管理器可以以普通的bean的形式声明在Spring IOC容器中。

7.2.4 事务管理器的主要实现

①DataSourceTransactionManager：在应用程序中只需要处理一个数据源，而且通过JDBC存取。
②JtaTransactionManager：在JavaEE应用服务器上用JTA(Java Transaction API)进行事务管理
③HibernateTransactionManager：用Hibernate框架存取数据库
image.png

7.3 事务控制—注解

image.png

7.3.1 配置文件

image.png

  1. <context:property-placeholder location="classpath:dbconfig.properties"/>
  2.     <bean id="dataPoolSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  3.         <property name="user" value="${jdbc.user}"></property>
  4.         <property name="password" value="${jdbc.password}"></property>
  5.         <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
  6.         <property name="driverClass" value="${jdbc.driverClass}"></property>
  7.     </bean>
  9. <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  10.         <property name="dataSource" ref="dataPoolSource"></property>
  11.     </bean>
  13.     <tx:annotation-driven transaction-manager="transactionManager"/>

7.3.2 加入注解@Transactional

@Service
public class BookService {

    @Autowired
    BookDao bookDao;

    @Transactional(propagation=Propagation.REQUIRED)
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

    @Transactional(propagation=Propagation.REQUIRED)
    public void updatePrice(String isbn,int price) {
        bookDao.updatePrice(isbn, price);
        int i = 10/0;
    }

7.4 事务细节

image.png

7.4.1 timeout—超时设置

超时事务属性：事务在强制回滚之前可以保持多久。这样可以防止长期运行的事务占用资源。

①注解
设置超过3s超时

@Transactional(timeout=3)
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

②xml
image.png

7.4.2 readOnly—只读事务

只读事务属性: 表示这个事务只读取数据但不更新数据, 这样可以帮助数据库引擎优化事务。

①注解
加快查询速度，不用管事务那一堆操作了。

    @Transactional(readOnly=true)
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

②xml
image.png

7.4.3 noRollBackFor—指定异常不回滚

image.png

@Transactional(noRollbackFor= {ArithmeticException.class,NullPointerException.class})
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

image.png

7.4.4 rollBackFor—指定异常回滚

image.png

@Transactional(rollbackFor= {FileNotFoundException.class})
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

image.png

7.4.5 isolation—调整隔离级别

1、数据库事务并发问题

假设现在有两个事务：Transaction01和Transaction02并发执行。
①脏读
[1]Transaction01将某条记录的AGE值从20修改为30。
[2]Transaction02读取了Transaction01更新后的值：30。
[3]Transaction01回滚，AGE值恢复到了20。
[4]Transaction02读取到的30就是一个无效的值。
②不可重复读
[1]Transaction01读取了AGE值为20。
[2]Transaction02将AGE值修改为30。
[3]Transaction01再次读取AGE值为30，和第一次读取不一致。
③幻读
[1]Transaction01读取了STUDENT表中的一部分数据。
[2]Transaction02向STUDENT表中插入了新的行。
[3]Transaction01读取了STUDENT表时，多出了一些行。

2、隔离级别

数据库系统必须具有隔离并发运行各个事务的能力，使它们不会相互影响，避免各种并发问题。一个事务与其他事务隔离的程度称为隔离级别。SQL标准中规定了多种事务隔离级别，不同隔离级别对应不同的干扰程度，隔离级别越高，数据一致性就越好，但并发性越弱。
①读未提交：READ UNCOMMITTED
允许Transaction01读取Transaction02未提交的修改。
②读已提交：READ COMMITTED
要求Transaction01只能读取Transaction02已提交的修改。
③可重复读：REPEATABLE READ
确保Transaction01可以多次从一个字段中读取到相同的值，即Transaction01执行期间禁止其它事务对这个字段进行更新。
④串行化：SERIALIZABLE
确保Transaction01可以多次从一个表中读取到相同的行，在Transaction01执行期间，禁止其它事务对这个表进行添加、更新、删除操作。可以避免任何并发问题，但性能十分低下。
⑤各个隔离级别解决并发问题的能力见下表


 脏读 不可重复读 幻读
READ UNCOMMITTED 有 有 有
READ COMMITTED 无 有 有
REPEATABLE READ 无 无 有
SERIALIZABLE 无 无 无

⑥各种数据库产品对事务隔离级别的支持程度


 Oracle MySQL
READ UNCOMMITTED × √
READ COMMITTED √ √
REPEATABLE READ × √(默认)
SERIALIZABLE √ √

3、在Spring中指定事务隔离级别

①注解
用@Transactional注解声明式地管理事务时可以在@Transactional的isolation属性中设置隔离级别

@Transactional(isolation=Isolation.READ_COMMITTED)
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

②XML
在Spring 2.x事务通知中，可以在元素中指定隔离级别
image.png

4、在cmd指定事务隔离级别

image.png

image.png

7.4.6 事务的传播行为

1、 简介

当事务方法被另一个事务方法调用时，必须指定事务应该如何传播。例如：方法可能继续在现有事务中运行，也可能开启一个新事务，并在自己的事务中运行。
事务的传播行为可以由传播属性指定。Spring定义了7种类传播行为。
事务传播属性可以在@Transactional注解的propagation属性中定义。
image.png

2、测试

image.png

3、说明

①REQUIRED传播行为
当bookService的purchase()方法被另一个事务方法checkout()调用时，它默认会在现有的事务内运行。这个默认的传播行为就是REQUIRED。因此在checkout()方法的开始和终止边界内只有一个事务。这个事务只在checkout()方法结束的时候被提交，结果用户一本书都买不了。
image.png

②REQUIRES_NEW传播行为
表示该方法必须启动一个新事务，并在自己的事务内运行。如果有事务在运行，就应该先挂起它。

image.png

4、在Spring中设置传播事务属性

①注解

@Transactional(propagation=Propagation.REQUIRED)
    public void checkout(String username,String isbn)  {

        bookDao.updateStock(isbn);

        int price = bookDao.getPrice(isbn);
        bookDao.updateBalance(username, price);
    }

②xml
在Spring 2.x事务通知中，可以像下面这样在元素中设定传播事务属性。
image.png

5、异常崩溃

image.png

由于D在遇到10/0的异常错误的时候就已经开启了新的事务溜走了所以不会收到崩溃的影响。

image.png

image.png

7.5 事务控制—xml

image.png

<?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.0.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-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.hao"></context:component-scan>

    <context:property-placeholder location="classpath:dbconfig.properties"/>
    <bean id="dataPoolSource" 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>
    </bean>

    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg name="dataSource" ref="dataPoolSource"></constructor-arg>
    </bean>




    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataPoolSource"></property>
    </bean>

    <bean id="bookService" class="com.hao.service.BookService"></bean>

    <aop:config>
        <aop:pointcut expression="execution(* com.hao.service.*.*(..))" id="txPoint"/>
<!--         事务建议；事务增强 advice-ref：指向事务管理器的配置 -->
        <aop:advisor advice-ref="myAdvice" pointcut-ref="txPoint"/>
    </aop:config>

<!--     配置事务管理器 
transaction-manager="transactionManager"：指定是配置哪个事务管理器
-->
    <tx:advice id="myAdvice" transaction-manager="transactionManager">
<!--     事务属性 -->
        <tx:attributes>
<!--         指明哪些方法是事务方法；切入点表达式只是事务管理器要切入这些方法，哪些方法加事务使用tx：method指定的 -->
<!--         *表示所有方法都加事务 -->
            <tx:method name="*"/>
            <tx:method name="checkout" propagation="REQUIRED" />
            <tx:method name="get*" read-only="true"/>
        </tx:attributes>
    </tx:advice>

</beans>