如何在MongoDB的ProjectionOperation中添加字符串数组实现动态投影

你遇到的问题核心在于Spring Data MongoDB的ProjectionOperation是不可变对象——每次调用andInclude()方法时，它不会修改原实例，而是返回一个全新的ProjectionOperation对象。你之前的循环里只是调用了方法，但没有把新实例重新赋值给project变量，导致最终的ProjectionOperation还是空的，自然会触发"at least one field need to specify in project"的错误。

下面是正确的实现方式，分步骤说明：

1. 预处理字段参数 #

首先把URI传来的逗号分隔字符串转换成干净的字段列表，注意处理空值、空格等异常情况：

// 假设从URI参数获取的fields字符串
String fieldsParam = "id,name";
List<String> fields = Arrays.stream(fieldsParam.split(","))
                           .map(String::trim)
                           .filter(field -> !field.isEmpty())
                           .collect(Collectors.toList());

2. 动态构建ProjectionOperation #

因为ProjectionOperation不可变，所以每次调用andInclude()后都要重新赋值给变量。同时要处理字段列表为空的边界情况（比如默认保留_id，或者根据业务需求抛出异常）：

ProjectionOperation project;

if (fields.isEmpty()) {
    // 字段为空时的默认处理，示例为保留_id，可根据业务调整
    project = project("_id");
} else {
    // 初始化第一个字段
    project = project(fields.get(0));
    // 循环添加剩余字段，每次将返回的新实例重新赋值
    for (int i = 1; i < fields.size(); i++) {
        project = project.andInclude(fields.get(i));
    }
}

也可以用更简洁的Stream流式写法：

ProjectionOperation project = fields.stream()
                                    .reduce(
                                        null,
                                        (proj, field) -> proj == null ? project(field) : proj.andInclude(field),
                                        (proj1, proj2) -> proj1.andInclude(proj2.getFields())
                                    );

3. 构建完整的聚合查询 #

把动态生成的ProjectionOperation和skip、limit组合起来：

int page = 1; // 假设从URI获取的页码
int limit = 10; // 假设从URI获取的每页条数

Aggregation aggregation = newAggregation(
    project,
    skip((page - 1) * limit),
    limit(limit)
);

验证结果 #

当fieldsParam为"id,name"时，生成的ProjectionOperation对应的MongoDB查询语句就是：

{ "$project" : {"id": 1, "name": 1} }

和你预期的完全一致，最终聚合查询会返回只包含指定字段的文档。

为什么原来的代码不生效？ #

再强调关键原因：ProjectionOperation是不可变的，你的原代码中：

ProjectionOperation project = project();
for(String field : fields) {
    project.andInclude(field); // 仅调用方法但未接收返回的新实例
}

循环结束后，project还是最初的空ProjectionOperation对象，所以MongoDB会报错要求至少指定一个字段。必须把每次andInclude()的返回值重新赋值给project，才能累积添加字段。

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