java - Mongodb Morphia聚合

Question

我在 Morphia 中创建聚合时遇到问题，documentation真的不清楚。这是原始查询:

db.collection('events').aggregate([
  {
    $match: {
      "identifier": {
        $in: [
          userId1, userId2
        ]
      },
      $or: [
        {
          "info.name": "messageType",
          "info.value": "Push",
          "timestamp": {
            $gte: newDate("2015-04-27T19:53:13.912Z"),
            $lte: newDate("2015-08-27T19:53:13.912Z")
          }
        }
      ]
    }{
      $unwind: "$info"
    },
    {
      $match: {
        $or: [
          {
            "info.name": "messageType",
            "info.value": "Push"
          }
        ]
      }
    ]);

他们文档中的唯一示例是使用 out 并且有一些示例 here但我无法让它工作。

我什至没有通过第一场比赛，这就是我所拥有的:

    ArrayList<String> ids = new ArrayList<>();
            ids.add("199941");
            ids.add("199951");
    Query<Event> q = ads.getQueryFactory().createQuery(ads);
    q.and(q.criteria("identifier").in(ids));
    AggregationPipeline pipeline = ads.createAggregation(Event.class).match(q);
Iterator<Event> iterator =  pipeline.aggregate(Event.class);

一些帮助或指导以及如何开始查询或查询如何工作会很棒。

Answer 1

您需要为 match() 创建查询通过将您的代码分解为易于遵循的可管理部分来构建流水线。那么让我们开始吧使用匹配标识符字段的查询，到目前为止你已经做得很好了。然后我们需要结合 $or查询的一部分。

从您离开的地方继续，将完整的查询创建为:

Query<Event> q = ads.getQueryFactory().createQuery(ads);
Criteria[] arrayA = {
    q.criteria("info.name").equal("messageType"), 
    q.criteria("info.value").equal("Push"),
    q.field("timestamp").greaterThan(start);
    q.field("timestamp").lessThan(end);
};

Criteria[] arrayB = {
    q.criteria("info.name").equal("messageType"), 
    q.criteria("info.value").equal("Push")  
};

q.and(
    q.criteria("identifier").in(ids),
    q.or(arrayA)
);

Query<Event> query = ads.getQueryFactory().createQuery(ads);
query.or(arrayB);

AggregationPipeline pipeline = ads.createAggregation(Event.class)
                                  .match(q)
                                  .unwind("info")
                                  .match(query);
Iterator<Event> iterator =  pipeline.aggregate(Event.class);

以上内容未经测试，但会引导您到更近的地方，因此请在适当的时候进行一些必要的调整。对于一些引用，以下 SO 问题可能会给您一些指示:

1. Complex AND-OR query in Morphia
2. Morphia query with or operator

当然还有 AggregationTest.java Github页面