spring多数据源事务

 @Override
    //方法使用注解事务,指定asset数据源
    @Transactional(value = "asset", rollbackFor = Throwable.class)
    public void test() {
        //asset数据源,配置了事务管理器
        investMapper.selectById("1");

        investMapper.selectById("2");

        //assetNew数据源,没配置事务管理器
        save();

        select();

        log.info("stop");

    }
方法开始

方法刚进入test方法，还未执行具体逻辑

org.springframework.jdbc.datasource.DataSourceTransactionManager - Creating new transaction with name [com.fengjr.p2p.settle.service.TestService.TestServiceImpl.test]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; 'asset',-java.lang.Throwable
org.springframework.jdbc.datasource.DataSourceTransactionManager - Acquired Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java] for JDBC transaction
org.springframework.jdbc.datasource.DataSourceTransactionManager - Switching JDBC Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java] to manual commit

上面这段日志实际上是由动态代理类打印出来
1.创建事务
2.获取数据库连接a
3.将a设置为手动提交

第一步

执行 investMapper.selectById("1");

org.mybatis.spring.SqlSessionUtils - Creating a new SqlSession
org.mybatis.spring.SqlSessionUtils - Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11]
org.mybatis.spring.transaction.SpringManagedTransaction - JDBC Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java] will be managed by Spring
com.fengjr.p2p.settle.dao.asset.auto.InvestMapper.selectById - ooo Using Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java]
com.fengjr.p2p.settle.dao.asset.auto.InvestMapper.selectById - ==>  Preparing: select ID, AMOUNT, BIDMETHOD, LOANID, PURPOSE, RATE, REPAYMETHOD, STATUS, SUBMITTIME, USERID, DAYS, MONTHS, YEARS, CREDITASSIGNID, ORIGINALAMOUNT, BUYAMOUNT, SOURCE, UPDATE_TIME, PAYTYPE, CURRENTLOANID, COMBINATIONID, COMBINATIONALLOTID, CATEGORY, CATEGORY_ID, TIMEFINISHED from TB_INVEST where ID = ? 
com.fengjr.p2p.settle.dao.asset.auto.InvestMapper.selectById - ==> Parameters: 1(String)
org.mybatis.spring.SqlSessionUtils - Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11]
第二步
org.mybatis.spring.SqlSessionUtils - Fetched SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11] from current transaction
com.fengjr.p2p.settle.dao.asset.auto.InvestMapper.selectById - ooo Using Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java]
com.fengjr.p2p.settle.dao.asset.auto.InvestMapper.selectById - ==>  Preparing: select ID, AMOUNT, BIDMETHOD, LOANID, PURPOSE, RATE, REPAYMETHOD, STATUS, SUBMITTIME, USERID, DAYS, MONTHS, YEARS, CREDITASSIGNID, ORIGINALAMOUNT, BUYAMOUNT, SOURCE, UPDATE_TIME, PAYTYPE, CURRENTLOANID, COMBINATIONID, COMBINATIONALLOTID, CATEGORY, CATEGORY_ID, TIMEFINISHED from TB_INVEST where ID = ? 
com.fengjr.p2p.settle.dao.asset.auto.InvestMapper.selectById - ==> Parameters: 2(String)
org.mybatis.spring.SqlSessionUtils - Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11]
第三步
org.mybatis.spring.SqlSessionUtils - Creating a new SqlSession
org.mybatis.spring.SqlSessionUtils - Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78]
org.springframework.jdbc.datasource.DataSourceUtils - Fetching JDBC Connection from DataSource
org.springframework.jdbc.datasource.DataSourceUtils - Registering transaction synchronization for JDBC Connection
org.mybatis.spring.transaction.SpringManagedTransaction - JDBC Connection [com.dangdang.ddframe.rdb.sharding.jdbc.core.connection.ShardingConnection@5950a15f] will be managed by Spring
c.f.p2p.sharding.repayment.mapper.InvestRepaymentShardingMapper.insertSelective - ooo Using Connection [com.dangdang.ddframe.rdb.sharding.jdbc.core.connection.ShardingConnection@5950a15f]
c.f.p2p.sharding.repayment.mapper.InvestRepaymentShardingMapper.insertSelective - ==>  Preparing: insert into TB_INVEST_REPAYMENT ( ID, CURRENTPERIOD, STATUS, SOURCE_ID, AMOUNTINTEREST, AMOUNTOUTSTANDING, AMOUNTPRINCIPAL, DUEDATE, INVEST_ID, USER_ID, LOAN_ID, TIMEFINISHED ) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) 
c.f.p2p.sharding.repayment.mapper.InvestRepaymentShardingMapper.insertSelective - ==> Parameters: K562369F-98AC-4AE2-9526-DB453FE990D1(String), 6(Integer), REPAYED(String), REPAYED(String), 0.1(BigDecimal), 0.1(BigDecimal), 0.1(BigDecimal), 2018-01-03(String), 17022000-A000-AAA2-07CA-487C9C782066(String), YFDBFA9F-C8B0-499C-AE67-45FD7608858B(String), S062369F-98AC-4AE2-9526-DB453FE990D1(String), 2017090822(String)
org.mybatis.spring.SqlSessionUtils - Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78]
第四步
org.mybatis.spring.SqlSessionUtils - Fetched SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78] from current transaction
c.f.p.sharding.repayment.mapper.InvestRepaymentShardingMapper.selectByCondition - ooo Using Connection [com.dangdang.ddframe.rdb.sharding.jdbc.core.connection.ShardingConnection@5950a15f]
c.f.p.sharding.repayment.mapper.InvestRepaymentShardingMapper.selectByCondition - ==>  Preparing: select ID, CURRENTPERIOD, REPAYAMOUNT, REPAYDATE, STATUS, SOURCE_ID, SOURCE_REALM, AMOUNTINTEREST, AMOUNTOUTSTANDING, AMOUNTPRINCIPAL, DUEDATE, INVEST_ID, USER_ID, LOAN_ID, RELATIVEPERIOD, CREATE_TIME, UPDATE_TIME, CATEGORY, TIMEFINISHED from TB_INVEST_REPAYMENT WHERE ( USER_ID = ? and TIMEFINISHED = ? ) 
c.f.p.sharding.repayment.mapper.InvestRepaymentShardingMapper.selectByCondition - ==> Parameters: UFDBFA9F-C8B0-499C-AE67-45FD7608858B(String), 2018010722(String)
org.mybatis.spring.SqlSessionUtils - Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78]
方法结束
com.fengjr.p2p.settle.service.TestService.TestServiceImpl - stop
org.mybatis.spring.SqlSessionUtils - Transaction synchronization committing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11]
org.mybatis.spring.SqlSessionUtils - Transaction synchronization committing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78]
org.mybatis.spring.SqlSessionUtils - Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11]
org.mybatis.spring.SqlSessionUtils - Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72ca1a11]
org.mybatis.spring.SqlSessionUtils - Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78]
org.mybatis.spring.SqlSessionUtils - Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@40e1df78]
org.springframework.jdbc.datasource.DataSourceUtils - Returning JDBC Connection to DataSource
org.springframework.jdbc.datasource.DataSourceTransactionManager - Initiating transaction commit
org.springframework.jdbc.datasource.DataSourceTransactionManager - Committing JDBC transaction on Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java]
org.springframework.jdbc.datasource.DataSourceTransactionManager - Releasing JDBC Connection [jdbc:mysql://betadb.fengjr.inc:3306/asset?useUnicode=true&characterEncoding=UTF-8, UserName=beta_all@10.254.124.165, MySQL Connector Java] after transaction
org.springframework.jdbc.datasource.DataSourceUtils - Returning JDBC Connection to DataSource

从上面可以看出,
1.虽然assetNew上没是事务,但是
org.mybatis.spring.transaction.SpringManagedTransaction - JDBC Connection [com.dangdang.ddframe.rdb.sharding.jdbc.core.connection.ShardingConnection] will be managed by Spring
2.committing SqlSession不是提交事务！！！
Committing JDBC transaction才是。

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

  • 由浅入深谈论spring事务
    很多人喜欢这篇文章，特此同步过来 由浅入深谈论spring事务 前言 这篇其实也要归纳到《常识》系列中，但这重点又...
    码农戏码阅读 4,775评论 2赞 59
  • Spring事务_06_Spring事务常见问题
    1.Jdbc访问数据库 在默认情况下，dataSource数据源的autoCommit被设置为true,这也意味着...
    老猫头阅读 1,472评论 0赞 6
  • Spring 事务 详解
    1. 关于事务 事务控制就是将一系列操作当成一个不可拆分的逻辑单元，保证这些操作要么都成功，要么都失败。在关系数据...
    七弦桐语阅读 2,916评论 0赞 14
  • Spring事务
    1.事务理解 事务是一系列的动作，它们综合在一起才是一个完整的工作单元，这些动作必须全部完成，如果有一个失败的话，...
    Aimerwhy阅读 333评论 0赞 0
  • 积极的心态
    每天醒来，考虑积极有意义的事，明确自己的目标，不断努力前行，同时能带动影响身边的人一起改变，将是一件无比幸福的事，...
    王奔奔发现阅读 238评论 0赞 1