使用来自另一个集合的属性筛选mongodb上文档的更好方法

Question

我试图使用来自另一个集合的属性过滤mongodb上的文档，但问题是我需要先获取所有对象，然后再执行筛选。以下是我的现状：

当前数据：

/* Message collection */
/* 1 */
{
    "_id" : ObjectId("571063533e41b42c2753828a"),
    "user" : ObjectId("570ae3d0a27d4cd44730fc38"),
    "text" : "First text",
    "enabled" : true,
    "deleted" : false,
    "__v" : 0
}

/* 2 */
{
    "_id" : ObjectId("5712a9be27adcff81ea5a39f"),
    "user" : ObjectId("5f236vgh74de563swer120rt"),
    "text" : "Second text",
    "deleted" : false,
    "enabled" : true,
    "__v" : 0
}

/* User collection */
/* 1 */
{
    "_id" : ObjectId("570ae3d0a27d4cd44730fc38"),
    "email" : "test@test.com",
    "showMessage" : true,
    "__v" : 0
}

/* 2 */
{
    "_id" : ObjectId("5f236vgh74de563swer120rt"),
    "email" : "test1@test.com",
    "showMessage" : false,
    "__v" : 0
}

当前的过滤方式：

Message.aggregate([{
            $match: {
                enabled: true,
                deleted: false
            }
        }, {
            $lookup: {
                from: 'users',
                localField: 'user',
                foreignField: '_id',
                as: 'user'
            }
        }], function(err, messages) {
            if (err) {
                reject(err);
            } else {
                var filteredMessages = this.filterMessages(messages);
                //do other stuff with the filtered data
            }
        });

filterMessages(messages) {
    return messages.filter((current) => {
        return current.user[0].showMessage;
    });
}

正如您所看到的，我正在尝试使用来自messages的属性showMessages来获取user，但是我在首先获得所有消息之后执行筛选，这是一种效率低下的方法。

是否有一种方法只获取我需要的消息，使用来自另一个集合的属性过滤它们？

注意:我需要用用户属性过滤所有的消息，而不是相反，我的意思是，我不能得到用户，然后再过滤消息。

Answer 1

只需直接在集合中执行，而不是：

Message.aggregate([
  { "$match": {
    "enabled": true,
    "deleted": false  
  }},
  { "$lookup": {
    "from": "users",
    "localField": "user",
    "foreignField": "_id",
    "as": "user"
  }},
  { "$unwind": "user" },
  { "$redact": {
      "if": "$user.showMessage",
      "then": "$$KEEP",
      "else": "$$PRUNE"
  }}
],function(err,messages) {
    if (err) reject(err);
    // Already filtered
})

因此，您可以$unwind单个关系(因为$lookup是一个“左连接”)，然后在值为true/false的条件下，简单地使用$redact。

或者反向执行$lookup，这可能更有表现力：

User.aggregate([
  { "$match": { "showMessage": true } },
  { "$lookup": {
    "from": "messages",
    "localField": "_id",
    "foreignField": "user",
    "as": "messages"
  }},
  { "$unwind": "$messages" },
  { "$match": {
      "messages.enabled": true,
      "messages.deleted": false
  }},
  { "$project": {
    "_id": "$messages._id",
    "user": {
      "_id": "$_id",
      "email": "$email",
      "showMessage": "$showMessage"
    },
    "text": "$messages.text",
    "deleted": "$messages.deleted",
    "enabled": "$messages.enabled"
  }}
],function(err,messages) {

})

目前，$lookup操作符本身并不基于“本地”和“外域”字段属性匹配的任何其他条件来“查询”文档。在以后的版本中，这种情况很可能会改变。

但是现在，在随后的聚合管道阶段，您将进一步进行“过滤”。

另一种情况实际上是在“反向”查询，其中获取有效User数据的User值，然后只检索消息。但是，当然，只有当$in的结果列表实际上不太大时：

async.waterfall
  [
    function(callback) {
      User.find({ "showMesage": true }).select("_id").exec(callback);
    },
    function(users,callback) {
      Message.find({
        "user": { "$in": users.map((current) => { return current._id }) },
        "enabled": true,
        "deleted": false
      }).populate("user").exec(callback);
    }
  ],function(err,messages) {
    // filter and populated
  }
)

与$lookup相比，这是额外的查询，但是在最终匹配时处理的结果较少。

这真的取决于您的情况是什么与数据，哪些是最好的工作在这里，所以你真的应该测试它。我的猜测是，使用$lookup的“反向”拼贴选择或使用$in的后一种情况将是更好的选择。但是，它实际上取决于哪个查询产生的结果最少，而哪个"order“是最好的。