使用 mongodb 和 node js 制作一个有历史的聊天系统

Question

尝试与历史聊天，我在使用 mongodb 和 node js 时遇到了一些问题 要清楚： 我可以在 mongodb 集合中保存一条新消息 部分代码：

MongoClient.connect('mongodb://127.0.0.1:27017/gt-chat', function(err, db) {
    if(err) throw err;

    var collection = db.collection('gt-chat');


    collection.insert({message:mess}, function(err, docs) {
        console.log("//////////////\r\n mess insertion :"+mess);
        collection.count(function(err, count) {
            console.log(format("count = %s", count));
        });
    });

但我无法从 mongodb 中读取内容 我试过了：

MongoClient.connect('mongodb://127.0.0.1:27017/gt-chat', function(err, db) {
    if(err) throw err;

    var collection = db.collection('gt-chat');

    console.log("Printing docs from Cursor Each")

    // Find all records. find() returns a cursor

    // Print each row, each document has an _id field added on insert
    // to override the basic behaviour implement a primary key factory
    // that provides a 12 byte value

    collection.find().each(function(err, doc) {

    console.log(doc);
    if(doc != null) {
        console.log("Doc from Each ");
        console.dir(doc);
    }
});

但没有成功，它返回“null”作为结果，这对我来说听起来很奇怪:(

非常感谢您对此的帮助！:)

Answer 1

您正在链接到查询。这意味着您在 mongo 光标上运行 .each 循环。您要做的就是将查询传递给回调。

collection.find({},function(err,doc){
    //do stuff with doc and err
 })

Answer 2

我试过你的代码，它工作正常。

doc 在最后一次调用 each 回调时为 null 是正常的，这表明光标已用尽（请参阅 docs 示例代码中的注释以获取 each） .

我对您的代码所做的只是添加一个尾随 }); 以便它运行：

MongoClient.connect('mongodb://127.0.0.1:27017/gt-chat', function(err, db) {
    if(err) throw err;

    var collection = db.collection('gt-chat');

    console.log("Printing docs from Cursor Each")

    collection.find().each(function(err, doc) {

        console.log(doc);
        if(doc != null) {
            console.log("Doc from Each ");
            console.dir(doc);
        }
    });
});

哪些输出：

Printing docs from Cursor Each
{ _id: 5480e2667baf089e0b055c7a,
  message: 'The quick brown fox jumps over the lazy dog' }
Doc from Each 
{ _id: 5480e2667baf089e0b055c7a,
  message: 'The quick brown fox jumps over the lazy dog' }
{ _id: 5480e293744a68a90b3f44fb,
  message: 'The quick brown fox jumps over the lazy dog' }
Doc from Each 
{ _id: 5480e293744a68a90b3f44fb,
  message: 'The quick brown fox jumps over the lazy dog' }
null

我使用 message 运行了您的 insert 代码两次以添加它显示的两个文档。

var mess = 'The quick brown fox jumps over the lazy dog';
MongoClient.connect('mongodb://127.0.0.1:27017/gt-chat', function(err, db) {
    if(err) throw err;

    var collection = db.collection('gt-chat');

    collection.insert({message:mess}, function(err, docs) {
        console.log("//////////////\r\n mess insertion :"+mess);
        collection.count(function(err, count) {
            console.log("count = %s", count);
        });
    });
});