網站首頁 編程語言 正文
參考資料:
- 參考視頻(講述多數據源實現原理,以及原生的多數據源實現方式,Dynamic-DataSource的基本使用)
- 官方github(dynamic-datasource-spring-boot-starter的源碼,用處不大)
- 官方文檔(具有很高的參考價值,你想要的這里都有,不過是要收費的)
- 個人demo及視頻參考資料
內容簡介:
- Dynamic-DataSource 可以和絕大多是連接層插件搭配使用,比如:mybatis,mybatis-plus,hibernate等
- 如果公司不允許使用Dynamic-DataSource,可以參考上述視頻進行原生代碼的編寫
- 本示例僅講就基本的使用(多數據源及事務),如果還需要更多功能,可參考上述官方文檔進行編碼
搭建示例(mybatis):
- 首先搭建一個springBoot框架,參考
- 然后創建兩個數據庫,模擬讀寫分離,每個數據庫有個user表
CREATE TABLE `user` (
`id` int(0) NOT NULL AUTO_INCREMENT,
`userName` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
`passWord` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
`realName` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE,
INDEX `userName_index`(`userName`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 975224 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
- ?導入數據庫
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.5.2</version>
</dependency>
- 配置數據源?
server:
port: 8088
spring:
datasource:
dynamic:
#設置默認的數據源或者數據源組,默認值即為master
primary: master
#嚴格匹配數據源,默認false. true未匹配到指定數據源時拋異常,false使用默認數據源
strict: false
datasource:
master:
url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
username: root
password: 123888
driver-class-name: com.mysql.jdbc.Driver
slave_1:
url: jdbc:mysql://localhost:3306/user?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
username: root
password: 123888
driver-class-name: com.mysql.jdbc.Driver
mybatis:
mapper-locations: classpath:mapper/*.xml
type-aliases-package: com.example.demo.model
#idea配置文件默認不允許有中文注釋
logging:
level:
com.example.demo.dao: debug
- 其他的MVC層,正嘗寫就行,只需要在對應的類,方法或接口上添加@DS注解來進行數據源的切換即可?,關于DS注解詳情,可參考上面的官方文檔
@DS?可以注解在方法上或類上,同時存在就近原則 方法上注解 優先于 類上注解
注解 | 結果 |
沒有@DS | 默認數據源 |
@DS("dsName") | dsName可以為組名也可以為具體某個庫的名稱 |
- UserMapping.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.dynamicdatasourcemybatis.dao.UserMapper">
<resultMap id="BaseResultMap" type="com.example.dynamicdatasourcemybatis.model.User">
<result column="id" jdbcType="INTEGER" property="id" />
<result column="userName" jdbcType="VARCHAR" property="userName" />
<result column="passWord" jdbcType="VARCHAR" property="passWord" />
<result column="realName" jdbcType="VARCHAR" property="realName" />
</resultMap>
<select id="Sel" resultType="com.example.dynamicdatasourcemybatis.model.User">
select * from user where id = #{id}
</select>
<insert id="insertUser" parameterType="com.example.dynamicdatasourcemybatis.model.User">
insert into user(id,userName,passWord,realName) values(#{id},#{userName},#{passWord},#{realName})
</insert>
</mapper>
- dao層? ?(這里通過@DS來選擇數據源)
package com.example.dynamicdatasourcemybatis.dao;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.example.dynamicdatasourcemybatis.model.User;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface UserMapper {
//通過@DS 來選擇 配置文件中的master 數據源
@DS("master")
User Sel(int id);
//通過@DS 來選擇 配置文件中的master 數據源
@DS("slave_1")
Integer insertUser(User u);
}
- service層,這里也可以在方法上加@DS 來選擇數據源,這里就不演示了
package com.example.dynamicdatasourcemybatis.service;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.example.dynamicdatasourcemybatis.dao.UserMapper;
import com.example.dynamicdatasourcemybatis.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Random;
import java.util.UUID;
@Service
//@DS("master") 這里指定整個類使用的數據源
public class UserService {
@Autowired
UserMapper userMapper;
//分庫分表 中 從 test 庫中查找
//@DS("master") 這里指定整個方法使用的數據源
public User Sel(int id){
return userMapper.Sel(id);
}
//分庫分表 中 存入 user 庫
//@DS("master") 這里指定整個方法使用的數據源
public Integer insertUser(){
User user = new User();
user.setId(1000+new Random().nextInt());
user.setPassWord(UUID.randomUUID().toString());
user.setUserName("張老三");
user.setRealName("張三");
return userMapper.insertUser(user);
}
//@DS("master") 這里指定整個方法使用的數據源
public Integer testTrans(){
User user = new User();
user.setId(1000+new Random().nextInt());
user.setPassWord(UUID.randomUUID().toString());
user.setUserName("李老四");
user.setRealName("李四");
userMapper.insertUser(user);
System.out.println("==========構建錯誤,測試回滾==============");
System.out.println(1/0);
return 0;
}
}
- controller層? 這里也可以在方法或者類上 使用@DS來選擇數據源
package com.example.dynamicdatasourcemybatis.controller;
import com.example.dynamicdatasourcemybatis.model.User;
import com.example.dynamicdatasourcemybatis.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
/**
* @Author:wjup
* @Date: 2018/9/26 0026
* @Time: 14:42
* 用多數據源來模擬分庫分表 master 負責 讀 操作 slave_1 負責 寫操作
*/
@Controller
@RequestMapping("/testBoot")
public class UserController {
@Autowired
private UserService userService;
@RequestMapping("getUser/{id}")
public String GetUser(@PathVariable int id,Model model){
User user = userService.Sel(id);
model.addAttribute("user", user);
System.out.println("xxxxxxxxxxxxxxxxxx"+user.toString());
return "index";
}
@RequestMapping("getUser/insert")
@ResponseBody
public String GetUser(){
return String.valueOf(userService.insertUser());
}
//測試事務
@RequestMapping("getUser/testTrans")
@Transactional
@ResponseBody
public String testTrans(){
return String.valueOf(userService.testTrans());
}
}
- 如果需要事務的話,用@Transactional? ?即可,同上
- 然后最后的就是上面的參考demo
功能擴展(mybatis-plus):
- 關于mybatis-plus的多數據源切換,同樣也是導入依賴,然后使用@DS在類或者方法上控制數據源即可
- 實在不會參考上述官方文檔
原文鏈接:https://blog.csdn.net/qq_23095607/article/details/127031349
相關推薦
- 2022-04-08 c++11中std::move函數的使用_C 語言
- 2022-09-04 Go語言中的函數詳解_Golang
- 2023-11-21 python使用print輸出不同顏色的字體、終端顯示不同顏色字體
- 2022-03-22 C++計算圓形、矩形和三角形的面積_C 語言
- 2023-07-02 Pandas數據查詢的集中實現方法_python
- 2022-09-16 Python中的?No?Module?named?***問題及解決_python
- 2022-05-17 使用@async 注解,導致訪問RequestContextHolder獲取request為空
- 2022-02-18 git忽略文件,.gitignore配置
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支