使用Spring Data MongoDB Criteria按产品ID查询关联订单的实现方法

解决方案 #

首先根据你的数据模型分两种场景处理：

场景1：Product为Order的内嵌文档数组（无独立的product集合）

你编写的代码本身逻辑是正确的，MongoDB原生支持对内嵌数组字段的属性匹配，只要订单的products数组中存在任意一个元素的id等于目标值，就会被匹配命中，完全符合你要查询包含指定ID产品订单的需求。

如果代码运行没有返回预期结果，优先排查两个常见问题：

• 检查Product类的主键字段是否配置了@Field自定义字段名，比如注解指定了字段为_id，那么查询条件就要改为Criteria.where("products._id").is(目标产品ID)
• 检查传入的产品ID类型是否和数据库存储类型一致，比如数据库存储的是ObjectId类型，你传入的是字符串类型，需要修改为Criteria.where("products.id").is(new ObjectId(你的ID字符串))

场景2：Product为独立集合，Order中存储关联的Product ID引用

如果Product单独标注了@Document注解对应独立的Mongo集合，那需要通过聚合查询的$lookup实现关联匹配，代码示例如下：

Aggregation aggregation = Aggregation.newAggregation(
    // 关联product集合，匹配Order的products字段和Product的_id字段
    Aggregation.lookup("product", "products", "_id", "matchedProducts"),
    // 过滤出关联到目标产品ID的订单
    Aggregation.match(Criteria.where("matchedProducts._id").is(目标产品ID)),
    // 可选：移除返回结果中临时生成的matchedProducts字段
    Aggregation.project().andExclude("matchedProducts")
);
List<Order> orders = mongoTemplate.aggregate(aggregation, Order.class, Order.class).getMappedResults();

多条件拼接支持 #

不管是哪种场景，都可以自由拼接and/or条件，满足你后续的过滤器扩展需求，示例如下：

// 示例：查询状态为已支付，且包含目标产品的订单
Criteria criteria = new Criteria();
criteria.and("orderStatus").is(OrderStatus.PAID)
        .and("products.id").is(目标产品ID);
query.addCriteria(criteria);

// 示例：查询包含产品A 或 包含产品B的订单
Criteria orCriteria = new Criteria().orOperator(
    Criteria.where("products.id").is(产品A_ID),
    Criteria.where("products.id").is(产品B_ID)
);
query.addCriteria(orCriteria);

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