SpringBoot-技術專區-Mybatisplus多數據源

一、引入依賴

<!-- https://mvnrepository.com/artifact/com.baomidou/dynamic-datasource-spring-boot-starter -->
<dependency>
　　<groupId>com.baomidou</groupId>
　　<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
　　<version>2.4.2</version>
</dependency>

二、配置 application.properties 文件

#server.port = 8091
#mysql

#刪除多表
#allowMultiQueries=true

#換成 druid
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

#設置默認的數據源或者數據源組,默認值即為master
spring.datasource.dynamic.primary=master

spring.datasource.dynamic.datasource.master.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.dynamic.datasource.master.url=jdbc:mysql://127.0.0.1:3306/wangmx_test1?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&allowMultiQueries=true
spring.datasource.dynamic.datasource.master.username=hopson
spring.datasource.dynamic.datasource.master.password=hopson

# slave_1
spring.datasource.dynamic.datasource.slave_1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.dynamic.datasource.slave_1.url=jdbc:mysql://127.0.0.1:3306/wangmx_test2?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&allowMultiQueries=true
spring.datasource.dynamic.datasource.slave_1.username=hopson
spring.datasource.dynamic.datasource.slave_1.password=hopson


# druid 下面為連接池的補充設置，應用到上面所有數據源中
# druid 初始化連接數大小，最小，最大
spring.datasource.dynamic.druid.initial-size=8
spring.datasource.dynamic.druid.min-idle=8
spring.datasource.dynamic.druid.max-active=30
# druid 配置獲取連接等待超時的時間
spring.datasource.dynamic.druid.max-wait=30000
# druid 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒
spring.datasource.dynamic.druid.time-between-eviction-runs-millis=60000

# 配置一個連接在池中最小生存的時間，單位是毫秒
spring.datasource.dynamic.druid.min-evictable-idle-time-millis=300000
# druid 驗證數據庫連接的有效性
spring.datasource.dynamic.druid.validation-query=select 1
spring.datasource.dynamic.druid.test-while-idle=true
spring.datasource.dynamic.druid.test-on-borrow=false
spring.datasource.dynamic.druid.test-on-return=false
# druid 打開PSCache，並且指定每個連接上PSCache的大小
spring.datasource.dynamic.druid.pool-prepared-statements=true
spring.datasource.dynamic.druid.max-open-prepared-statements=20
spring.datasource.dynamic.druid.max-pool-prepared-statement-per-connection-size=20
# druid 配置監控統計攔截的filters，去掉后監控界面sql無法統計，'wall'用於防火牆
spring.datasource.dynamic.druid.filters=stat,slf4j


# druid 狀態監控
spring.datasource.dynamic.druid.filter.stat.enabled=true
spring.datasource.dynamic.druid.filter.stat.db-type=mysql
spring.datasource.dynamic.druid.filter.stat.log-slow-sql=true
spring.datasource.dynamic.druid.filter.stat.slow-sql-millis=2000
# druid 監控過濾器
spring.datasource.dynamic.druid.web-stat-filter.enabled=true
spring.datasource.dynamic.druid.web-stat-filter.exclusions="*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
# druid 監控頁面
spring.datasource.dynamic.druid.stat-view-servlet.enabled=true
spring.datasource.dynamic.druid.stat-view-servlet.url-pattern=/druid/*
spring.datasource.dynamic.druid.stat-view-servlet.reset-enable=false
spring.datasource.druid.stat-view-servlet.login-username=root
spring.datasource.druid.stat-view-servlet.login-password=root
spring.datasource.dynamic.druid.stat-view-servlet.allow=

mybatis-plus.mapper-locations=classpath*:/mybatis/*/**.xml
mybatis-plus.type-aliases-package=com.bims.hopson.*.entity

spring.jackson.serialization.indent_output=true

# redis 配置
#spring.redis.host=192.168.0.100
#spring.redis.host=127.0.0.1
#spring.redis.port=6379
#spring.redis.pool.max-idle=20

三、在啟動類上加注解

@SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class)
四、啟動日志

 

---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

優勢

網上關於動態數據源的切換的文檔有很多，核心只有兩種。

1. 構建多套環境，優勢是方便控制也容易集成一些簡單的分布式事務，缺點是非動態同時代碼量較多,配置難度大。
2. 基於spring提供原生的 AbstractRoutingDataSource ，參考一些文檔自己實現切換。

