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<ResAdminLogin> login = service.adminLogin(new ReqAdminLogin() {{
|
// setUserName("admin");
|
// setPassword("lunhan123456");
|
// }});
|
// if (login.isFailed()) {
|
// ExecutedResult<Long> 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<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();
|
}
|
}
|
