From 59029ee11e9d1c1f2f07a3d5dc42165777739074 Mon Sep 17 00:00:00 2001
From: liulin <lin.liu@aliyun.com>
Date: 星期四, 08 八月 2024 12:39:02 +0800
Subject: [PATCH] 修改配置
---
src/test/java/com/lunhan/xxx/host/BasicServiceApplicationTests.java | 37 ++++++++++++++++++++++++++++++++++++-
1 files changed, 36 insertions(+), 1 deletions(-)
diff --git a/src/test/java/com/lunhan/xxx/host/BasicServiceApplicationTests.java b/src/test/java/com/lunhan/xxx/host/BasicServiceApplicationTests.java
index fc89ad2..1512eb3 100644
--- a/src/test/java/com/lunhan/xxx/host/BasicServiceApplicationTests.java
+++ b/src/test/java/com/lunhan/xxx/host/BasicServiceApplicationTests.java
@@ -1,11 +1,18 @@
package com.lunhan.xxx.host;
+import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
+import com.lunhan.xxx.po.UserPO;
+import com.lunhan.xxx.repository.mapper.UserMapper;
import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.List;
@SpringBootTest
class BasicServiceApplicationTests {
-
+ @Autowired
+ private UserMapper userMapper;
// @Autowired
// private AdminService service;
@@ -30,4 +37,32 @@
System.out.println("END.");
}
+
+ @Test
+ void dbTest() {
+ // 动态设置数据源上下文
+ DynamicDataSourceContextHolder.push("test_db1");
+ List<UserPO> list = userMapper.selectList(null);
+
+ UserPO item = new UserPO();
+ item.setName("jeff");
+ item.setAge(18);
+ item.setEmail("");
+ int insertRowCount = userMapper.insert(item);
+ System.out.println("insertRowCount: " + insertRowCount);
+
+ UserPO find = userMapper.selectById(item.getId());
+
+ UserPO upd = new UserPO();
+ upd.setId(item.getId());
+ upd.setName("jeff1");
+ int updRowCount = userMapper.updateById(item);
+ System.out.println("updRowCount: " + updRowCount);
+
+ int delRowCount = userMapper.deleteById(item.getId());
+ System.out.println("delRowCount: " + delRowCount);
+
+ // 数据源上下文清空，避免影响后续的数据库操作
+ DynamicDataSourceContextHolder.poll();
+ }
}
--
Gitblit v1.9.3