如果你的數據源較少，場景不復雜，選擇以上任意一種都可以。如果你需要更多特性，請嘗試本動態數據源。

1. 數據源分組，適用於多種場景 純粹多庫 讀寫分離 一主多從 混合模式。
2. 簡單集成Druid數據源監控多數據源，簡單集成Mybatis-Plus簡化單表，簡單集成P6sy格式化sql，簡單集成Jndi數據源。
3. 簡化Druid和HikariCp配置，提供全局參數配置。
4. 提供自定義數據源來源(默認使用yml或properties配置)。
5. 項目啟動后能動態增減數據源。
6. 使用spel動態參數解析數據源，如從session，header和參數中獲取數據源。（多租戶架構神器）
7. 多層數據源嵌套切換。（一個業務ServiceA調用ServiceB，ServiceB調用ServiceC，每個Service都是不同的數據源）
8. 使用正則匹配或spel表達式來切換數據源（實驗性功能）。

劣勢

不能使用多數據源事務（同一個數據源下能使用事務），網上其他方案也都不能提供。

如果你需要使用到分布式事務，那么你的架構應該到了微服務化的時候了。

如果呼聲強烈，項目達到800 star，作者考慮集成分布式事務。

PS: 如果您只是幾個數據庫但是有強烈的需求分布式事務，建議還是使用傳統方式自己構建多套環境集成atomic這類，網上百度很多。

約定

1. 本框架只做 切換數據源 這件核心的事情，並不限制你的具體操作，切換了數據源可以做任何CRUD。
2. 配置文件所有以下划線 _ 分割的數據源 首部 即為組的名稱，相同組名稱的數據源會放在一個組下。
3. 切換數據源即可是組名，也可是具體數據源名稱，切換時默認采用負載均衡機制切換。
4. 默認的數據源名稱為 master ，你可以通過spring.datasource.dynamic.primary修改。
5. 方法上的注解優先於類上注解。

建議

強烈建議在 主從模式 下遵循普遍的規則，以便他人能更輕易理解你的代碼。

主數據庫 建議 只執行 INSERT UPDATE DELETE 操作。

從數據庫 建議 只執行 SELECT 操作。

使用方法

引入dynamic-datasource-spring-boot-starter。

<dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId> <version>${version}</version> </dependency> 

配置數據源。

spring: datasource: dynamic: primary: master #設置默認的數據源或者數據源組,默認值即為master datasource: master: username: root password: 123456 driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://xx.xx.xx.xx:3306/dynamic slave_1: username: root password: 123456 driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://xx.xx.xx.xx:3307/dynamic slave_2: username: root password: 123456 driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://xx.xx.xx.xx:3308/dynamic #......省略 #以上會配置一個默認庫master，一個組slave下有兩個子庫slave_1,slave_2 

# 多主多從 純粹多庫（記得設置primary） 混合配置 spring: spring: spring: datasource: datasource: datasource: dynamic: dynamic: dynamic: datasource: datasource: datasource: master_1: mysql: master: master_2: oracle: slave_1: slave_1: sqlserver: slave_2: slave_2: postgresql: oracle_1: slave_3: h2: oracle_2: 

使用 @DS 切換數據源。

　　@DS 可以注解在方法上和類上，同時存在方法注解優先於類上注解。

　　注解在service實現或mapper接口方法上，但強烈不建議同時在service和mapper注解。 (可能會有問題)

注解	結果
沒有@DS	默認數據源
@DS("dsName")	dsName可以為組名也可以為具體某個庫的名稱

@Service @DS("slave") public class UserServiceImpl implements UserService { @Autowired private JdbcTemplate jdbcTemplate; public List<Map<String, Object>> selectAll() { return jdbcTemplate.queryForList("select * from user"); } @Override @DS("slave_1") public List<Map<String, Object>> selectByCondition() { return jdbcTemplate.queryForList("select * from user where age >10"); } } 

在mybatis環境下也可注解在mapper接口層。

@DS("slave") public interface UserMapper { @Insert("INSERT INTO user (name,age) values (#{name},#{age})") boolean addUser(@Param("name") String name, @Param("age") Integer age); @Update("UPDATE user set name=#{name}, age=#{age} where id =#{id}") boolean updateUser(@Param("id") Integer id, @Param("name") String name, @Param("age") Integer age); @Delete("DELETE from user where id =#{id}") boolean deleteUser(@Param("id") Integer id); @Select("SELECT * FROM user") @DS("slave_1") List<User> selectAll();