From 5015aa5e835176f3d12dd0472820f173782164d8 Mon Sep 17 00:00:00 2001 From: ajaxfan <909938737@qq.com> Date: Sun, 7 Feb 2021 15:00:19 +0800 Subject: [PATCH] debug --- .../project/config/DataSourceProxyConfig.java | 35 +++++++++++++++++++ .../impl/ProjectSectionServiceImpl.java | 1 - 2 files changed, 35 insertions(+), 1 deletion(-) create mode 100644 src/main/java/com/chinaunicom/mall/ebtp/project/config/DataSourceProxyConfig.java diff --git a/src/main/java/com/chinaunicom/mall/ebtp/project/config/DataSourceProxyConfig.java b/src/main/java/com/chinaunicom/mall/ebtp/project/config/DataSourceProxyConfig.java new file mode 100644 index 0000000..39bbe11 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/project/config/DataSourceProxyConfig.java @@ -0,0 +1,35 @@ +package com.chinaunicom.mall.ebtp.project.config; + +import javax.sql.DataSource; + +import org.apache.ibatis.session.SqlSessionFactory; +import org.mybatis.spring.SqlSessionFactoryBean; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import com.alibaba.druid.pool.DruidDataSource; + +import io.seata.rm.datasource.DataSourceProxy; + +@Configuration +public class DataSourceProxyConfig { + + @Bean + @ConfigurationProperties(prefix = "spring.datasource") + public DataSource dataSource() { + return new DruidDataSource(); + } + + @Bean + public DataSourceProxy dataSourceProxy(DataSource dataSource) { + return new DataSourceProxy(dataSource); + } + + @Bean + public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception { + SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); + sqlSessionFactoryBean.setDataSource(dataSourceProxy); + return sqlSessionFactoryBean.getObject(); + } +} \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/project/projectsection/service/impl/ProjectSectionServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/project/projectsection/service/impl/ProjectSectionServiceImpl.java index ed82462..8ed61c4 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/project/projectsection/service/impl/ProjectSectionServiceImpl.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/project/projectsection/service/impl/ProjectSectionServiceImpl.java @@ -267,7 +267,6 @@ public class ProjectSectionServiceImpl extends BaseServiceImpl sectionIds) { log.info("xid 2021-02-07:"+ RootContext.getXID()); UpdateWrapper updateWrapper = new UpdateWrapper<>();