我有一个简单的代码试图在MongoDB集合中查找文档.我可以通过Mongo的shell客户端正常找到它,但通过Node是不可能的,我已经尝试了很多方法无济于事.
首先来自MongoDB本身的结果:
raul@rmedina:~$ mongo sdk_back
MongoDB shell version: 2.0.6
connecting to: sdk_back
> db.metadatos.find();
{ "_id" : ObjectId("514cbee35c10db0299c015c7"), "tipo" : "proceso" }
> db.metadatos.findOne({"tipo":"proceso"});
{ "_id" : ObjectId("514cbee35c10db0299c015c7"), "tipo" : "proceso" }
> db.metadatos.findOne({tipo:"proceso"});
{ "_id" : ObjectId("514cbee35c10db0299c015c7"), "tipo" : "proceso" }
>
Run Code Online (Sandbox Code Playgroud)
如您所见,find和findOne查询都有效.现在这是我的节点代码:
var utils = require('../utils/utils.js'),
Server = require('mongodb').Server,
Db = require('mongodb').Db;
exports.procesaJSON = function (input_json){
if(!utils.validaJSON(input_json))
throw new Error('JSON de entrada inválido!');
//procesamos
input_json = JSON.parse(input_json);
if(typeof(input_json.id) === "undefined")
throw new Error('JSON de entrada inválido (falta propiedad \"id\"!');
//obtenemos meta-data de mongo
var db = new Db("sdk_back", new Server('localhost',27017,{auto_reconnect:true, poolsize:1}),{safe:true});
db.open(function(err,db){
if(!err){
db.collection("metadatos",function(err,collection){
console.log('Entering collection meta-data');
if(!err){
console.log('Lets find one');
collection.findOne({"tipo":"proceso"},function(err,doc){
console.log('Results of findOne');
if(!err){
console.log(doc);
}
else{
throw new Error('Error al buscar meta_data!');
}
if(doc){
console.log('We have results');
}
else{
console.log('We dont have results');
}
});
}
else{
throw new Error('Error al buscar meta_data 1!');
}
});
}
else{
throw new Error('Error al conectarse a MongoDB!');
}
db.close();
});
};
Run Code Online (Sandbox Code Playgroud)
输出始终是:
raul@rmedina:~$ node pu_entrypoint.js
Entering collection meta-data
Lets find one
raul@rmedina:~$
Run Code Online (Sandbox Code Playgroud)
正如您所看到的,从未显示带有"findOne的结果"文本的日志,因此findOne方法实际上永远不会被执行,或类似的东西.
我的问题是,我做错了什么?我已经下载并重新创建了集合,删除了数据库,甚至我更改了Mongo的/ data/db目录,但无济于事.
我究竟做错了什么?
谢谢!
[已解决]更新: 问题出在db.close()上.节点beign异步,在到达集合的查找之前达到db的结束,所以当然找不到东西.只是在我上次回调中移动db.close,解决了这个问题.这是编辑过的代码:
db.open(function(err,db){
if(!err){
db.collection("metadatos",function(err,collection){
console.log('Entering collection meta-data');
if(!err){
console.log('Lets find one');
collection.findOne({"tipo":"proceso"},function(err,doc){
console.log('Results of findOne');
if(!err){
if(doc){
console.log('We have results');
console.log(doc._id);
}
else{
console.log('We dont have results');
}
/********** MOVED db.close() HERE ********************/
db.close();
}
else{
throw new Error('Error al buscar meta_data!');
}
});
}
else{
throw new Error('Error al buscar meta_data 1!');
}
});
}
else{
throw new Error('Error al conectarse a MongoDB!');
}
/********** REMOVED db.close() FROM HERE ********************/
});
Run Code Online (Sandbox Code Playgroud)
问题出在 db.close() 上。节点开始异步并在到达集合的查找之前到达数据库的关闭,因此当然找不到任何东西。将 db.close 移到最后一个回调内可以解决问题。这是编辑后的代码:
db.open(function(err,db){
if(!err){
db.collection("metadatos",function(err,collection){
console.log('Entering collection meta-data');
if(!err){
console.log('Lets find one');
collection.findOne({"tipo":"proceso"},function(err,doc){
console.log('Results of findOne');
if(!err){
if(doc){
console.log('We have results');
console.log(doc._id);
}
else{
console.log('We dont have results');
}
/********** MOVE db.close() HERE ********************/
db.close();
}
else{
throw new Error('Error al buscar meta_data!');
}
});
}
else{
throw new Error('Error al buscar meta_data 1!');
}
});
}
else{
throw new Error('Error al conectarse a MongoDB!');
}
/********** REMOVED db.close() FROM HERE ********************/
});
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
798 次 |
| 最近记录: |