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

你需要，当你用它做关闭您的MongoDB连接或将持有的程序中打开。

喜欢的东西：

.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的本地驱动程序，而不是因为你可以使用最新版本。