junit单元测试，mock数据后，调用时返回数据为null

测试积点老人

junit单元测试，mock数据后，调用时返回数据为null

1. package com.zdicc.online.core.service;
   
2. 
   
3. import com.alibaba.fastjson.JSONObject;
   
4. import com.zdicc.online.core.ZdiccApplicationTests;
   
5. import com.zdicc.online.core.dto.DatasourceDto;
   
6. import java.util.*;
   
7. import org.junit.jupiter.api.Assertions;
   
8. import org.junit.jupiter.api.BeforeEach;
   
9. import org.junit.jupiter.api.Test;
   
10. import org.mockito.Mockito;
    
11. import org.mockito.MockitoAnnotations;
    
12. import org.springframework.beans.factory.annotation.Autowired;
    
13. import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
    
14. import org.springframework.boot.test.mock.mockito.MockBean;
    
15. import org.springframework.web.client.RestTemplate;
    
16. 
    
17. @AutoConfigureMockMvc
    
18. public class DatasourceServiceTest extends ZdiccApplicationTests {
    
19. 
    
20.   @MockBean
    
21.   private RestTemplate restTemplate;
    
22.   @Autowired
    
23.   private DatasourceService datasourceService;
    
24. 
    
25.   @BeforeEach
    
26.   public void init() {
    
27.     MockitoAnnotations.initMocks(this);
    
28.   }
    
29. 
    
30.   @Test
    
31.   public void remoteGetDatasourceByTypeIds() {
    
32.     Map<String, List<Integer>> map = new HashMap<>();
    
33.     map.put("job", Collections.singletonList(105));
    
34.     map.put("api", Collections.singletonList(101));
    
35. 
    
36.      String response = "{\n" +
    
37.          "\t\"status\": 1,\n" +
    
38.          "\t\"data\": [{\n" +
    
39.          "\t\t\"dbType\": \"mysql\",\n" +
    
40.          "\t\t\"nodeType\": \"api\",\n" +
    
41.          "\t\t\"originId\": 101,\n" +
    
42.          "\t\t\"sourceType\": 1,\n" +
    
43.          "\t\t\"url\": \"192.168.100.134:3306/demo.create_tables\"\n" +
    
44.          "\t}, {\n" +
    
45.          "\t\t\"dbType\": \"mysql\",\n" +
    
46.          "\t\t\"nodeType\": \"job\",\n" +
    
47.          "\t\t\"originId\": 195,\n" +
    
48.          "\t\t\"sourceType\": 1,\n" +
    
49.          "\t\t\"url\": \"192.168.100.134:3306/demo.vote_demo\"\n" +
    
50.          "\t}, {\n" +
    
51.          "\t\t\"dbType\": \"hive\",\n" +
    
52.          "\t\t\"nodeType\": \"job\",\n" +
    
53.          "\t\t\"originId\": 195,\n" +
    
54.          "\t\t\"sourceType\": 2,\n" +
    
55.          "\t\t\"url\": \"hello.demo_vote_demo_hourly_vera2\"\n" +
    
56.          "\t}, {\n" +
    
57.          "\t\t\"dbType\": \"mysql\",\n" +
    
58.          "\t\t\"nodeType\": \"job\",\n" +
    
59.          "\t\t\"originId\": 150,\n" +
    
60.          "\t\t\"sourceType\": 1,\n" +
    
61.          "\t\t\"url\": \"192.168.100.134:3306/demo.vote_demo\"\n" +
    
62.          "\t}, {\n" +
    
63.          "\t\t\"dbType\": \"hive\",\n" +
    
64.          "\t\t\"nodeType\": \"job\",\n" +
    
65.          "\t\t\"originId\": 150,\n" +
    
66.          "\t\t\"sourceType\": 2,\n" +
    
67.          "\t\t\"url\": \"default.david_test_vote_demo\"\n" +
    
68.          "\t}]\n" +
    
69.          "}";
    
70. 
    
71.     JSONObject jsonObject = JSONObject.parseObject(response);
    
72.     Mockito.when(this.restTemplate.postForObject(Mockito.any(), Mockito.anyList(), Mockito.any()))
    
73.         .thenReturn(jsonObject);
    
74. 
    
75.     Map<String, List<DatasourceDto>> resMap = datasourceService.remoteGetDatasourceByTypeIds(map);
    
76.     Assertions.assertNotNull(resMap);
    
77.   }
    
78. }
    
79. 
    

复制代码

运行结果及报错内容

1. public Map<String, List<DatasourceDto>> remoteGetDatasourceByTypeIds(Map<String, List> typeIdsMap) {
   
2.     if (typeIdsMap == null || typeIdsMap.isEmpty()) {
   
3.       return null;
   
4.     }
   
5. 
   
6.     String url = onlineEnvConfig.getDAAM_BASE_URL() + DAAM_DATASOURCE_URI;
   
7.     List<Map<String, Object>> paramMap = new ArrayList<>();
   
8.     Map<String, Object> subMap = null;
   
9.     for (String nodeType : typeIdsMap.keySet()) {
   
10.       subMap = new HashMap<>();
    
11.       subMap.put("nodeType", nodeType);
    
12.       subMap.put("originalIdList", typeIdsMap.get(nodeType));
    
13.       paramMap.add(subMap);
    
14.     }
    
15.     JSONObject response = null;
    
16.     try {
    
17.       response = restTemplate.postForObject(url, paramMap, JSONObject.class);
    
18.       //这里返回null，并没有返回mock的内容
    
19.     } catch (RestClientException e) {
    
20.       log.error("Failed to request step datasource detail, e = {}", e.getMessage(), e);
    
21.       // FIXME: 2021/2/26 是否需要直接报错
    
22.       //            throw new OnlineException(ResponseEnum.REST_TEMPLATE_REQUEST_FAIL);
    
23.     }
    

复制代码

qqq911

检查下mock的配置

jingzizx

看返回信息啊