使用

使用 SpringBoot 建立一个测试项目.

sql

  1. create database test;
  2. -- auto-generated definition
  3. create table test_transaction
  4. (
  5.   id    int auto_increment
  6.     primary key,
  7.   name  varchar(16) default ''              not null,
  8.   email varchar(24) default ''              not null,
  9.   birth timestamp default CURRENT_TIMESTAMP not null
  10.   on update CURRENT_TIMESTAMP
  11. )
  12.   engine = InnoDB;

DataSource

  1. /**
  2.  * @author chenshun00@gmail.com
  3.  * @since 2019/5/4
  4.  */
  5. @Configuration
  6. @EnableTransactionManagement(proxyTargetClass = true) // 开启事务
  7. public class DataSourceConfig implements EnvironmentAware {
  8.     private Environment environment;
  10.     @Bean(initMethod = "init", destroyMethod = "close")
  11.     public DataSource dataSource() {
  12.         DruidDataSource druidDataSource = new DruidDataSource();
  13.         druidDataSource.setUsername(this.environment.getProperty("spring.datasource.username"));
  14.         druidDataSource.setPassword(this.environment.getProperty("spring.datasource.password"));
  15.         druidDataSource.setUrl(this.environment.getProperty("spring.datasource.url"));
  16.         druidDataSource.setDriverClassName(this.environment.getProperty("spring.datasource.driver-class-name"));
  17.         druidDataSource.setDbType(this.environment.getProperty("spring.datasource.type"));
  18.         druidDataSource.setInitialSize(Integer.parseInt(this.environment.getProperty("spring.datasource.initialSize")));
  19.         druidDataSource.setMaxActive(Integer.parseInt(this.environment.getProperty("spring.datasource.maxActive")));
  20.         druidDataSource.setMaxWait(Integer.parseInt(this.environment.getProperty("spring.datasource.maxWait")));
  21.         druidDataSource.setValidationQuery(this.environment.getProperty("spring.datasource.validationQuery"));
  22.         druidDataSource.setTestWhileIdle(Boolean.parseBoolean(this.environment.getProperty("spring.datasource.testWhileIdle")));
  23.         druidDataSource.setTestOnBorrow(Boolean.parseBoolean(this.environment.getProperty("spring.datasource.testOnBorrow")));
  24.         druidDataSource.setTestOnReturn(Boolean.parseBoolean(this.environment.getProperty("spring.datasource.testOnReturn")));
  25.         return druidDataSource;
  26.     }
  29.     @Override
  30.     public void setEnvironment(Environment environment) {
  31.         this.environment = environment;
  32.     }
  33. }

例子

