SpringBoot+mybatis实现多数据源支持操作
什么是多数据源支持？
简单的说，就是一个项目里，同时可以访问多个不同的数据库。
实现原理
单个数据源在配置时会绑定一套mybatis配置，多个数据源时，不同的数据源绑定不同的mybatis配置就可以了，简单的思路就是让不同的数据源扫描不同的包，让不同的包下的mapper对应连接不同的数据源去处理逻辑。
业务场景假设
项目底层有正常业务库和日志库，希望解决的是将项目中的一些日志单独记录到一个库里，比如用户操作记录、产品更新记录等。
说一下为什么会有这个需求：用户操作记录和产品更新记录可能很多，而实际中使用的又很少，就只是在某些页面单独展示一下操作或更新记录，绝大部分时间都在不停的做着插入操作，这时就可以把这种记录放到业务核心库外面。
实现步骤
1.定义多个数据源的mybatis配置
application.properties mybatis.mapper-locations=mappers/*.xml mybatisLog.mapper-locations=mappersLog/*.xml ## datasource master # spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://localhost:3306/test1?characterEncoding=UTF-8 spring.datasource.username=root spring.datasource.password=466420182 ## datasource log # spring.datasourceLog.type=com.alibaba.druid.pool.DruidDataSource spring.datasourceLog.driver-class-name=com.mysql.jdbc.Driver spring.datasourceLog.url=jdbc:mysql://localhost:3306/log?characterEncoding=UTF-8 spring.datasourceLog.username=root spring.datasourceLog.password=466420182
2.定义多个数据源
@Configuration
public class DatasourceConfig {
@Bean(destroyMethod = "close", name = DataSources.MASTER_DB)
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource dataSource() {
return DataSourceBuilder.create().type(DruidDataSource.class).build();
}
@Bean(destroyMethod = "close", name = DataSources.LOG_DB)
@ConfigurationProperties(prefix = "spring.datasourceLog")
public DataSource dataSourceLog() {
return DataSourceBuilder.create().type(DruidDataSource.class).build();
}
}
3.分别配置多个数据源
@Configuration
@MapperScan(basePackages = {"com.mmall.practice.dao"})
public class MybatisConfig {
@Autowired
@Qualifier(DataSources.MASTER_DB)
private DataSource masterDB;
@Bean
@Primary
@ConfigurationProperties(prefix = "mybatis")
public SqlSessionFactoryBean sqlSessionFactoryBean() {
SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(masterDB);
return sqlSessionFactoryBean;
}
}
@Configuration
@MapperScan(basePackages = {"com.mmall.practice.daoLog"}, sqlSessionFactoryRef = "logSqlSessionFactory")
public class MybatisLogConfig {
@Autowired
@Qualifier("logDB")
private DataSource logDB;
@Bean(name = "logSqlSessionFactory")
@ConfigurationProperties(prefix = "mybatisLog")
public SqlSessionFactoryBean sqlSessionFactoryBean() {
SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(logDB);
return sqlSessionFactoryBean;
}
}
这里需要注意两个数据源配置的差别，也是支持多数据源的关键
1）Configuration 扫描不同的前缀，取不同包下的sql对应的xml文件
2）SqlSessionFactoryBean 实例化时，默认的额外添加了 @Primary注解
3）MapperScan 扫描的不同的包，如果扫描相同的包也能做，但是还需要做额外的配置，可以自己尝试
4）不同的数据源使用不同的SqlSessionFactoryBean实例
至此，不同包下面的 Mapper.java 文件就可以连接不同的数据源了。这里就不说如何去使用了，和之前正常一样去使用 Mapper.java 就可以了，只是操作的是不同的数据库。
补充知识：springboot+mybatis多数据源不用增加硬编码，只需简单配置即可
背景
原有系统增加统计功能，数据源有本地系统的数据，还有其他系统数据。其他系统数据可以同步到mysql表。但是又不想与当前页面表混用，打算使用另外的库，并且不想单独提供接口，想通过当前系统配置数据源来实现此功能。
目前常用的方式是分包或切面等，感觉要改的地方比较多，最后采用了一种改动最简单的方式来实现多数据源，shardingjdbc这种方式，感觉比较简单，而且便于日后分库分表的拓展。
项目实施
目标
系统增加一个数据源，统计数据，此数据源与系统原有数据源不发生关系。
当前环境
viewer.sql：原业务库，大概有二十多张表（当前举例，展示user,role）
test.sql:新增的统计库，目前只使用一张表(模拟统计测试数据zhy)
使用mybatis，自动生成了原业务的mapper和test中zhy表的数据
代码
第一步 引入shardingjdbc依赖
gradle
compile 'org.apache.shardingsphere:sharding-jdbc-spring-boot-starter:4.0.1'
maven
<dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>4.0.1</version> </dependency>
第二步 配置properties
原来连接数据库
# jdbc_config datasource spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.url=jdbc:mysql://127.0.0.1:3306/viewer?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=CONVERT_TO_NULL&serverTimezone=UTC spring.datasource.username=root spring.datasource.password=123456 # Hikari will use the above plus the following to setup connection pooling spring.datasource.type=com.zaxxer.hikari.HikariDataSource spring.datasource.hikari.minimum-idle=5 spring.datasource.hikari.maximum-pool-size=15 spring.datasource.hikari.auto-commit=true spring.datasource.hikari.idle-timeout=30000 spring.datasource.hikari.pool-name=DatebookHikariCP spring.datasource.hikari.max-lifetime=1800000 spring.datasource.hikari.connection-timeout=30000 spring.datasource.hikari.connection-test-query=SELECT 1
修改后
spring.shardingsphere.datasource.names=ds-viewer,ds-test # 系统原有数据源 spring.shardingsphere.datasource.ds-viewer.type=com.zaxxer.hikari.HikariDataSource spring.shardingsphere.datasource.ds-viewer.driver-class-name=com.mysql.cj.jdbc.Driver spring.shardingsphere.datasource.ds-viewer.jdbc-url=jdbc:mysql://127.0.0.1:3306/viewer?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=CONVERT_TO_NULL&serverTimezone=UTC spring.shardingsphere.datasource.ds-viewer.username=root spring.shardingsphere.datasource.ds-viewer.password=123456 # 新增统计数据源 spring.shardingsphere.datasource.ds-test.type=com.zaxxer.hikari.HikariDataSource spring.shardingsphere.datasource.ds-test.driver-class-name=com.mysql.cj.jdbc.Driver spring.shardingsphere.datasource.ds-test.jdbc-url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=CONVERT_TO_NULL&serverTimezone=UTC spring.shardingsphere.datasource.ds-test.username=root spring.shardingsphere.datasource.ds-test.password=123456 # 规则 spring.shardingsphere.sharding.tables.user.actual-data-nodes=ds-viewer.user spring.shardingsphere.sharding.tables.role.actual-data-nodes=ds-viewer.role spring.shardingsphere.sharding.tables.zhy.actual-data-nodes=ds-test.zhy
主要需要看，配置分片规则这块，根据表名进行分库。
spring.shardingsphere.sharding.tables.user.actual-data-nodes=ds-viewer.user
解释：
user:原有数据库中的表
ds-viewer:定义的数据源spring.shardingsphere.datasource.names=ds-viewer,ds-test
有几张表就可以定义几张（可以使用idea纵列编辑，很方便改造）
大功告成，可以进行开发测试了，对于代码层来说，没有任何改动。
如果系统有配置文件，有的配置启动不需要多数据源，可以在配置文件中禁止启动shardingjdbc
spring.shardingsphere.enabled=false
以上这篇SpringBoot+mybatis实现多数据源支持操作就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家详细介绍了三个时间标准GMT,CST,UTC的规定,以及Java进行时间处理的相关知识,感兴趣的小伙伴可以跟随小编一起学习一下2023-09-09
本文非常详细的介绍了java异常，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们可以学习一下这篇文章2021-08-08
Java Stream实现多字段分组groupingBy操作详解
Stream是Java8的一个新特性，主要用户集合数据的处理，如排序、过滤、去重等等功能，本文就来讲讲如何利用Stream实现比较优雅的按多字段进行分组groupingBy吧2023-06-06
我们知道Java是一个面相对象的编程语言，基本类型并不具有对象的性质，为了让基本类型也具有对象的特征，就出现了包装类型，它相当于将基本类型“包装起来”，使得它具有了对象的性质，并且为其添加了属性和方法，丰富了基本类型的操作2021-06-06
这篇文章主要介绍了Spring AOP源码，AOP（Aspect Orient Programming）,直译过来就是 面向切面编程,AOP 是一种编程思想，是面向对象编程（OOP）的一种补充2023-01-01
这篇文章主要为大家介绍了PowerJob的MapProcessor工作流程源码解读，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2024-01-01
这篇文章主要介绍了springboot多数据源配置及切换,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-09-09
Spring Boot使用过滤器和拦截器分别实现REST接口简易安全认证示例代码详解
这篇文章主要介绍了Spring Boot使用过滤器和拦截器分别实现REST接口简易安全认证示例代码，通过开发实践，理解过滤器和拦截器的工作原理,需要的朋友可以参考下2018-06-06
解决java拦截器获取POST入参导致@RequestBody参数丢失问题
文章讲述了在Java开发中使用拦截器获取POST请求入参时,由于流关闭导致`@RequestBody`参数丢失的问题,并提出了一种解决方案,解决方案包括自定义方法、防止流丢失、过滤器和拦截器的合理组织和使用,最终确保了参数的正确传递2024-11-11
在现代Web应用中,文件上传是一个核心功能,尤其是对于大文件,传统的上传方式常常因网络中断或超时而失败,为了解决这一痛点,我们推出了基于 Hyperlane 的文件分块上传服务端代码,为开发者提供了一个高效、可靠的大文件上传解决方案,感兴趣的朋友一起看看吧2025-04-04
最新评论