Mongodb Morphia 聚合

Question

我在 Morphia 中创建聚合时遇到问题，文档确实不清楚。这是原始查询：

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"
          }
        ]
      }
    ]);

他们的文档中唯一的例子是使用了，这里有一些例子，但我无法让它工作。

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

    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. Morphia 中的复杂 AND-OR 查询
2. Morphia 查询与或运算符

当然还有AggregationTest.java Github 页面