Transactions in spring

Spring transaction processing

1. What is a transaction?
保证业务操作完整性的一种数据库机制

事务的4特点: A C I D
1. A 原子性
2. C 一致性
3. I 隔离性
4. D 持久性
2. How to control affairs
JDBC:
    Connection.setAutoCommit(false);
    Connection.commit();
    Connection.rollback();
Mybatis:
    Mybatis自动开启事务
    
    sqlSession(Connection).commit();
    sqlSession(Connection).rollback();

结论:控制事务的底层 都是Connection对象完成的。
3. Spring control transaction development
Spring是通过AOP的方式进行事务开发
1. The original object
public class XXXUserServiceImpl{
   private xxxDAO xxxDAO
   set get

   1. 原始对象 ---》 原始方法 ---》核心功能 (业务处理+DAO调用)
   2. DAO作为Service的成员变量,依赖注入的方式进行赋值
}
2. Extra features
1. org.springframework.jdbc.datasource.DataSourceTransactionManager
2. 注入DataSource 
1. MethodInterceptor
   public Object invoke(MethodInvocation invocation){
      try{
        Connection.setAutoCommit(false);
        Object ret = invocation.proceed();
        Connection.commit();
      }catch(Exception e){
        Connection.rollback();
      }
        return ret;
   }
2. @Aspect
   @Around 
3. Entry point
@Transactional 
事务的额外功能加入给那些业务方法。

1. 类上:类中所有的方法都会加入事务
2. 方法上:这个方法会加入事务
4 Assemble the cut surface
1. 切入点
2. 额外功能

<tx:annotation-driven transaction-manager=""/>
4. Spring control transaction coding

Build a development environment (jar)

<dependency>
  <groupId>org.springframework</groupId>
  <artifactId>spring-tx</artifactId>
  <version>5.1.14.RELEASE</version>
</dependency>

coding

<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
  <property name="userDAO" ref="userDAO"/>
</bean>

<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"/>
</bean>

@Transactional
public class UserServiceImpl implements UserService {
    private UserDAO userDAO;

<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>

detail

<tx:annotation-driven transaction-manager="dataSourceTransactionManager" proxy-target-class="true"/>
进行动态代理底层实现的切换   proxy-target-class
    默认 false JDK
        true  Cglib 

Chapter 4: Transaction Attribute in Spring

1. What are transaction attributes
属性:描述物体特征的一系列值
     性别 身高 体重 ...
事务属性:描述事务特征的一系列值 
1. 隔离属性
2. 传播属性
3. 只读属性
4. 超时属性
5. 异常属性 
2. How to add transaction attributes
@Transactional(isloation=,propagation=,readOnly=,timeout=,rollbackFor=,noRollbackFor=,)
3. Detailed explanation of transaction attributes
1. Isolation properties (ISOLATION)

The concept of isolation properties

概念:他描述了事务解决并发问题的特征
1. 什么是并发
       多个事务(用户)在同一时间,访问操作了相同的数据
       
