適用于多種場景:純粹多庫、?? 讀寫分離、??? 一主多從、?? 混合模式等
目前我們就來模擬一個純粹多庫的一個場景,其他場景類似
場景說明:
我們創建兩個庫,分別為:? mybatis_plus(以前的庫不動)與mybatis_plus_1? (新建),將
mybatis_plus庫的product表移動到mybatis_plus_1庫,這樣每個庫一張表,通過一個測試用例 分別獲取用戶數據與商品數據,如果獲取到說明多庫模擬成功
1.創建數據庫及表
CREATE DATABASE `mybatis_plus_1` /*!40100 DEFAULT CHARACTER SET utf8mb4 */; use `mybatis_plus_1`;
CREATE TABLE product
(
id BIGINT(20) NOT NULL COMMENT '主鍵ID',
name VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名稱 ',
price INT(11) DEFAULT 0 COMMENT '價格 ',
version INT(11) DEFAULT 0 COMMENT '樂觀鎖版本號 ',
PRIMARY KEY (id)
);INSERT INTO product (id, NAME, price) VALUES (1, '外星人筆記本 ', 100);-------------------------------------------------CREATE DATABASE `mybatis_plus` /*!40100 DEFAULT CHARACTER SET utf8mb4 */; use `mybatis_plus`;
CREATE TABLE `user` (
`id` bigint(20) NOT NULL COMMENT '主鍵ID',
`name` varchar(30) DEFAULT NULL COMMENT '姓名 ',
`age` int(11) DEFAULT NULL COMMENT '年齡 ',
`email` varchar(50) DEFAULT NULL COMMENT '郵箱 ',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;INSERT INTO user (id, name, age, email) VALUES
(1, 'Jone', 18, 'test1@baomidou.com'),
(2, 'Jack', 20, 'test2@baomidou.com'),
(3, 'Tom', 28, 'test3@baomidou.com'),
(4, 'Sandy', 21, 'test4@baomidou.com'),
(5, 'Billie', 24, 'test5@baomidou.com');
?注:小編的表里的數據已經做過修改了,與插入的數據不一致,但不影響多數據源配置
2.引入依賴
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.5.0</version>
</dependency>
3.配置多數據源
說明:注釋掉之前的數據庫連接,添加新配置
spring:# 配置數據源信息datasource:dynamic:# 設置默認的數據源或者數據源組 ,默認值即為masterprimary: master# 嚴格匹配數據源 ,默認false.true未匹配到指定數據源時拋異常 ,false使用默認數據源strict: falsedatasource:master:url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=falsedriver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: 123456slave_1:url: jdbc:mysql://localhost:3306/mybatis_plus_1?characterEncoding=utf-8&useSSL=falsedriver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: 123456
4.創建用戶商品service?
public interface UserService extends IService<User> {
}/////////////////////////////////////////////////////
@DS("master") //指定所操作的數據源
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}
public interface ProductService extends IService<Product> {
}
///////////////////////////////////////////////////////
@DS("slave_1")
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
}
?5.測試
@SpringBootTest
public class TestDynamicDataSource {@Autowiredprivate UserService userService;@Autowiredprivate ProductService productService;@Testpublic void test() {System.out.println(userService.list());System.out.println(productService.list());}
}
@Service
//@DS("slave_1")
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {@Autowiredprivate ProductMapper productMapper;@DS("slave_1")@Overridepublic List<Product> findall() {return productMapper.selectList(null);}
}
6.在方法上添加數據源
(1)需要自己編寫一個方法
public interface ProductService extends IService<Product> {List<Product> findall();
}
(2)實現該方法并將注解@DS放到這個方法上
@Service
//@DS("slave_1")
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {@Autowiredprivate ProductMapper productMapper;@DS("slave_1")@Overridepublic List<Product> findall() {return productMapper.selectList(null);}
}
(3)測試
@Autowiredprivate ProductService productService;@Testpublic void test() {
// System.out.println(userService.list());System.out.println(productService.findall());}
}