快捷導(dǎo)航

SpringBoot+mybatis實現(xiàn)多數(shù)據(jù)源支持操作

更新時間：2020年10月19日 09:26:35 作者：那啥快看

這篇文章主要介紹了SpringBoot+mybatis實現(xiàn)多數(shù)據(jù)源支持操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

什么是多數(shù)據(jù)源支持？

簡單的說，就是一個項目里，同時可以訪問多個不同的數(shù)據(jù)庫。

實現(xiàn)原理

單個數(shù)據(jù)源在配置時會綁定一套mybatis配置，多個數(shù)據(jù)源時，不同的數(shù)據(jù)源綁定不同的mybatis配置就可以了，簡單的思路就是讓不同的數(shù)據(jù)源掃描不同的包，讓不同的包下的mapper對應(yīng)連接不同的數(shù)據(jù)源去處理邏輯。

業(yè)務(wù)場景假設(shè)

項目底層有正常業(yè)務(wù)庫和日志庫，希望解決的是將項目中的一些日志單獨記錄到一個庫里，比如用戶操作記錄、產(chǎn)品更新記錄等。

說一下為什么會有這個需求：用戶操作記錄和產(chǎn)品更新記錄可能很多，而實際中使用的又很少，就只是在某些頁面單獨展示一下操作或更新記錄，絕大部分時間都在不停的做著插入操作，這時就可以把這種記錄放到業(yè)務(wù)核心庫外面。

實現(xiàn)步驟

1.定義多個數(shù)據(jù)源的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.定義多個數(shù)據(jù)源

@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.分別配置多個數(shù)據(jù)源

@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;
 }
}

這里需要注意兩個數(shù)據(jù)源配置的差別，也是支持多數(shù)據(jù)源的關(guān)鍵

1）Configuration 掃描不同的前綴，取不同包下的sql對應(yīng)的xml文件

2）SqlSessionFactoryBean 實例化時，默認的額外添加了 @Primary注解

3）MapperScan 掃描的不同的包，如果掃描相同的包也能做，但是還需要做額外的配置，可以自己嘗試

4）不同的數(shù)據(jù)源使用不同的SqlSessionFactoryBean實例

至此，不同包下面的 Mapper.java 文件就可以連接不同的數(shù)據(jù)源了。這里就不說如何去使用了，和之前正常一樣去使用 Mapper.java 就可以了，只是操作的是不同的數(shù)據(jù)庫。

補充知識：springboot+mybatis多數(shù)據(jù)源不用增加硬編碼，只需簡單配置即可

背景

原有系統(tǒng)增加統(tǒng)計功能，數(shù)據(jù)源有本地系統(tǒng)的數(shù)據(jù)，還有其他系統(tǒng)數(shù)據(jù)。其他系統(tǒng)數(shù)據(jù)可以同步到mysql表。但是又不想與當前頁面表混用，打算使用另外的庫，并且不想單獨提供接口，想通過當前系統(tǒng)配置數(shù)據(jù)源來實現(xiàn)此功能。

目前常用的方式是分包或切面等，感覺要改的地方比較多，最后采用了一種改動最簡單的方式來實現(xiàn)多數(shù)據(jù)源，shardingjdbc這種方式，感覺比較簡單，而且便于日后分庫分表的拓展。

項目實施

目標

系統(tǒng)增加一個數(shù)據(jù)源，統(tǒng)計數(shù)據(jù)，此數(shù)據(jù)源與系統(tǒng)原有數(shù)據(jù)源不發(fā)生關(guān)系。

當前環(huán)境

viewer.sql：原業(yè)務(wù)庫，大概有二十多張表（當前舉例，展示user,role）

test.sql:新增的統(tǒng)計庫，目前只使用一張表(模擬統(tǒng)計測試數(shù)據(jù)zhy)

使用mybatis，自動生成了原業(yè)務(wù)的mapper和test中zhy表的數(shù)據(jù)

代碼

第一步引入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

原來連接數(shù)據(jù)庫

# 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
# 系統(tǒng)原有數(shù)據(jù)源
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
# 新增統(tǒng)計數(shù)據(jù)源
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
# 規(guī)則
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

主要需要看，配置分片規(guī)則這塊，根據(jù)表名進行分庫。