package com.lunhan.xxx; 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; @Test void contextLoads() { // ExecutedResult login = service.adminLogin(new ReqAdminLogin() {{ // setUserName("admin"); // setPassword("lunhan123456"); // }}); // if (login.isFailed()) { // ExecutedResult result = service.createAdmin(new ReqCreateAdmin() {{ // setUserType(EUserType.ADMIN.getValue()); // setUserName("admin"); // setPassword("lunhan123456"); // setNickName("超鸡管理猿"); // setHeadImg(""); // setContact("13368384110"); // setEmail("lin.liu@aliyun.com"); // setStatus(EState.NORMAL.getValue()); // }}); // } System.out.println("END."); } @Test void dbTest() { // 动态设置数据源上下文 DynamicDataSourceContextHolder.push("test_db1"); List 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(); } }