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實現多資料來源支援操作就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支援我們。