亲宝软件园·资讯

展开

SpringBoot mybatis多数据源 SpringBoot+mybatis实现多数据源支持操作

那啥快看 人气:0
想了解SpringBoot+mybatis实现多数据源支持操作的相关内容吗,那啥快看在本文为您仔细讲解SpringBoot mybatis多数据源的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点: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实现多数据源支持操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。

加载全部内容

相关教程
猜你喜欢
用户评论