如果使用 .toArray()，我知道您可以像这样在回调中使用 db.close():

db.collection('grades').find(query).toArray(function(err, docs) {
  if (err) throw err;
  console.dir(docs);
  db.close();
});

但是如果你需要遍历数组怎么办？ 1) 遍历游标以构造数组然后 2) 遍历数组以完成工作似乎过多。所以我在想使用 cursor.forEach() 会很好.

var MongoClient = require('mongodb').MongoClient;

MongoClient.connect('mongodb://localhost:27017/weather', function(err, db) {
  if (err) throw err;

  var cursor = db
                .collection('data')
                .find({})
                .sort({State: 1, Temperature: -1});

  var prevState = '';
  var curr;

  cursor.forEach(function(doc) {
    if (doc.State === prevState) return;

    db.collection('data').update(doc, { $set: { month_high: true}});
    prevState = doc.State;
  });

  db.close();
});

但是，这给了我一个错误:

~/code/m101js $ node test.js
/Users/azerner/code/node_modules/mongodb/lib/utils.js:97
    process.nextTick(function() { throw err; });
                                        ^
TypeError: undefined is not a function
    at /Users/azerner/code/node_modules/mongodb/lib/cursor.js:527:15
    at handleCallback (/Users/azerner/code/node_modules/mongodb/lib/utils.js:95:12)
    at /Users/azerner/code/node_modules/mongodb/lib/cursor.js:493:22
    at handleCallback (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/cursor.js:234:5)
    at /Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/cursor.js:533:22
    at queryCallback (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/cursor.js:167:20)
    at Callbacks.flush (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/topologies/server.js:86:7)
    at Server.destroy (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/topologies/server.js:694:41)
    at Server.close (/Users/azerner/code/node_modules/mongodb/lib/server.js:344:17)
    at Db.close (/Users/azerner/code/node_modules/mongodb/lib/db.js:273:19)
~/code/m101js $ node test.js
/Users/azerner/code/node_modules/mongodb/lib/utils.js:97
    process.nextTick(function() { throw err; });
                                        ^
TypeError: undefined is not a function
    at /Users/azerner/code/node_modules/mongodb/lib/cursor.js:527:15
    at handleCallback (/Users/azerner/code/node_modules/mongodb/lib/utils.js:95:12)
    at /Users/azerner/code/node_modules/mongodb/lib/cursor.js:493:22
    at handleCallback (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/cursor.js:234:5)
    at /Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/cursor.js:533:22
    at queryCallback (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/cursor.js:167:20)
    at Callbacks.flush (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/topologies/server.js:86:7)
    at Server.destroy (/Users/azerner/code/node_modules/mongodb/node_modules/mongodb-core/lib/topologies/server.js:694:41)
    at Server.close (/Users/azerner/code/node_modules/mongodb/lib/server.js:344:17)
    at Db.close (/Users/azerner/code/node_modules/mongodb/lib/db.js:273:19)
~/code/m101js $

这似乎都是库代码，我不太确定如何调试它。但看起来问题出在 db.close() 中。

1. 是这样吗？
2. 如果是这样，那么我还能把 db.close() 放在哪里？

最佳答案

问题是调用了 db.close()，然后我尝试与数据库交互。当连接已经关闭时，您无法与数据库进行交互。

我的代码在连接关闭后尝试与数据库交互的原因是因为 .update() 是异步的。

使用 async.each为我工作。 async.each 为您提供一个回调，以便在循环遍历集合中的所有内容后运行。我在该回调中调用了 db.close()，这是我想要关闭与数据库的连接的时间。

关于javascript - 使用 cursor.forEach() 时什么时候调用 db.close()？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30675618/