       同一时间:0.000几秒 微小前 微小后
2. 并发会产生那些问题
       1. 脏读
       2. 不可重复读
       3. 幻影读
3. 并发问题如何解决
       通过隔离属性解决,隔离属性中设置不同的值,解决并发处理过程中的问题。

Problems caused by transaction concurrency

Dirty read

一个事务,读取了另一个事务中没有提交的数据。会在本事务中产生数据不一致的问题
解决方案  @Transactional(isolation=Isolation.READ_COMMITTED)

Non-repeatable

一个事务中,多次读取相同的数据,但是读取结果不一样。会在本事务中产生数据不一致的问题
注意:1 不是脏读 2 一个事务中
解决方案 @Transactional(isolation=Isolation.REPEATABLE_READ)
本质: 一把行锁

Phantom reading

一个事务中,多次对整表进行查询统计,但是结果不一样,会在本事务中产生数据不一致的问题
解决方案 @Transactional(isolation=Isolation.SERIALIZABLE)
本质:表锁 

to sum up

并发安全: SERIALIZABLE>REPEATABLE_READ>READ_COMMITTED
运行效率: READ_COMMITTED>REPEATABLE_READ>SERIALIZABLE

Database support for isolation attributes

The value of the isolation attributeMySQLOracle
ISOLATION_READ_COMMITTED
IOSLATION_REPEATABLE_READ
ISOLATION_SERIALIZABLE
Oracle不支持REPEATABLE_READ值 如何解决不可重复读
采用的是多版本比对的方式 解决不可重复读的问题

Default isolation properties

ISOLATION_DEFAULT:会调用不同数据库所设置的默认隔离属性

MySQL : REPEATABLE_READ 
Oracle: READ_COMMITTED  

View database default isolation properties

MySQL

select @@tx_isolation;

Oracle

SELECT s.sid, s.serial#,
   CASE BITAND(t.flag, POWER(2, 28))
      WHEN 0 THEN 'READ COMMITTED'
      ELSE 'SERIALIZABLE'
   END AS isolation_level
FROM v$transaction t 
JOIN v$session s ON t.addr = s.taddr
AND s.sid = sys_context('USERENV', 'SID');

Suggestions for isolation properties in actual combat

推荐使用Spring指定的ISOLATION_DEFAULT
 1. MySQL   repeatable_read
 2. Oracle  read_commited 

未来实战中,并发访问情况 很低 

如果真遇到并发问题,乐观锁 
   Hibernate(JPA)  Version 
   MyBatis         通过拦截器自定义开发
 
2. PROPAGATION

The concept of propagating attributes

概念:他描述了事务解决嵌套问题的特征

什么叫做事务的嵌套:他指的是一个大的事务中,包含了若干个小的事务

问题:大事务中融入了很多小的事务,他们彼此影响,最终就会导致外部大的事务,丧失了事务的原子性

Propagate the value of the attribute and its usage

Propagate the value of the attributeExternal affairsExternal existence transactionusageRemarks
REQUIREDStart a new transactionIntegration into external affairs@Transactional(propagation = Propagation.REQUIRED)Addition, deletion and modification method
SUPPORTSDo not open transactionIntegration into external affairs@Transactional(propagation = Propagation.SUPPORTS)Query method
REQUIRES_NEWStart a new transactionSuspend external affairs and create new ones@Transactional(propagation = Propagation.REQUIRES_NEW)Logging method
NOT_SUPPORTEDDo not open transactionSuspend external affairs@Transactional(propagation = Propagation.NOT_SUPPORTED)And not commonly used
NEVERDo not open transactionThrow an exception@Transactional(propagation = Propagation.NEVER)And not commonly used
MANDATORYThrow an exceptionIntegration into external affairs@Transactional(propagation = Propagation.MANDATORY)And not commonly used

Default propagation properties

REQUIRED是传播属性的默认值

Recommend the use of propagation attributes

增删改 方法:直接使用默认值REQUIRED 
查询   操作:显示指定传播属性的值为SUPPORTS  
3. Read-only attribute (readOnly)
针对于只进行查询操作的业务方法,可以加入只读属性,提供运行效率

默认值:false 
4. Timeout attribute (timeout)
指定了事务等待的最长时间

1. 为什么事务进行等待?
   当前事务访问数据时,有可能访问的数据被别的事务进行加锁的处理,那么此时本事务就必须进行等待。
2. 等待时间 秒
3. 如何应用 @Transactional(timeout=2)
4. 超时属性的默认值 -1 
   最终由对应的数据库来指定
5. Exception properties
Spring事务处理过程中
默认 对于RuntimeException及其子类 采用的是回滚的策略
默认 对于Exception及其子类 采用的是提交的策略

rollbackFor = {java.lang.Exception,xxx,xxx} 
noRollbackFor = {java.lang.RuntimeException,xxx,xx}

@Transactional(rollbackFor = {java.lang.Exception.class},noRollbackFor = {java.lang.RuntimeException.class})

建议:实战中使用RuntimeExceptin及其子类 使用事务异常属性的默认值
4. Summary of common configuration of transaction attributes
1. 隔离属性   默认值 
2. 传播属性   Required(默认值) 增删改   Supports 查询操作
3. 只读属性   readOnly false  增删改   true 查询操作
4. 超时属性   默认值 -1
5. 异常属性   默认值 

增删改操作   @Transactional
查询操作     @Transactional(propagation=Propagation.SUPPORTS,readOnly=true)
5. Tag-based transaction configuration (the second form of transaction development)
基于注解 @Transaction的事务配置回顾
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
  <property name="userDAO" ref="userDAO"/>
</bean>

<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"/>
</bean>

@Transactional(isolation=,propagation=,...)
public class UserServiceImpl implements UserService {
    private UserDAO userDAO;

<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>

基于标签的事务配置
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
  <property name="userDAO" ref="userDAO"/>
</bean>

<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"/>
</bean>

事务属性 
<tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager">
    <tx:attributes>
          <tx:method name="register" isoloation="",propagation=""></tx:method>
          <tx:method name="login" .....></tx:method>
          等效于 
          @Transactional(isolation=,propagation=,)
          public void register(){
        
          }
      
    </tx:attributes>
</tx:advice>

<aop:config>
     <aop:pointcut id="pc" expression="execution(* com.baizhiedu.service.UserServiceImpl.register(..))"></aop:pointcut>
     <aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor>
</aop:config>

Application of label-based transaction configuration in actual combat

<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
  <property name="userDAO" ref="userDAO"/>
</bean>

<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"/>
</bean>

编程时候 service中负责进行增删改操作的方法 都以modify开头
                       查询操作 命名无所谓 
<tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager">
    <tx:attributes>
          <tx:method name="register"></tx:method>
          <tx:method name="modify*"></tx:method>
          <tx:method name="*" propagation="SUPPORTS"  read-only="true"></tx:method>
    </tx:attributes>
</tx:advice>

应用的过程中,service放置到service包中
<aop:config>
     <aop:pointcut id="pc" expression="execution(* com.baizhiedu.service..*.*(..))"></aop:pointcut>
     <aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor>
</aop:config>