MongoDB聚合不同的集合

Question

我从昨天开始就一直在尝试做这个聚合，但没有运气，希望你们能给我一些想法。一点背景知识，我有 2 个集合，一个用于结果，另一个用于问题。结果基本上是人们解决问题的地方，所以如果我没记错的话，它可以有 1 个问题或最多 99 个问题。这是简化的架构：

Results Schema:
_id: ObjectId("6010664ac5c4f77f26f5d005")
questions: [
  {
    _id: ObjectId("5d2627c94bb703bfcc910763"),
    correct: false
  },
  {
    _id: ObjectId("5d2627c94bb703bfcc910764"),
    correct: true
  },
  {
    _id: ObjectId("5d2627c94bb703bfcc910765"),
    correct: true
  }
]

所以，对于这个特定的对象，用户回答了 3 个问题，其中 2 个是正确的。

Questions Schema:
_id: ObjectId("5d2627c94bb703bfcc910763")

我正在努力做的是：对于所有问题架构中的每个元素，我必须检查问题是否得到回答 - 即（检查问题架构上是否有问题数组的 _id == _id，是的可以有多个问题与 Questions Schema 具有相同的 _id，但 Questions Schema _id 是唯一的）。如果该问题得到了回答，我需要检查是否正确=真，如果是，我将其添加到一个正确答案变量中，如果不是，则为错误答案。

到目前为止，我已经尝试了很多条件，分组以获得正确和错误答案的 $sum，查找以加入两个集合，但到目前为止，我什至无法只显示聚合结果。

我尝试过的其中一件事（我试图先做一些小步骤）但如前所述，甚至无法打印结果。

Result.aggregate([
    $lookup: {
      from: 'question',
      localField: 'questions._id',
      foreignField: '_id',
      as: 'same'
    },

但这让我将两个集合结合在一起，并且“相同”作为空数组出现，尝试使用 match 也没有运气。 我还做了一个 $project 来获取我想要的信息

$project: {
  _id: 0,
  questions: {
  _id: 1,
  correct: 1
  }
},

尝试使用 $group： $组：{ _id: "$_id", $cond: {if: {"$correct": { $eq: true}}, then: {testField: {$sum: 1}}, else: {testField: 0}} } 正如我所说，我只是尝试做一些小步骤，所以 testField 是手动设置的，还尝试了 stackoverflow 中的许多其他事情。 非常感谢您的帮助，并为很长的文字感到抱歉，只是想举一些我做过并尝试过的例子。

TLDR：需要从Results Schema中找到一个question，其中_id与Questions Schema中的一个_id匹配，如果有，检查是correct: true还是@ 987654331@。相应地更新Questions Schema，从Questions Schema 中的每个question 有多少是正确的，多少是错误的。 示例：newField: {correctAnswer: 4, wrongAnswer: 3} 所以在这种情况下，Result schemaquestion 数组中有 7 个问题与来自Question Schema 的_id 匹配，4 个问题具有 correct: true，3 个问题具有 correct: false。然后在Question Schema的其余部分继续这样下去@

Answer 1

对于由于Question 集合位于不同数据库中而无法使用"$lookup" 的场景，Result 集合可用于生成输出文档以更新Question 集合。

这是一种方法。

db.Result.aggregate([
  {
    "$unwind": "$questions"
  },
  {
    "$group": {
      "_id": "$questions._id",
      "correct": {
        "$push": "$questions.correct"
      }
    }
  },
  {
    "$project": {
      "newField": {
        "correctAnswers": {
          "$size": {
            "$filter": {
              "input": "$correct",
              "as": "bool",
              "cond": "$$bool"
            }
          }
        },
        "wrongAnswers": {
          "$size": {
            "$filter": {
              "input": "$correct",
              "as": "bool",
              "cond": { "$not": "$$bool" }
            }
          }
        }
      }
    }
  }
])

试试mongoplayground.net。

Answer 2

我不知道有什么方法可以同时使用"$lookup" 和update。可能有更好的方法来做到这一点，但下面的聚合管道创建了可以在后续update 中使用的文档。管道通过单个 Result _id 正确计算重复问题，以防有人一直尝试问题直到他们做对为止。一个可能的问题是，如果问题没有 Result 答案，则不会创建 "newField": { "correctAnswers": 0, "wrongAnswers": 0 } 文档。

db.Question.aggregate([
  {
    // lookup documents in Result that match _id
    "$lookup": {
      "from": "Result",
      "localField": "_id",
      "foreignField": "questions._id",
      "as": "results"
    }
  },
  {
    // unwind everything
    "$unwind": "$results"
  },
  {
    // more of everything
    "$unwind": "$results.questions"
  },
  {
    // only keep answers that match question
    "$match": {
      "$expr": { "$eq": [ "$_id", "$results.questions._id" ] }
    }
  },
  {
    // reassemble and count correct/wrong answers
    "$group": {
      "_id": "$_id",
      "correct": {
        "$sum": {
          "$cond": [ { "$eq": [ "$results.questions.correct", true ] }, 1, 0 ]
        }
      },
      "wrong": {
        "$sum": {
          "$cond": [ { "$eq": [ "$results.questions.correct", false ] }, 1, 0 ]
        }
      }
    }
  },
  {
    // project what you want as output
    "$project": {
      newField: {
        correctAnswers: "$correct",
        wrongAnswers: "$wrong"
      }
    }
  }
])

试试mongoplayground.net。