te')); return $arr; } /* 遍历用户所有主题 * @param $uid 用户ID * @param int $page 页数 * @param int $pagesize 每页记录条数 * @param bool $desc 排序方式 TRUE降序 FALSE升序 * @param string $key 返回的数组用那一列的值作为 key * @param array $col 查询哪些列 */ function thread_tid_find_by_uid($uid, $page = 1, $pagesize = 1000, $desc = TRUE, $key = 'tid', $col = array()) { if (empty($uid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('uid' => $uid), array('tid' => $orderby), $page, $pagesize, $key, $col); return $arr; } // 遍历栏目下tid 支持数组 $fid = array(1,2,3) function thread_tid_find_by_fid($fid, $page = 1, $pagesize = 1000, $desc = TRUE) { if (empty($fid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('fid' => $fid), array('tid' => $orderby), $page, $pagesize, 'tid', array('tid', 'verify_date')); return $arr; } function thread_tid_delete($tid) { if (empty($tid)) return FALSE; $r = thread_tid__delete(array('tid' => $tid)); return $r; } function thread_tid_count() { $n = thread_tid__count(); return $n; } // 统计用户主题数 大数量下严谨使用非主键统计 function thread_uid_count($uid) { $n = thread_tid__count(array('uid' => $uid)); return $n; } // 统计栏目主题数 大数量下严谨使用非主键统计 function thread_fid_count($fid) { $n = thread_tid__count(array('fid' => $fid)); return $n; } ?>javascript - node-mongodb-native - cursor returns null as last value during an each call - Stack Overflow
最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

javascript - node-mongodb-native - cursor returns null as last value during an each call - Stack Overflow

programmeradmin2浏览0评论

So. I have a very basic script, that connects to a database and does a find on a collection that has a lot of documents and limit it to 3 items. Everything runs smoothly except that at the end of my results, a null and the script doesn't terminate instead of closing the connection quietly after having succeedeed.

Here I declare my params and create my database object:

var SERVER = 'localhost',
 PORT = 27017,
 DATABASE = 'test',
 COLLECTION = 'coll',
 mongo = require('mongodb'),
 db = new mongo.Db(DATABASE,
  new mongo.Server(SERVER, PORT, {auto_reconnect: true}),
  {});

And here I connect to the database and proceed to query it with a find cursor and the each function:

db.open(function(err, db) {
 if(err) throw err;
 var collection = new mongo.Collection(db, COLLECTION),
  cursor = collection.find({}, {}).limit(3);
 cursor.each(function(err, doc) {
  if(err) throw err;
  console.log(doc);
 });
 db.close();
});

Results are nice:

{ _id: '1',
  a: 'first object' }
{ _id: '2',
  a: 'second object' }
{ _id: '3',
  a: 'third object' }

up until the point where a

null

appears.

As described above, the script then proceeds not to terminate.

I don't get why and would appreciate pointers on how to make it terminate nicely.

So. I have a very basic script, that connects to a database and does a find on a collection that has a lot of documents and limit it to 3 items. Everything runs smoothly except that at the end of my results, a null and the script doesn't terminate instead of closing the connection quietly after having succeedeed.

Here I declare my params and create my database object:

var SERVER = 'localhost',
 PORT = 27017,
 DATABASE = 'test',
 COLLECTION = 'coll',
 mongo = require('mongodb'),
 db = new mongo.Db(DATABASE,
  new mongo.Server(SERVER, PORT, {auto_reconnect: true}),
  {});

And here I connect to the database and proceed to query it with a find cursor and the each function:

db.open(function(err, db) {
 if(err) throw err;
 var collection = new mongo.Collection(db, COLLECTION),
  cursor = collection.find({}, {}).limit(3);
 cursor.each(function(err, doc) {
  if(err) throw err;
  console.log(doc);
 });
 db.close();
});

Results are nice:

{ _id: '1',
  a: 'first object' }
{ _id: '2',
  a: 'second object' }
{ _id: '3',
  a: 'third object' }

up until the point where a

null

appears.

As described above, the script then proceeds not to terminate.

I don't get why and would appreciate pointers on how to make it terminate nicely.

Share Improve this question edited Aug 21, 2023 at 13:33 bflemi3 6,79021 gold badges95 silver badges158 bronze badges asked Aug 30, 2012 at 21:06 m09m09 7,4933 gold badges33 silver badges61 bronze badges
Add a ment  | 

2 Answers 2

Reset to default 10

This question's a few years old, and already has a possible answer, but I just wanted to point out another possibility for anyone who's still confused after reading this. Turns out, each repeatedly calls nextObject which actually is intended to return null when the cursor is exhausted.

The answer here was the one I needed: Node Mongo Native - how to tell when a cursor is exhausted?

From the Node MongoDB driver docs: http://mongodb.github.io/node-mongodb-native/api-generated/cursor.html#nextobject

Well, that was stupid. Too much time without programming in an async setup and you make mistakes: the db.close() call came before the each looping was over. Returned null and hanged because of that. Here is the correct code:

db.open(function(err, db) {
 if(err) throw err;
 var collection = new mongo.Collection(db, COLLECTION),
  cursor = collection.find({}, {}).limit(3);
 cursor.each(function(err, doc) {
  if(err) throw err;
  if(doc !== null) console.log(doc);
  else db.close();
 });
});

I hope it'll save some minutes to someone, somehow.

发布评论

评论列表(0)

  1. 暂无评论