如何让SAP Cloud SDK OData客户端请求Spring MockMVC测试Servlet并获取响应？

要在Spring虚拟Web上下文（MockMVC）中使用SAP Cloud SDK的类型安全OData客户端，核心思路是替换Cloud SDK的默认HttpClient，将其请求转发到MockMVC执行，无需启动真实服务器。以下是具体实现方案：

核心原理 #

SAP Cloud SDK允许自定义HttpClient实现，我们可以利用这一点，把Cloud SDK生成的OData请求转换成MockMVC能处理的请求格式，执行后再把MockMVC的响应转换回Cloud SDK所需的HttpResponse格式，从而在虚拟上下文里完成类型安全的请求与验证。

步骤与代码实现 #

1. 注入MockMvc并自定义HttpClient #

在Spring测试类中，先注入MockMvc实例，然后实现一个基于MockMvc的自定义HttpClient：

import com.sap.cloud.sdk.cloudplatform.connectivity.HttpClient;
import com.sap.cloud.sdk.cloudplatform.connectivity.HttpRequest;
import com.sap.cloud.sdk.cloudplatform.connectivity.HttpResponse;
import org.springframework.mock.web.MockHttpServletResponse;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.request.MockHttpServletRequestBuilder;
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
import java.util.Map;
import java.util.stream.Collectors;

public class MockMvcHttpClient implements HttpClient {
    private final MockMvc mockMvc;

    public MockMvcHttpClient(MockMvc mockMvc) {
        this.mockMvc = mockMvc;
    }

    @Override
    public HttpResponse execute(HttpRequest request) throws IOException {
        try {
            // 将Cloud SDK HttpRequest转换为MockMvc请求构建器
            MockHttpServletRequestBuilder requestBuilder = convertToMockMvcRequest(request);
            // 执行MockMvc请求
            MockHttpServletResponse mockResponse = mockMvc.perform(requestBuilder).andReturn().getResponse();
            
            // 将MockMvc响应转换为Cloud SDK HttpResponse
            return new HttpResponse() {
                @Override
                public int getStatusCode() {
                    return mockResponse.getStatus();
                }

                @Override
                public Map<String, String> getHeaders() {
                    return mockResponse.getHeaderNames().stream()
                            .collect(Collectors.toMap(
                                    h -> h,
                                    h -> mockResponse.getHeader(h)
                            ));
                }

                @Override
                public InputStream getContent() throws IOException {
                    return new ByteArrayInputStream(mockResponse.getContentAsByteArray());
                }
            };
        } catch (Exception e) {
            throw new IOException("Failed to execute request via MockMvc", e);
        }
    }

    private MockHttpServletRequestBuilder convertToMockMvcRequest(HttpRequest request) {
        URI uri = request.getUri();
        MockHttpServletRequestBuilder builder = switch(request.getMethod()) {
            case GET -> MockMvcRequestBuilders.get(uri.getPath());
            case POST -> MockMvcRequestBuilders.post(uri.getPath());
            case PUT -> MockMvcRequestBuilders.put(uri.getPath());
            case DELETE -> MockMvcRequestBuilders.delete(uri.getPath());
            default -> throw new IllegalArgumentException("Unsupported HTTP method: " + request.getMethod());
        };

        // 添加请求参数
        if (uri.getQuery() != null) {
            for (String param : uri.getQuery().split("&")) {
                String[] keyValue = param.split("=");
                if (keyValue.length == 2) {
                    builder.param(keyValue[0], keyValue[1]);
                }
            }
        }

        // 添加请求头
        request.getHeaders().forEach((key, values) -> values.forEach(value -> builder.header(key, value)));

        // 添加请求体（如果有）
        request.getContent().ifPresent(content -> {
            try (InputStream is = content) {
                builder.content(new String(is.readAllBytes()));
            } catch (IOException e) {
                throw new RuntimeException("Failed to read request content", e);
            }
        });

        return builder;
    }
}

2. 配置Cloud SDK使用自定义HttpClient #

在测试类中，通过HttpClientAccessor替换默认的HttpClient，确保Cloud SDK的OData客户端使用我们的MockMvcHttpClient：

import com.sap.cloud.sdk.cloudplatform.connectivity.DefaultHttpDestination;
import com.sap.cloud.sdk.cloudplatform.connectivity.HttpClientAccessor;
import com.sap.cloud.sdk.cloudplatform.connectivity.HttpDestination;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.web.servlet.MockMvc;

import static org.assertj.core.api.Assertions.assertThat;

@SpringBootTest
@AutoConfigureMockMvc
public class ODataEndpointIntegrationTest {
    @Autowired
    private MockMvc mockMvc;

    private YourODataService serviceClient;

    @BeforeEach
    void setUp() {
        // 创建虚拟HttpDestination（URL仅作为占位，实际请求由MockMvc处理）
        HttpDestination destination = DefaultHttpDestination.builder("http://localhost:8080")
                .build();

        // 替换Cloud SDK的HttpClient为自定义实现
        HttpClientAccessor.setHttpClient(destination, new MockMvcHttpClient(mockMvc));

        // 初始化OData服务客户端
        serviceClient = new YourODataService(destination);
    }

    // 测试用例示例：使用类型安全API查询并验证结果
    @Test
    void testFetchFilteredEntities() {
        // 用Cloud SDK类型安全构造OData查询
        List<YourEntity> entities = serviceClient.getAllYourEntity()
                .select(YourEntity.ID, YourEntity.NAME)
                .filter(YourEntity.ID.greaterThan(10))
                .executeRequest();

        // 直接验证POJO，无需手动解析JSON
        assertThat(entities).hasSize(2);
        assertThat(entities.get(0).getName()).isEqualTo("Sample Entity");
    }
}

关键注意事项 #

• HTTP方法覆盖：确保自定义HttpClient覆盖所有业务用到的HTTP方法（GET/POST/PUT/DELETE等）。
• 复杂请求处理：若涉及OData Batch请求或特殊格式的请求体，需调整convertToMockMvcRequest方法中的内容转换逻辑。
• 版本兼容性：不同版本的SAP Cloud SDK对HttpClient接口可能有细微调整，请根据实际使用版本适配代码。

这种方案既保留了MockMVC的高性能（无需启动真实服务器），又利用了SAP Cloud SDK的类型安全优势，彻底避免手动构造OData查询URL和解析JSON响应的繁琐工作。

内容的提问来源于stack exchange，提问作者Eric Jiang