场景

在日常开发过程中，大家经常使用到的spring事务管理，保证更新和新增要么全部成功，要么全部失败；
但是在某些场景中，需要保证执行的sql在同一条事务中，使用mysql自带的语句可以实现；

begin;
UPDATE table SET max_id=max_id+step WHERE biz_tag=xxx;
SELECT tag, max_id, step FROM table WHERE biz_tag=xxx;
commit;

如上所述场景，需要更新完立马查询更新的内容，而此时并不能保证是否有其他人在修改当前记录，只有开启事务来保证获取到最新的数据；

实现

使用mybatis的sqlSession可以在代码中实现这种目的，话不多说上代码；

• 配置sqlSession

import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import javax.sql.DataSource;

@Configuration
public class DataSourceConfig {

    @Autowired
    private DataSource dataSource;

    @Bean
    public SqlSessionFactory sqlSessionFactory() throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        PathMatchingResourcePatternResolver resourcePatternResolver = new PathMatchingResourcePatternResolver();
        sqlSessionFactoryBean.setMapperLocations(resourcePatternResolver.getResource("classpath:/mapping/GeneratorMapper.xml"));
        // 需要注意，事务依靠jdbc事务
        sqlSessionFactoryBean.setTransactionFactory(new JdbcTransactionFactory());
        return sqlSessionFactoryBean.getObject();
    }
}

• 使用

    @Test
    void testTransaction(){
        List<String> list = Lists.newArrayList("111", "222", "333");
        // 开启事务
        SqlSession sqlSession = sqlSessionFactory.openSession(false);
        // 从sqlSession中获取mapper
        GeneratorMapper mapper = sqlSession.getMapper(GeneratorMapper.class);
        mapper.insertGenerator(list);
        // 测试回滚和提交
        sqlSession.rollback();
        // sqlSession.commit();
    }

• 最后
  test中代码可以当作Service中代码来实现；