Mongo Java Driver 3.6.3 POJO映射优化后，如何简化Java原生查询构建？

确实，Mongo Java Driver 3.6.3的POJO映射已经帮我们省去了不少样板代码，但原生查询（尤其是聚合管道这类）的构建还是容易写得繁琐又冗长。我整理了几个实用的优化方向，帮你简化这个过程：

1. 用静态导入简化基础类调用 #

很多时候我们反复写BasicDBObject、BasicDBList这些类的构造，用静态导入可以省去全类名的书写，让代码更简洁：

import static com.mongodb.client.model.Aggregates.*;
import static com.mongodb.client.model.Filters.*;
import static com.mongodb.client.model.Projections.*;
import static org.bson.Document.parse;

比如原来需要这样写聚合管道：

List<Document> pipeline = new ArrayList<>();
pipeline.add(new Document("$match", new Document("status", "active")));

用了静态导入后可以简化成：

List<Document> pipeline = Arrays.asList(
    match(eq("status", "active")),
    project(fields(include("name", "email"), excludeId()))
);

2. 直接用JSON字符串解析为Document #

如果查询逻辑比较复杂，手写嵌套的BasicDBObject容易出错，不如直接写你熟悉的Mongo Shell风格的JSON查询，再用Document.parse()转成对象：

String matchStage = "{ $match: { status: 'active', age: { $gte: 18 } } }";
Document matchDoc = Document.parse(matchStage);
pipeline.add(matchDoc);

这种方式对熟悉Mongo原生语法的人来说更直观，也减少了嵌套代码的层级，降低出错概率。

3. 封装自定义查询工具类 #

针对项目中常用的查询场景，封装自己的工具方法，把重复的逻辑抽离出来，既减少代码冗余，也提升可读性：

public class MongoQueryUtils {
    // 构建通用的匹配条件
    public static Document buildMatchQuery(String status, Integer minAge) {
        Document match = new Document();
        match.append("status", status);
        if (minAge != null) {
            match.append("age", new Document("$gte", minAge));
        }
        return new Document("$match", match);
    }

    // 分页跳过阶段
    public static Document buildSkipStage(int skip) {
        return new Document("$skip", skip);
    }

    // 可以根据项目需求添加更多通用方法
}

之后使用的时候直接调用即可：

pipeline.add(MongoQueryUtils.buildMatchQuery("active", 18));
pipeline.add(MongoQueryUtils.buildSkipStage(10));

4. 借助Builder模式构建复杂查询 #

如果项目中有大量复杂的查询需求，可以自己实现Builder类，用链式调用的方式构建查询，让代码更流畅易读：

public class AggregationPipelineBuilder {
    private final List<Document> stages = new ArrayList<>();

    public AggregationPipelineBuilder match(Document matchCondition) {
        stages.add(new Document("$match", matchCondition));
        return this;
    }

    public AggregationPipelineBuilder project(Document projection) {
        stages.add(new Document("$project", projection));
        return this;
    }

    // 按需添加更多管道阶段的方法，比如sort、group等
    public AggregationPipelineBuilder sort(Document sortCondition) {
        stages.add(new Document("$sort", sortCondition));
        return this;
    }

    public List<Document> build() {
        return new ArrayList<>(stages);
    }
}

使用示例：

List<Document> pipeline = new AggregationPipelineBuilder()
    .match(eq("status", "active"))
    .project(fields(include("name", "email")))
    .sort(new Document("age", -1))
    .build();

5. 考虑升级到更高版本的Driver #

如果项目允许的话，升级到Mongo Java Driver 4.x及以上版本会更好——新版本对查询构建API做了大量优化，比如支持用Lambda表达式构建查询、更简洁的聚合操作API，甚至增强了POJO的映射能力，能进一步减少样板代码的编写。

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