springboot配置多数据源并集成Druid和mybatis的操作
作者:BUG记录机
这篇文章主要介绍了springboot配置多数据源并集成Druid和mybatis的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
可以是mysql,oracle等多种不同数据源
项目结构
注意:只有@Primary的数据源所控制的mapper文件加注解@Mapper,否则mybatis无法切换扫描;即本文中的mapper/opener文件夹下mapper加注解
1、pom
驱动之外加入druid和mybatis等pom,整合mybatis自行搜索
<dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.23</version> </dependency>
2、properties配置
################## JDBC 配置 ################ #资讯数据库一配置 spring.datasource.druid.opener.driver-class-name=oracle.jdbc.driver.OracleDriver spring.datasource.druid.opener.url=jdbc:oracle:thin:@127.0.0.1:1521:wljrdb spring.datasource.druid.opener.username=opener spring.datasource.druid.opener.password=123456 #舆情数据库二配置 spring.datasource.druid.yq.driver-class-name=oracle.jdbc.driver.OracleDriver spring.datasource.druid.yq.url=jdbc:oracle:thin:@127.0.0.1:1521:wljrdb spring.datasource.druid.yq.username=YQ spring.datasource.druid.yq.password=123456 #f10数据库二配置 spring.datasource.druid.f10.driver-class-name=com.mysql.jdbc.Driver spring.datasource.druid.f10.url=jdbc:mysql://127.0.0.1:3306/iwin-f10?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2b8 spring.datasource.druid.f10.username=root spring.datasource.druid.f10.password=123456 ########################## druid配置 ########################## # 下面为连接池的补充设置,应用到上面所有数据源中# 初始化大小,最小,最大 ################## 连接池配置 ################ spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.druid.initial-size=5 spring.datasource.druid.max-active=20 spring.datasource.druid.min-idle=5 spring.datasource.druid.max-wait=30000 spring.datasource.druid.validation-query=SELECT 1 FROM DUAL spring.datasource.druid.validation-query-timeout=30000 # 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙 spring.datasource.druid.filters=stat,wall,log4j2 # 通过connectProperties属性来打开mergeSql功能;慢SQL记录 spring.datasource.druid.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000 # 监控中心 如果设置了StatViewServlet,即配置了监控池认证, # 要进监控池需要输入http://127.0.0.1:8083/druid/login.html,如果没配置,直接输入http://127.0.0.1:8083/druid/即可 spring.datasource.druid.stat-view-servlet.enabled= true spring.datasource.druid.stat-view-servlet.url-pattern= /druid/* spring.datasource.druid.stat-view-servlet.reset-enable= true spring.datasource.druid.stat-view-servlet.login-username= admin spring.datasource.druid.stat-view-servlet.login-password= admin123 spring.datasource.druid.stat-view-servlet.allow= 127.0.0.1
3、配置文件
import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.mapper.MapperScannerConfigurer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import javax.sql.DataSource; /** * @Author: admin */ @Configuration public class MultiDataSourceConfig { private final static Logger logger = LoggerFactory.getLogger(MultiDataSourceConfig.class); @Bean @Primary @ConfigurationProperties(prefix = "spring.datasource.druid.opener") public DataSource openerDataSource(){ logger.info("opener数据源初始化。。。"); return DruidDataSourceBuilder.create().build(); } @Bean @ConfigurationProperties(prefix = "spring.datasource.druid.yq") public DataSource yqDataSource(){ logger.info("YQ数据源初始化。。。"); return DruidDataSourceBuilder.create().build(); } @Bean @ConfigurationProperties(prefix = "spring.datasource.druid.f10") public DataSource f10DataSource(){ logger.info("f10数据源初始化。。。"); return DruidDataSourceBuilder.create().build(); } @Bean @Primary public SqlSessionFactory openerSqlSessionFactory(@Qualifier("openerDataSource")DataSource openerDataSource) throws Exception{ SqlSessionFactoryBean fb = new SqlSessionFactoryBean(); fb.setDataSource(openerDataSource); fb.setMapperLocations( new PathMatchingResourcePatternResolver().getResources("classpath:/mybatis/opener/*.xml") ); return fb.getObject(); } @Bean public SqlSessionFactory yqSqlSessionFactory(@Qualifier("yqDataSource")DataSource yqDataSource) throws Exception{ SqlSessionFactoryBean fb = new SqlSessionFactoryBean(); fb.setDataSource(yqDataSource); fb.setMapperLocations( new PathMatchingResourcePatternResolver().getResources("classpath:/mybatis/yq/*.xml") ); return fb.getObject(); } @Bean public SqlSessionFactory f10SqlSessionFactory(@Qualifier("f10DataSource")DataSource f10DataSource) throws Exception{ SqlSessionFactoryBean fb = new SqlSessionFactoryBean(); fb.setDataSource(f10DataSource); fb.setMapperLocations( new PathMatchingResourcePatternResolver().getResources("classpath:/mybatis/f10/*.xml") ); return fb.getObject(); } @Bean(name="openerMapperScannerConfigurer") @Primary public MapperScannerConfigurer openerMapperScannerConfigurer(){ MapperScannerConfigurer configurer = new MapperScannerConfigurer(); configurer.setSqlSessionFactoryBeanName("openerSqlSessionFactory"); configurer.setBasePackage("com.cfzq.lz.mapper.opener"); return configurer; } @Bean(name="yqMapperScannerConfigurer") public MapperScannerConfigurer yqMapperScannerConfigurer(){ MapperScannerConfigurer configurer = new MapperScannerConfigurer(); configurer.setSqlSessionFactoryBeanName("yqSqlSessionFactory"); configurer.setBasePackage("com.cfzq.lz.mapper.yq"); return configurer; } @Bean(name="f10MapperScannerConfigurer") public MapperScannerConfigurer f10MapperScannerConfigurer(){ MapperScannerConfigurer configurer = new MapperScannerConfigurer(); configurer.setSqlSessionFactoryBeanName("f10SqlSessionFactory"); configurer.setBasePackage("com.cfzq.lz.mapper.f10"); return configurer; } @Bean(name="openerTransactionManager") @Primary public DataSourceTransactionManager openerTransactionManager(@Qualifier("openerDataSource")DataSource openerDataSource) throws Exception{ return new DataSourceTransactionManager(openerDataSource); } @Bean(name="yqTransactionManager") public DataSourceTransactionManager yqTransactionManager(@Qualifier("yqDataSource")DataSource yqDataSource) throws Exception{ return new DataSourceTransactionManager(yqDataSource); } @Bean(name="f10TransactionManager") public DataSourceTransactionManager f10TransactionManager(@Qualifier("f10DataSource")DataSource f10DataSource) throws Exception{ return new DataSourceTransactionManager(f10DataSource); } }
代码调用
很简单,使用哪个数据源service注入哪个mapper就可以了
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
您可能感兴趣的文章:
- SpringBoot集成Druid实现多数据源的两种方式
- SpringBoot整合Mybatis-Plus+Druid实现多数据源配置功能
- springboot mybatis druid配置多数据源教程
- 关于springboot配置druid数据源不生效问题(踩坑记)
- 使用springboot+druid双数据源动态配置操作
- SpringBoot环境Druid数据源使用及特点
- Springboot mybatis plus druid多数据源解决方案 dynamic-datasource的使用详解
- SpringBoot整合Druid数据源过程详解
- 通过springboot+mybatis+druid配置动态数据源
- springboot 动态数据源的实现方法(Mybatis+Druid)
- Spring Boot+Mybatis+Druid+PageHelper实现多数据源并分页的方法
- 详解Spring Boot整合Mybatis实现 Druid多数据源配置
- spring使用xml方式整合Druid数据源连接池