SpringBootMybatisPlusDruid多数据源项目

写在前面&＃xff1a;本文主要介绍SpringBoot MybatisPlus和Druid这些组件下&＃xff0c;如何创建多数据源(DataSource)的web项目。写这篇博客的原因就是我在搜索同类型的问题的时候&＃xff0c;其他人写的博客非常不清晰&＃xff0c;完全无法按照介绍的步骤来实现。我希望我写的这篇博客可以真的替看这篇博客的人能解决这类问题。如果你看完之后还是没有解决可以评论留言&＃xff0c;甚至加我的微信(JB328258)帮你解决。因为我觉得我们中国人写技术博客有的时候太敷衍了&＃xff0c;不要把博客当成一个记事本。而是要真正对不管是行业还是同样的从业人员有价值才有意义。

背景: 我们的web项目需要读取两个数据库里面的表的数据&＃xff0c;然后就有了这个需求。但是我在网上搜索解决方法&＃xff0c;很多人的博客都是写的连接两个数据源&＃xff0c;并且还通过AOP动态切换数据源&＃xff0c;但是我认为这种使用场景应该是非常非常少的。一般情况下的应用场景都是表的数据在多个库里面。然后web项目需要读多个库的数据进行汇合。

正文:

第一步&＃xff1a;引入对于的SpringBoot MybatisPlus Druid的Jar包。这一步不赘述&＃xff0c;网上示例很多。

第二步:  填写多个数据源的相关配置&＃xff0c;如JDBC的连接地址&＃xff0c;JDBC的数据库等。

           1. cmdb代表一个数据库。

           2. compass代表一个数据库。

spring:datasource:cmdb:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://192.168.60.11:3306/cmdb_docker?useUnicode&＃61;true&characterEncoding&＃61;utf8&zeroDateTimeBehavior&＃61;convertToNullusername: YourXXXpassword: YourXXXinitial-size: 0min-idle: 1max-active: 20max-wait: 60000remove-abandoned: trueremove-abandoned-timeout: 180time-between-eviction-runs-millis: 60000min-evictable-idle-time-millis: 300000test-while-idle: truetest-on-borrow: falsetest-on-return: falsefilters: stat,wall,log4j2compass:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://192.168.60.11:3306/compass?useUnicode&＃61;true&characterEncoding&＃61;utf8&zeroDateTimeBehavior&＃61;convertToNullusername: YourXXXpassword: YourXXXinitial-size: 0min-idle: 1max-active: 20max-wait: 60000remove-abandoned: trueremove-abandoned-timeout: 180time-between-eviction-runs-millis: 60000min-evictable-idle-time-millis: 300000test-while-idle: truetest-on-borrow: falsetest-on-return: falsefilters: stat,wall,log4j2


第三步&＃xff1a;创建对应的MybatisPlus的分页插件如下

&＃64;Configuration
public class MybatisPlusConfig {/*** 分页插件* &＃64;return*/&＃64;Beanpublic PaginationInterceptor paginationInterceptor(){PaginationInterceptor page &＃61; new PaginationInterceptor();page.setDialectType("mysql");return page;}}


第四步&＃xff1a;分别创建两个DataSource对应的Config&＃xff0c;注意看下面代码里面的备注&＃xff0c;比较重要。

4.1 创建第一个DataSource的Config

//创建Compass数据的DataSource数据源
&＃64;Configuration
// basePackages 是扫描的Compass库对应的Mapper
&＃64;MapperScan(basePackages &＃61; "com.ximalaya.compass.core.mapper",sqlSessionFactoryRef &＃61; "compassFactory")
public class CompassDataSourceConfig {&＃64;AutowiredPaginationInterceptor paginationInterceptor;&＃64;Bean(name&＃61;"compass")&＃64;ConfigurationProperties("spring.datasource.compass")public DataSource createCmdbDataSource(){return new DruidDataSource();}&＃64;Bean(name &＃61; "compassFactory")public SqlSessionFactory createCompassFactory(&＃64;Qualifier("compass") DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean &＃61; new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);//这里是配置Mybatis的ConfigurationMybatisConfiguration configuration &＃61; new MybatisConfiguration();configuration.setJdbcTypeForNull(JdbcType.NULL);configuration.setMapUnderscoreToCamelCase(true);configuration.setCacheEnabled(false);factoryBean.setConfiguration(configuration);//这里是添加Mybatis的分页插件factoryBean.setPlugins(new Interceptor[]{paginationInterceptor});//这里是填写Compass这个库对应的Mapper.xml文件factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis-compass/*.xml"));return factoryBean.getObject();}&＃64;Bean(name &＃61; "compassSqlSessionTemplate")public SqlSessionTemplate createCompassSqlSessionTemplate(&＃64;Qualifier("compassFactory") SqlSessionFactory sqlSessionFactory){return new SqlSessionTemplate(sqlSessionFactory);}}

4.2 创建第二个DataSource的Config

&＃64;Configuration
&＃64;MapperScan(basePackages &＃61; "com.ximalaya.compass.collector.mapper",sqlSessionFactoryRef &＃61; "cmdbFactory")
public class CmdbDockerDataSourceConfig {&＃64;AutowiredPaginationInterceptor paginationInterceptor;&＃64;Bean(name&＃61;"cmdb_docker")&＃64;ConfigurationProperties("spring.datasource.cmdb")public DataSource createCmdbDataSource(){return new DruidDataSource();}&＃64;Bean(name &＃61; "cmdbFactory")public SqlSessionFactory createCmdbFactory(&＃64;Qualifier("cmdb_docker") DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean &＃61; new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);MybatisConfiguration configuration &＃61; new MybatisConfiguration();configuration.setJdbcTypeForNull(JdbcType.NULL);configuration.setMapUnderscoreToCamelCase(true);configuration.setCacheEnabled(false);factoryBean.setConfiguration(configuration);factoryBean.setPlugins(new Interceptor[]{paginationInterceptor});factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis-cmdb/*.xml"));return factoryBean.getObject();}&＃64;Bean(name &＃61; "cmdbSqlSessionTemplate")public SqlSessionTemplate createCmdbSqlSessionTemplate(&＃64;Qualifier("cmdbFactory") SqlSessionFactory sqlSessionFactory){return new SqlSessionTemplate(sqlSessionFactory);}}


结尾&＃xff1a;至此所有的创建和修改都完成&＃xff0c;启动SpringBoot项目使用对应的Service就可以访问对应的数据库了。