如何在节点 js 中调用同步 mongo 查询

Question

我要 mongodb 集合。 首先我会调用 coll1 并获取 ids。然后我想调用 coll2 并按 ids 和其他一些字段进行搜索。

当我调用函数时，它正在返回未定义。

我怎么能等到我没有从函数中得到结果。

coll1 文档示例： {

"_id" : ObjectId(""), “container_id”：“56867887fdb391ff09d15e9”， “项目状态”：[ { “用户 ID”：1， “用户名”：“x”， “状态”：“1” }, { “用户 ID”：2， “用户名”：“y”， “状态”：“3” } ], “名称”：“成员测试” } 在此输入代码

function listMyWorkitems(user_id,callback) {
    var user_id=1;
    var workItemList = new Array();
    db.collection('containers').find({'start_date':{"$lt":new Date(2017,02,11)}}).toArray(function(err,docs){
    console.log("doc length");
    console.log(docs.length);
    for (var i = 0; i < docs.length; i++) {
            db.collection('work_items').find({"$and":[{'container_id':docs[i]._id.toString()},{'item_state':{"$elemMatch":{'user_id':user_id,'is_active':1,'state':{"$in":["1","2","3"]}}}}]}).toArray(function(err,workDocs){
            //console.log(workDocs);
            for (var i = 0; i < workDocs.length; i++) {
                    for (var j = 0; j < workDocs[i].item_state.length; j++) {
                        var doc=workDocs[i].item_state[j]
                         workItemList.push(workDocs[i].name)
                    }
                }
            });
        }
          callback(workItemList);
});
}

listMyWorkitems(user_id,funtion(err,workItemList) {
console.log(workItemList)
});

我了解异步自动概念，但它仍然返回空列表 这是我到目前为止尝试过的代码..我为集合 1 完成了，但一旦解决了，我也可以查询集合 2..

var async = require('async');
var mongojs = require("mongojs");
var db = mongojs("localhost/mc_dev");
    async.auto({
           coll1task: function(callback) {
            var idlist =[];
            console.log("ids fetch from collection 1");
            db.collection('containers').find({'start_date':{"$lt":new Date(2017,02,11)}}).toArray(function(err,docs){
             docs.forEach(function(doc){
             console.log(doc._id);
             idlist.push(doc._id);
            });});
            callback(null,idlist);
           },

       finalcontrol: [
          'coll1task',
          function(results,callback) {
            console.log(results.coll1task);
          }
       ],
},
   function(error, results) {
        console.log('error = ', error)
        console.log('results = ', results)         
    })

Answer 1

在 node.js 中异步执行操作的最佳方法是使用 ASYNC 或 PROMISE 等模块。

您可以访问async 并访问该库提供的所有模块。

异步库提供的主要模块有

1. async.series=> 这是你可以在你的情况下使用的。 2.async.parallel
2. async.auto => 我建议你使用它，因为它可以让你异步和同步地执行操作

此外，您还可以使用 PROMISES，因为现在它们是 ECMA SCRIPT 6 的一部分，您还可以使用各种模块来完成这项工作。