SQL语句使用 wireshark 抓取. 源代码地址: https://github.com/chenshun00/mysql-transaction/

  • checked异常回滚

    • NullPointException

    • RuntimeException…

      1.    set autocommit = 0
      2.    INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:20:37.209')
      3.    rollback
      4.    SET autocommit=1
      6.    @Transactional
      7.    public void testUncheckedExceptionRollback() {
      8.        testTransactionDao.addTestTransaction(build());
      9.        throw new NullPointerException("测试checked异常会滚");
      10.    }

  • unchecked异常不回滚

    • SQLException

    • other exception…

      1.    set autocommit = 0
      2.    INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:20:37.209' )
      3.    SET autocommit=1
      5.    @Transactional
      6.    public void testCheckedException() throws SQLException {
      7.        testTransactionDao.addTestTransaction(build());
      8.        throw new SQLException("ggg");
      9.    }

  • 指定异常回滚

    @Transactional(rollbackFor = {SQLException.class})

  1.         set autocommit = 0
  2.         INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:20:37.209' )
  3.         rollback
  4.         SET autocommit=1
  6.         @Transactional(rollbackFor = {SQLException.class})
  7.         public void testCheckedExceptionRollback() throws SQLException {
  8.             testTransactionDao.addTestTransaction(build());
  9.             throw new SQLException("ggg");
  10.         }

  • 嵌套方法(无异常)

    1.       --nest method 共插入2条记录 sql
    2.       SET autocommit=0
    3.       select @@session.tx_read_only
    4.       INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:47:00.572' )
    5.       select @@session.tx_read_only
    6.       INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:47:00.635' )
    7.       commit
    8.       SET autocommit=1
    10.       @Transactional
    11.       public void testNestMethod() {
    12.           //insert
    13.           testTransactionDao.addTestTransaction(build());
    14.           this.subMethod();
    15.       }
    17.       private void subMethod() {
    18.           testTransactionDao.addTestTransaction(build());
    19.       }

  • 嵌套方法带checked异常

    1.       --子方法出现运行运行时异常，回滚
    2.       SET autocommit=0
    3.       select @@session.tx_read_only
    4.       SELECT @@session.tx_isolation
    5.       INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:57:47.05' )
    6.       INSERT INTO test_transaction ( name,email,birth ) VALUES ( 'chenshun00','chenshun00@gmail.com','2019-05-04 14:57:47.141' )
    7.       rollback
    8.       SET autocommit=1
    10.       @Transactional
    11.       public void testNestMethodRuntimeException() {
    12.           testTransactionDao.addTestTransaction(build());
    13.           this.subExceptionMethod();
    14.       }
    16.       private void subExceptionMethod() {
    17.           testTransactionDao.addTestTransaction(build());
    18.           throw new NullPointerException("运行时异常测试");
    19.       }

  • 嵌套方法带unchecked异常.

    1.       set autocommit = 1
    2.       select @@session.tx_read_only
    3.       SELECT @@session.tx_isolation
    4.       set autocommit = 0
    5.       insert sql语句
    6.       insert sql语句
    7.       commit
    8.       set autocommit = 1
    10.       @Transactional
    11.       public void testNestMethodUncheckException() throws SQLException {
    12.           testTransactionDao.addTestTransaction(build());
    13.           this.subUncheckExceptionMethod();
    14.       }
    16.       private void subUncheckExceptionMethod() throws SQLException {
    17.           testTransactionDao.addTestTransaction(build());
    18.           throw new SQLException("运行时异常测试");
    19.       }

  • 嵌套方法指定异常回滚

    1.       set autocommit = 1
    2.       select @@session.tx_read_only
    3.       SELECT @@session.tx_isolation
    4.       set autocommit = 0
    5.       insert sql语句
    6.       insert sql语句
    7.       rollback
    8.       set autocommit = 1
    10.       @Transactional(rollbackFor = {SQLException.class})
    11.       public void testNestMethodUncheckExceptionRollback() throws SQLException {
    12.           testTransactionDao.addTestTransaction(build());
    13.           this.subUncheckExceptionMethodRollback();
    14.       }
    16.       private void subUncheckExceptionMethodRollback() throws SQLException {
    17.           testTransactionDao.addTestTransaction(build());
    18.           throw new SQLException("运行时异常测试");
    19.       }

  • this 调用无事务

    1.   /**
    2.    * 测试调用未开启事务，直接是一条sql一个事务提交
    3.    * 没有事务原因:没有Transactional注解，没有进入proxy代理当中，没有进入代码当中就进入不了事务,
    4.    * this调用还是没有事务，这里如果要产生事务就需要获取当前(this)对象当proxy对象，再进行方法调用会产生事务
    5.    */
    6.   public void testMainMethodNoTransactionRuntimeException() {
    7.       this.subMethodTransactionRuntimeException();
    8.   }
    10.   @Transactional
    11.   public void subMethodTransactionRuntimeException() {
    12.       testTransactionDao.addTestTransaction(build());
    13.       throw new NullPointerException("11");
    14.   }

  • this 调用带事务

    1.   /**
    2.    * proxy代理调用产生事务
    3.    * 需要配置 @EnableAspectJAutoProxy(proxyTargetClass = true, exposeProxy = true)
    4.    */
    5.   public void testProxyObjectGetTransaction() throws SQLException {
    6.       ((TestTransactionService) AopContext.currentProxy()).testProxyObjectGetTransactionSubMethod();
    7.   }
    9.   @Transactional(rollbackFor = {SQLException.class})
    10.   public void testProxyObjectGetTransactionSubMethod() throws SQLException {
    11.       testTransactionDao.addTestTransaction(build());
    12.       throw new SQLException("11");
    13.   }

  • 多Transactional注解

    1.   /**
    2.    * 事务1
    3.    * <p>
    4.    * set autocommit = 0
    5.    * insert
    6.    * insert
    7.    * commit
    8.    * set autocommit = 1
    9.    */
    10.   @Transactional
    11.   public void firstTransaction() {
    12.       testTransactionDao.addTestTransaction(build());
    13.       this.secondTransaction();
    14.   }
    16.   /**
    17.    * 事务2
    18.    */
    19.   @Transactional
    20.   public void secondTransaction() {
    21.       testTransactionDao.addTestTransaction(build());
    22.   }

总结

自己多试试，抓包看本质.