arrays - MongoDB/NodeJS:遍历查询参数

我再次需要您的帮助，因为在querying through various Collections之后（感谢@SD的帮助！），我想遍历查询的参数，这变得非常令人沮丧，因为我再次不知道这是什么。发生...

我有以下代码：

var mongodb = require("mongodb");
let pairs = ["ETH/EUR", "BTC/EUR", "LTC/EUR", "BCH/EUR"];

mongodb.connect("mongodb://localhost:27017/orderInfo", function(err, db) {
  if (err) {
    throw err;
  }

  db.listCollections().toArray((err, cols) => {
    if (err) {
      throw err;
    }

    cols.forEach(col => {
      pairs.forEach(p => {
        db
          .collection(col.name)
          .findOne({ pair: "BTC/EUR" }, {}, function(err, docs) {
            if (err) {
              throw err;
            }
            console.log(col.name + "[OK]: " + docs.pair);
          });
      });
    });
  });
});

这似乎工作得很好：

Gatecoinorder[OK]: BTC/EUR
Gatecoinorder[OK]: BTC/EUR
Gatecoinorder[OK]: BTC/EUR
Gatecoinorder[OK]: BTC/EUR
Coinmateorder[OK]: BTC/EUR
Coinmateorder[OK]: BTC/EUR
Coinmateorder[OK]: BTC/EUR
Krakenorder[OK]: BTC/EUR
Krakenorder[OK]: BTC/EUR
Coinmateorder[OK]: BTC/EUR
Krakenorder[OK]: BTC/EUR
Quoineorder[OK]: BTC/EUR
Cexorder[OK]: BTC/EUR
Livecoinorder[OK]: BTC/EUR
Gdaxorder[OK]: BTC/EUR
Virwoxorder[OK]: BTC/EUR
Bl3porder[OK]: BTC/EUR
Bitlishorder[OK]: BTC/EUR
Paymiumorder[OK]: BTC/EUR
Coinfloororder[OK]: BTC/EUR
Lakebtcorder[OK]: BTC/EUR
Anxproorder[OK]: BTC/EUR
Bitbayorder[OK]: BTC/EUR
Fybseorder[OK]: BTC/EUR
Itbitorder[OK]: BTC/EUR
_1btcxeorder[OK]: BTC/EUR
Fybsgorder[OK]: BTC/EUR
Dsxorder[OK]: BTC/EUR
Vaultoroorder[OK]: BTC/EUR
Krakenorder[OK]: BTC/EUR
Bitstamporder[OK]: BTC/EUR
Cexorder[OK]: BTC/EUR
Livecoinorder[OK]: BTC/EUR
Gdaxorder[OK]: BTC/EUR
Therockorder[OK]: BTC/EUR
Bl3porder[OK]: BTC/EUR
Bitlishorder[OK]: BTC/EUR
Paymiumorder[OK]: BTC/EUR
Wexorder[OK]: BTC/EUR
Lakebtcorder[OK]: BTC/EUR
Anxproorder[OK]: BTC/EUR
Bitbayorder[OK]: BTC/EUR
Exmoorder[OK]: BTC/EUR
Itbitorder[OK]: BTC/EUR
_1btcxeorder[OK]: BTC/EUR
Fybsgorder[OK]: BTC/EUR
Coinsecureorder[OK]: BTC/EUR
Vaultoroorder[OK]: BTC/EUR
Bitstamporder[OK]: BTC/EUR
Quoineorder[OK]: BTC/EUR
Livecoinorder[OK]: BTC/EUR
Gdaxorder[OK]: BTC/EUR
Therockorder[OK]: BTC/EUR
Virwoxorder[OK]: BTC/EUR
Bitlishorder[OK]: BTC/EUR
Paymiumorder[OK]: BTC/EUR
Wexorder[OK]: BTC/EUR
Coinfloororder[OK]: BTC/EUR
Anxproorder[OK]: BTC/EUR
Bitbayorder[OK]: BTC/EUR
Exmoorder[OK]: BTC/EUR
Fybseorder[OK]: BTC/EUR
_1btcxeorder[OK]: BTC/EUR
Fybsgorder[OK]: BTC/EUR
Coinsecureorder[OK]: BTC/EUR
Dsxorder[OK]: BTC/EUR
Bitstamporder[OK]: BTC/EUR
Quoineorder[OK]: BTC/EUR
Cexorder[OK]: BTC/EUR
Livecoinorder[OK]: BTC/EUR
Therockorder[OK]: BTC/EUR
Virwoxorder[OK]: BTC/EUR
Bl3porder[OK]: BTC/EUR
Bitlishorder[OK]: BTC/EUR
Wexorder[OK]: BTC/EUR
Coinfloororder[OK]: BTC/EUR
Lakebtcorder[OK]: BTC/EUR
Anxproorder[OK]: BTC/EUR
Exmoorder[OK]: BTC/EUR
Fybseorder[OK]: BTC/EUR
Itbitorder[OK]: BTC/EUR
_1btcxeorder[OK]: BTC/EUR
Coinsecureorder[OK]: BTC/EUR
Dsxorder[OK]: BTC/EUR
Vaultoroorder[OK]: BTC/EUR
Bitstamporder[OK]: BTC/EUR
Quoineorder[OK]: BTC/EUR
Cexorder[OK]: BTC/EUR
Gdaxorder[OK]: BTC/EUR
Therockorder[OK]: BTC/EUR
Virwoxorder[OK]: BTC/EUR
Bl3porder[OK]: BTC/EUR
Paymiumorder[OK]: BTC/EUR
Wexorder[OK]: BTC/EUR
Coinfloororder[OK]: BTC/EUR
Lakebtcorder[OK]: BTC/EUR
Bitbayorder[OK]: BTC/EUR
Exmoorder[OK]: BTC/EUR
Fybseorder[OK]: BTC/EUR
Itbitorder[OK]: BTC/EUR
Fybsgorder[OK]: BTC/EUR
Coinsecureorder[OK]: BTC/EUR
Dsxorder[OK]: BTC/EUR
Vaultoroorder[OK]: BTC/EUR

