如何在mongodb模板中对聚合操作应用过滤器

Question

我使用的是spring data mongodb 4.3.6版本

并且过滤器在以下代码中不起作用。

// filter
    ArrayOperators.Filter filter = ArrayOperators.Filter.filter("messages")
        .as("message")
        .by(ComparisonOperators.Gt.valueOf("message._id").greaterThanValue(new ObjectId(startObjectId))); 
        // Apply only 1 condition due to testing

    
    Aggregation aggregation = Aggregation.newAggregation(
        Aggregation.match(Criteria.where("roomId").is(roomId)),
        Aggregation.project("messages").and(filter)
    );

    RoomMessage roomMsg = mongoTemplate.aggregate(aggregation, "room_msg", RoomMessage.class).getUniqueMappedResult();

    for (Message roomMessage : roomMsg.getMessageList()) {
        System.out.println("roomMessage.getContent() = " + roomMessage.getContent());
    }

▲ 匹配操作有效，但过滤器不起作用

实际收款单据状况：

[
{
roomId: 1
messages: [ {_id: , content: , .. } ]
},

{
roomId: 2
messages: [ {_id: , content: , .. } ]
}
.
.
]

我只想获取符合messages字段条件的消息
我想申请的查询如下：

db.room_msg.aggregate([
  { $match: { roomId: 1 } },
  { $project: { 
      messages: { 
        $filter: {
          input: "$messages",
          as: "message",
          cond: { 
            $and: [
              { $gt: [ "$$message._id", ObjectId("67622277a31d5f6390658340") ] },
              { $lt: [ "$$message._id", ObjectId("67622277a31d5f6390658345") ] }
            ]
          }
        }
      }
    }
  }
])

Answer 1

체스의달인。 很高兴在这里见到你。

您的问题不清楚，我们没有看到任何类声明。 请告诉我们

RoomMessage

的类型。