开发者社区 > 云原生 > 正文

seata集成mybatis或者tkmybatis问题本地事物和全局事务冲突

springboot 2.0 mybatis 3.4.4 seata 0.6.1

1、本地@transactional事务开启

mapper.insertSelective(Oblect)可以从Oblect.getId()获取自增id 单独加上全局事务@GlobalTransactiona从Oblect.getId()获取的却是undo_log的自增id

2、factoryBean.setTransactionFactory(new JdbcTransactionFactory()); 这样配置的话,本地事务@transactional无法回滚,必须配置DataSourceTransactionManager 配置seata的数据源代理才行

@bean public SqlSessionFactory sqlSessionFactory(DataSourceProxy dataSourceProxy) throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); factoryBean.setDataSource(dataSourceProxy); factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources("classpath*:/mapper/*.xml")); // factoryBean.setTransactionFactory(new JdbcTransactionFactory()); factoryBean.setTransactionFactory(new SpringManagedTransactionFactory()); org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration(); configuration.setMapUnderscoreToCamelCase(true); factoryBean.setConfiguration(configuration); return factoryBean.getObject(); }

@bean @primary public DataSourceTransactionManager dataSourceTransactionManager(DataSourceProxy dataSourceProxy){ DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(); transactionManager.setDataSource(dataSourceProxy); return transactionManager; }

还想知道:本地事物和全局事务兼容,seata和mybatis示例

环境信息:

JDK version : 1.8 OS : Others:

原提问者GitHub用户Empty66

展开
收起
学习娃 2023-06-14 16:43:33 51 0
1 条回答
写回答
取消 提交回答
  • 上面问题都已解决,wiki上面建议提供接入mybatis+sptingboot:

    1、对于本地事物@transactional和全局事务冲突问题: 配置calss类需要加上以下配置:配置事务管理器数据源为seata数据代理

    /** * spring事务配置数据源代理 * @param dataSourceProxy * @return */ @Bean @Primary public DataSourceTransactionManager dataSourceTransactionManager(DataSourceProxy dataSourceProxy){ DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(); transactionManager.setDataSource(dataSourceProxy); return transactionManager; }

    并且 factoryBean.setTransactionFactory(new SpringManagedTransactionFactory()); 必须配置成 SpringManagedTransactionFactory,因为mybatis默认用SpringManagedTransactionFactory

    /** * 替换 mybatis 的sqlSessionFactory,用数据源代理替换自动装配的数据源 * @Param: dataSourceProxy fescar数据源代理 * @Return: SqlSessionFactory mybatic使用的数据源 / @Bean public SqlSessionFactory sqlSessionFactory(DataSourceProxy dataSourceProxy) throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); factoryBean.setDataSource(dataSourceProxy); factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources("classpath:/mapper/*.xml")); // factoryBean.setTransactionFactory(new JdbcTransactionFactory()); //这个不可用 factoryBean.setTransactionFactory(new SpringManagedTransactionFactory()); org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration(); configuration.setMapUnderscoreToCamelCase(true); factoryBean.setConfiguration(configuration); return factoryBean.getObject(); }

    2、对于返回自增id是undo_log的自增id,解决方案如下: 可以在生成的xml文件的insert加上: useGeneratedKeys="true" keyProperty="id"

    tkmybatis的话需要在生成的映射对象类的id上配置generator = "JDBC"如下:

        @Table(name = "xxx_credit_apply")
        @Setter
        @Getter
         public class XxxCreditApplyPo {
             @Id
             @GeneratedValue(generator = "JDBC")
              private Long id;
          }
    

    原回答者GitHub用户Empty66

    2023-06-14 17:19:34
    赞同 展开评论 打赏

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

相关电子书

更多
集成智能接入网关APP:优化企业级移动办公网络 立即下载
Java Spring Boot开发实战系列课程【第6讲】:Spring Boot 2.0实战MyBatis与优化(Java面试题) 立即下载
云效助力企业集成安全到DevOps中 立即下载