我可以看到查询有效地遍历了数组的每个项目，然后返回了针对BTC / EUR的查询。但是，当我将参数pair: "BTC/EUR"更改为"p"时：

var mongodb = require("mongodb");
let pairs = ["ETH/EUR", "BTC/EUR", "LTC/EUR", "BCH/EUR"];

mongodb.connect("mongodb://localhost:27017/orderInfo", function(err, db) {
  if (err) {
    throw err;
  }

  db.listCollections().toArray((err, cols) => {
    if (err) {
      throw err;
    }

    cols.forEach(col => {
      pairs.forEach(p => {
        db.collection(col.name).findOne({ pair: p }, {}, function(err, docs) {
          if (err) {
            throw err;
          }
          console.log(col.name + "[OK]: " + docs.pair);
        });
      });
    });
  });
});

我得到以下内容：

Gatecoinorder[OK]: ETH/EUR
Gatecoinorder[OK]: BTC/EUR
/Users/ardzii/Documents/NodeJS/Invest-Fund-Crypto/node_modules/mongodb/lib/utils.js:123
    process.nextTick(function() { throw err; });
                                  ^

TypeError: Cannot read property 'pair' of null

显然，该查询适用于Gatecoinorder的ETH / EUR和BTC / EUR，但我想由于Gatecoinorder没有LTC / EUR或BCH / EUR文档，因此循环只是停止了。
我不知道为什么会停止，我的意思是，即使Gatecoinorder Collection没有LTC和BCH文档，也不应就此停止，应该吗？
该错误表明属性“ pair”为null，这意味着没有Collection？
我试图在循环中添加和if (col)，但没有帮助：

var mongodb = require("mongodb");
let pairs = ["ETH/EUR", "BTC/EUR", "LTC/EUR", "BCH/EUR"];

mongodb.connect("mongodb://localhost:27017/orderInfo", function(err, db) {
  if (err) {
    throw err;
  }

  db.listCollections().toArray((err, cols) => {
    if (err) {
      throw err;
    }

    cols.forEach(col => {
      pairs.forEach(p => {
        if (col)
          db.collection(col.name).findOne({ pair: p }, {}, function(err, docs) {
            if (err) {
              throw err;
            }
            console.log(col.name + "[OK]: " + docs.pair);
          });
      });
    });
  });
});

如何避免此错误？

提前致谢！

最佳答案

这是因为您可能没有带有某些指定对的文档。
您将不得不处理

var mongodb = require("mongodb");
let pairs = ["ETH/EUR", "BTC/EUR", "LTC/EUR", "BCH/EUR"];

mongodb.connect("mongodb://localhost:27017/orderInfo", function(err, db) {
  if (err) {
    throw err;
  }

  db.listCollections().toArray((err, cols) => {
    if (err) {
      throw err;
    }

    cols.forEach(col => {
      pairs.forEach(p => {
        if (col)
          db.collection(col.name).findOne({ pair: p }, {}, function(err, docs) {
            if (err) {
              throw err;
            }
            if(docs && docs.pair)
              console.log(col.name + "[OK]: " + docs.pair);
            else
              console.log(col.name + "[NOTOK]: No pair ");
          });
      });
    });
  });
});

关于arrays - MongoDB/NodeJS:遍历查询参数，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/47590469/