Spring Cloud + Mybatis 多数据源配置

最近接手了一个Spring Cloud + Mybatis架构的项目，本身用的是sqlserver的数据库，因为业务需要，需要连接另一个项目的mysql数据库，于是就想到了多数据源配置，费了些时间，终于弄好了，现把流程和注意事项mark一下。

1.首先是Application要加上exclude = {DataSourceAutoConfiguration.class}，禁用数据库自动配置。

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@EnableTransactionManagement
public class PromoApiApplication {public static void main(String[] args) {SpringApplication.run(PromoApiApplication.class, args);}
}

2.接下来是第一个数据源配置文件

@Configuration
@MapperScan(basePackages = {"com.xxxxx.xxxx.api.mapper.hos"},sqlSessionFactoryRef = "sqlSessionFactoryHosDataSource")
public class MybatisHosConfig {/*** 自动读取DataSource配置文件* @return*/@Primary@Bean(name = "hosProperties")public DataSourceProperties hosProperties() {return new DataSourceProperties();}/*** 添加@Primary注解，设置默认数据源，事务管理器* @return*/@Primary@Bean(name = "hosDataSource")@ConfigurationProperties("spring.datasource.hos")public DataSource hosDataSource(@Qualifier("hosProperties") DataSourceProperties properties) {DataSource dataSource = properties.initializeDataSourceBuilder().type(DruidDataSource.class).build();return dataSource;}@Primary@Bean(name = "sqlSessionFactoryHosDataSource")public SqlSessionFactory sqlSessionFactoryHosDataSource(@Qualifier("hosDataSource")DataSource hosDataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();configuration.setMapUnderscoreToCamelCase(true);factoryBean.setConfiguration(configuration);// 使用hosDataSource数据源, 连接hosDataSource库factoryBean.setDataSource(hosDataSource);//下边两句仅仅用于*.xml文件，如果整个持久层操作不需要使用到xml文件的话（只用注解就可以搞定），则不加//指定entity和mapper。xml的路径factoryBean.setTypeAliasesPackage("com.xxxx.xxxx.api.entity.hos");factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/hos/*Mapper.xml"));return factoryBean.getObject();}@Primary@Beanpublic SqlSessionTemplate sqlSessionTemplateHosDataSource(@Qualifier("sqlSessionFactoryHosDataSource") SqlSessionFactory sqlSessionTemplateHosDataSource) throws Exception {//使用注解中配置的FactorySqlSessionTemplate template = new SqlSessionTemplate(sqlSessionTemplateHosDataSource);return template;}@Primary@Beanpublic PlatformTransactionManager hosTransactionManager(@Qualifier("hosDataSource") DataSource prodDataSource) {return new DataSourceTransactionManager(prodDataSource);}
}

3.第二个数据源

@Configuration
@MapperScan(basePackages = {"com.xxxx.xxx.api.mapper.market"},sqlSessionFactoryRef = "sqlSessionFactoryMarketDataSource")
public class MybatisMarketConfig {/*** 自动读取DataSource配置文件* @return*/@Bean(name = "marketProperties")@ConfigurationProperties("spring.datasource.market")public DataSourceProperties hosProperties() {return new DataSourceProperties();}@Bean(name = "marketDataSource")public DataSource marketDataSource(@Qualifier("marketProperties") DataSourceProperties properties) {DataSource dataSource = properties.initializeDataSourceBuilder().type(DruidDataSource.class).build();return dataSource;}@Bean(name = "sqlSessionFactoryMarketDataSource")public SqlSessionFactory sqlSessionFactoryMarketDataSource(@Qualifier("marketDataSource")DataSource marketDataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();configuration.setMapUnderscoreToCamelCase(true);factoryBean.setConfiguration(configuration);// 使用marketDataSource数据源, 连接marketDataSource库factoryBean.setDataSource(marketDataSource);//下边两句仅仅用于*.xml文件，如果整个持久层操作不需要使用到xml文件的话（只用注解就可以搞定），则不加factoryBean.setTypeAliasesPackage("com.xxx.xxxx.api.entity.market");factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/market/*Mapper.xml"));return factoryBean.getObject();}@Beanpublic SqlSessionTemplate sqlSessionTemplateMarketDataSource(@Qualifier("sqlSessionFactoryMarketDataSource") SqlSessionFactory sqlSessionFactoryMarketDataSource) throws Exception {SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactoryMarketDataSource);return template;}@Beanpublic PlatformTransactionManager marketTransactionManager(@Qualifier("marketDataSource") DataSource sitDataSource) {return new DataSourceTransactionManager(sitDataSource);}
}

4.yml配置文件如下：

项目结构图如下：

其中要注意mybatis的entity，mapper，mapper.xml的路径，两个数据源要分开，在datasourcesconfig中路径都要手动声明且路径书写正确。

因为在声明datasource的时候加了@primary注解，所以事务管理的时候会默认使用这个TransactionManager去管理事务。

在要使用第二个事务管理的service上要加@Transactional(value = "marketTransactionManager")去管理事务。这就是使用方法。

好了，大家有兴趣的就去试试吧。

Spring Cloud + Mybatis 多数据源配置相关推荐

java+++多数据源配置,Spring Cloud + Mybatis 多数据源配置
项目开发中遇到缺陷,使用多数据源能避免分库间数据同步的步骤,在此记录配置步骤. 一.数据源自动配置禁用 1.将spring boot自带的DataSourceAutoConfiguration禁掉,防 ...
【Spring Cloud】多数据源配置
引言从8月份到现在,团队一直有一项资源整合迁移的任务.简单来说,原来的产品设计规划不合理,各业务组各做各的,导致各类核心数据分散于各个业务组.8月初资源整合方案落地并开始实施,我们组承担起了管控各类 ...
Spring集成Mybatis多数据源配置
既然在整理Mybatis那就把经常用的这个多数据源的笔记也整一下吧. Spring集成Mybatis在之前就已经提到了.Spring集成Mybatis 集成Mybatis多数据源有两种方式: 1.创建 ...
Spring MVC+Mybatis 多数据源配置
文章来自:https://www.jianshu.com/p/fddcc1a6b2d8 1. 继承AbstractRoutingDataSource AbstractRoutingDataSource ...
spring mybatis 多数据源配置 jeesite 多数据源配置
spring mybatis 多数据源配置 jeesite 多数据源配置一.情景描述在系统数据达到一定的访问量时,遇到单个数据库瓶颈,所以需要扩展数据库,启用第二个数据源资源,项目架构变成一个服 ...
MyBatis多数据源配置(读写分离)
MyBatis多数据源配置(读写分离) 首先说明,本文的配置使用的最直接的方式,实际用起来可能会很麻烦. 实际应用中可能存在多种结合的情况,你可以理解本文的含义,不要死板的使用. 多数据源的可能情况 ...
Spring Cloud: .yml属性文件配置 (完善中)
服务消费端 server:port: 8080 spring:application:name: orderservice # spring cloud 服务名称# 数据源datasource:dri ...
Spring Cloud【Finchley】实战-06使用/actuator/bus-refresh端点手动刷新配置 + 使用Spring Cloud Bus自动更新配置
文章目录概述特别注意版本信息使用@RefreshScope + /actuator/bus-refresh端点手动刷新配置 Step1. 添加依赖 Step2. 配置RabbitMQ信息 Ste ...
spring cloud gateway的stripPrefix配置
序本文主要研究下spring cloud gateway的stripPrefix配置使用zuul的配置 zuul:routes:demo:sensitiveHeaders: Access-Cont ...

Spring Cloud + Mybatis 多数据源配置

Spring Cloud + Mybatis 多数据源配置相关推荐

最新文章

热门文章