node.js - Mongojs回调不返回

Question

我正在使用 mongojs 更新 mongodb 集合中的数据。该程序逐行读取文件，并且对于每一行，它都会在 mongodb 数据库中进行更新。更新工作正常，但控件不返回。

var fs = require('fs')
var reader = require('buffered-reader');
var dataReader = reader.DataReader;

var mongojs = require('mongojs')
var db = mongojs.connect('testdb');
var col = db.collection('testCollection');

var file = "sample.txt";

var loadData = function (line) {
    record = line.split(",");
    rec_key = record[1];
    col.update(
        {rec_key: rec_key},
        {rec_key: rec_key,
         data: 5678},
        {upsert:true}, function(err){});
}

new dataReader (file, { encoding: "utf8" })
    .on ("error", function(error){
            console.log ("error: " + error);
        })
    .on ("line", loadData )
    .on ("end", function (end){
            console.log("EOF");
        }).read();

从节点运行完这个后，控件不会返回。该程序无限期运行。如果我在 dataReader 中注释 loadData 函数，它工作正常，程序在遍历所有行后结束。

在遍历所有行并在 mongodb 中进行更新后，如何使程序结束？

Answer 1

You need to close your MongoDB connection when you're done with it or it will hold the program open.

Something like:

.on ("end", function (end){
        console.log("EOF");
        db.close();
    }

Answer 2

   col.update(
    {rec_key: rec_key},
    {rec_key: rec_key,
     data: 5678},
    {upsert:true}, function(err){
        if(err)
          //return false
        else
          //return true
    });

Answer 3

我建议您尝试使用 node.js 本机驱动程序，因为您可以使用最新版本。