阅读数:81 评论数:0

一、概述

1、事务

事务就是一组操作数据库的动作集合，集合中的动作要么全部执行，要么全部不执行。

2、事务特点（ACID）

二、事务的实现方式

1、mysql事务的实现方式

（1）原子性和持久性利用redo log(重做日志)实现。

（2）一致性利用undo log（回滚日志）实现。

（3）隔离性利用锁来实现。

（4）innodb引擎支持事务，myisam不支持事务

2、springboot实现的方式

spring事务管理分为编码式和声明式两种：

（1）编码式

使用TransactionTemplate或者直接使用底层的PlatformTransactionManager。

PlatformTransactionManager接口中定义了创建、提交和回滚事务的方法：

@Autowired
DataSourceTransactionManager dataSourceTransactionManager;
@Autowired
TransactionDefinition transactionDefinition;
 
// 手动创建事务
TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
 
// 手动提交事务
dataSourceTransactionManager.commit(transactionStatus);
 
// 手动回滚事务。(最好是放在catch 里面，防止程序异常而事务一直卡在哪里未提交)
dataSourceTransactionManager.rollback(transactionStatus);

常用的实现类比如DataSourceTransactionalManager，它对应的是传统的JDBC事务管理。

（2）声明式：基于AOP

对方法前后进行拦截，在目标方法之前创建或者加入一个事务，方法执行之后根据执行情况提交或回滚事务。声明式事务有两种方式，一种是在配置文件中做相关的事务规则声明，另一种是基于@Transaction注解的方式。

三、@Transactional注解

1、使用注意事项

（1）在具体的类（或类的方法）上使用@Transactional注解，而不要使用在类所要实现的任何接口上。

（2）只能被应用在public修饰的方法上。

（3）基于动态代理，需要一个类调用另一个类，类内调用会失效。

（4）假设被外部调用的公共方法A有两个进行数据操作的方法B和方法C：

（5）如果自已使用的try-catch捕获异常，则回滚不会执行，如果需要try-catch后仍回滚，需要

//手动抛出异常
try{
      ....  
  }catch(Exception e){
      logger.error("fail",e);
      throw new RuntimeException;
}

// 或者手动回滚

try{
      ...
  }catch(Exception e){
      log.error("fail",e);
      TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
      return false;
}

2、常用配置

（1）默认情况下，Spring会对unchecked异常进行事务回滚，也就是默认对RuntimeException异常或者其子类进行事务回滚；如果是checked异常则不会回滚。

例如空指针异常、算数异常都会回滚；但文件读写、网络等异常，则不会回滚。所以若想对所有异常都起作用，需要：

@Transactional(rollbackFor = Exception.class)

3、事务传播行为

Spring在TranscationDefinition接口中规定了7种类型的事务传播行为，Propagation枚举引用了这些类型，开发过程中我们一般直接使用Propagation枚举。

@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true)

4、事务的隔离级别

@Transactional(isolation = Isolation.READ_COMMITTED)

四、常用方式

1、自动回滚（直接抛出异常，不try-catch）

@Override
@Transactional(rollbackFor = Exception.class)
public Object submitOrder() throws Exception {  
     success();  
     //假如exception这个操作数据库的方法会抛出异常，方法success()对数据库的操作会回滚
     exception(); 
     return ApiReturnUtil.success();
}

2、手动回滚

@Override
@Transactional(rollbackFor = Exception.class)
public Object submitOrder (){  
    success();  
    try {  
        exception(); 
     } catch (Exception e) {  
        e.printStackTrace();     
        //手工回滚异常
        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        return ApiReturnUtil.error();
     }  
    return ApiReturnUtil.success();
}

3、回滚部分异常

@Override
@Transactional(rollbackFor = Exception.class)
public Object submitOrder (){  
    success();  
    //只回滚以下异常，设置回滚点
    Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
    try {  
        exception(); 
     } catch (Exception e) {  
        e.printStackTrace();     
        //手工回滚异常，回滚到savePoint
        TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
        return ApiReturnUtil.error();
     }  
    return ApiReturnUtil.success();
}