mongoDB: Aggregation - 是否有相当于原生 node.js 驱动程序的 $lookup 连接？

Question

mongodb: 2.1.3

在阅读了一些关于 mongoDB 3.2 的 aggregation enhancements 之后，我对“$look”管道阶段进行左外等连接感到兴奋。

不幸的是，节点驱动程序似乎没有此运算符。（我在native driver docs for node 中没有看到它，当我尝试使用它时出现错误：

更新：这是我尝试过的代码

var cursor = db.collection('messagethreads').aggregate([
        {"$match": {
            _id: new ObjectID(threadID)}
        }, 
        {"$lookup": {
            from: "messages", 
            localField: "_id",
            foreignField: "threadID",
            as: "messagesList"}
        }
    ]);

    cursor.toArray(function(err,messages){
        if(err) {
            res.status(500).json(error);
        }
        else if(convo === null){
            res.status(400).end();
        }
        else{
            res.status(200).json(messages);
        }
    });
});

示例 - 一个 ThreadMessage 文档

{ 
    "_id" : ObjectId("56b4f52c0e6368c00630aee6"), 
    name: "Messages 1"
}

示例 - 消息文档

{
     "_id" : ObjectId("56b4f52c0e6368c00630af08"), 
     "author" : "Nick", 
     "text" : "Hello", 
     "threadID" : ObjectId("56b4f52c0e6368c00630aee6")
},
...

预期结果

{
    "_id" : ObjectId("56b4f52c0e6368c00630aee6"), 
    name: "Messages 1",
    messageList:[
        {
         "_id" : ObjectId("56b4f52c0e6368c00630af08"), 
         "author" : "Nick", 
         "text" : "Hello", 
         "threadID" : ObjectId("56b4f52c0e6368c00630aee6")
        },
        ...
    ]
}

" MongoError: 异常：无法识别的管道阶段名称：'$lookup'"

您可以阅读更多关于连接案例here！

问题：是否有预期的方式来执行与 node.js 原生驱动程序等效的操作？

Answer 1

“MongoError”异常是驱动程序如何从“服务器”报告任何错误消息，因此这种错误表明连接到的服务器不是支持$lookup的版本，为3.2或更高：

$lookup

3.2 版中的新功能。

对同一数据库中的未分片集合执行左外连接，以过滤来自“已连接”集合的文档以进行处理。 $lookup 阶段在输入文档中的字段与“加入”集合的文档中的字段之间进行相等匹配。

您始终可以通过serverStatus 数据库命令获取您要连接的服务器版本。也在完全可复制的列表中：

var async = require('async'),
    mongodb = require('mongodb'),
    MongoClient = mongodb.MongoClient,
    ObjectId = mongodb.ObjectId;

MongoClient.connect("mongodb://localhost/test",function(err,db) {

  async.series(
    [
      function(callback) {
        db.command({ "serverStatus": 1 }, function(err,status) {
          console.log(status.version);
          callback(err);
        });
      },
      function(callback) {
        async.each(['threadmessage','message'],function(colname,callback) {
          db.collection(colname).remove({},callback);
        },callback);
      },

      function(callback) {
        db.collection('threadmessage').insert(
          {
            "_id" : ObjectId("56b4f52c0e6368c00630aee6"),
            "name": "Messages 1"
          },
          callback
        );
      },

      function(callback) {
        db.collection('message').insert(
          {
            "_id" : ObjectId("56b4f52c0e6368c00630af08"),
            "author" : "Nick",
            "text" : "Hello",
            "threadID" : ObjectId("56b4f52c0e6368c00630aee6")
          },
          callback
        );
      },

      function(callback) {

        var cursor = db.collection('threadmessage').aggregate([
          { "$lookup": {
            "from": "message",
            "localField": "_id",
            "foreignField": "threadID",
            "as": "messagesList"
          }}
        ]);

        cursor.toArray(function(err,result) {
          console.log(JSON.stringify(result,undefined,2));
          callback(err);
        });
      }
    ],
    function(err) {
      if (err) throw err;
      db.close();
    }
  );

});

以及固定驱动程序版本的 package.json，只是为了表明没有驱动程序版本问题：

{
  "name": "lookup",
  "version": "1.0.0",
  "description": "",
  "main": "index.js",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "author": "",
  "license": "ISC",
  "dependencies": {
    "async": "^1.5.2",
    "mongodb": "2.1.3"
  }
}

使用受支持的服务器版本提供预期输出：

3.2.0
[
  {
    "_id": "56b4f52c0e6368c00630aee6",
    "name": "Messages 1",
    "messagesList": [
      {
        "_id": "56b4f52c0e6368c00630af08",
        "author": "Nick",
        "text": "Hello",
        "threadID": "56b4f52c0e6368c00630aee6"
      }
    ]
  }
]

因此，如果该列表未在您连接到的数据库上返回 3.2.x，则此处不支持 $lookup 管道操作，您将不得不求助于其他方法，例如拉入“相关”信息“客户端”。