0

当下一个查询需要同一个集合的结果时，如何进行嵌套查询？

var mongo = require('../config/mongo');

var mongoDB = mongo.db;
...

exports.myFunction = function(req, res) {

...
...
// e.g. myArray = ['a','b','c'];

mongoDB.collection('MyCollection', function(err, collection) {
    collection.find({ $or: [{ 'source': {$in: myArray} },{ 'target': {$in: myArray} }]}, { "someVar": 0}).toArray(function(err, firstResults) {

            var allResults = [];
            for (var i = 0; i < firstResults.length; i++) {
                allResults[firstResults[i].source]=1;
                allResults[firstResults[i].target]=1;
            };

            var secondResults = Object.keys(allResults);

            mongoDB.collection('MyCollection', function(err, collection) {
                collection.find({ $or: [{ 'source': {$in: secondResults} },{ 'target': {$in: secondResults} }]}, { "someVar": 0}).toArray(function(err, items) {
                    res.send(items);
                });
            });


    });
});

但它不喜欢我将同一个集合称为“MyCollection”两次。我正在尝试获取其源或目标涉及 secondResults 的任何文档。

4

1 回答 1

5

您应该摆脱打开“MyCollection”的第二次调用。打开一次后，您已经拥有一个“MyCollection”对象。也就是说，你有这个：

mongoDB.collection('MyCollection', function(err, collection) {
  collection.find({ $or: [{ 'source': {$in: secondResults} },{ 'target': {$in: secondResults} }]}, { "someVar": 0}).toArray(function(err, items) {
    res.send(items);
   });
});

但是您已经从这里获得了一个“MyCollection”实例：

mongoDB.collection('MyCollection', function(err, collection) {
  collection.find({ $or: [{ 'source': {$in: myArray} },{ 'target': {$in: myArray} }]}, { "someVar": 0}).toArray(function(err, firstResults) {

因此，由于对“收集”的第二次调用在第一次调用的范围内，您可以（并且应该）重用该实例：

collection.find({ $or: [{ 'source': {$in: secondResults} },{ 'target': {$in: secondResults} }]}, { "someVar": 0}).toArray(function(err, items) {
  res.send(items);
});

或者，如果您使用的是node-mongodb-native，您可以查看一些示例以了解完成您所追求的其他方式。

更新 1

这段代码对我有用：

var MongoClient = require('mongodb').MongoClient;
MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db){
  if(err) throw err;

  var collection = db.collection('c');
  var secondQuery = {};

  collection.find({a:'b'}).toArray(function(err, firstRes){
    for(var i = 0; i < firstRes.length; i++){
      secondQuery[firstRes[i].a] = firstRes[i].b;
    }

    collection.find(secondQuery).toArray(function(err, secondRes){
      for(var i = 0; i < secondRes.length; i++){
        console.log(secondRes[i]);
      }

      db.close();
    });
  });
});

更新 2

请注意，上面的代码使用的是node-mongodb-native 版本 1.3.19。从 1.2 版本开始，建议在Node.js 驱动与 mongodb 交互时使用 MongoClient。

于 2013-11-11T16:49:36.780 回答