【问题标题】:mongodb async nodejs external file with functions - return: undefined带有函数的mongodb异步nodejs外部文件-返回:未定义
【发布时间】:2018-05-29 14:10:48
【问题描述】:

我有两个文件

server.js

(function () {
  var x = modules.dbFind('7');
  setTimeout(function() {
      console.log(x);
  }, 100);
})();

还有我的 modules.js

var dbFind = (id) => {
    console.log("dbFIND function in use!");
    MongoClient.connect(url, function(err, db) {
        if (err) throw err;
        db.collection("users").findOne({id:id}, function(err, result) {
            if (err) throw err;
            console.log(JSON.stringify(result));
            return(result);
            db.close();
        });
    });
};

我想将 RESULT 从模块传递到服务器文件并在那里读取它,但 x = undefined。 modules.js 中的结果 - console.log(result) 如我所愿显示。

我知道问题在于在结果到达之前读取 X - 但我已经尝试了几天,但我不知道如何解决它。

【问题讨论】:

  • 您应该使用异步等待来获取值 x。当你分配了x 值时,dbFind 没有完成。

标签: node.js mongodb promise


【解决方案1】:

如下更改。 如果你使用promise/then,你不需要等待setTimeout。

server.js

(async function () {
  modules.dbFind('7')
          .then((result)=> {
            console.log(result);
          });
})();

modules.js

function dbFind(id) {
    return new Promise((resolve, reject)=> {
        console.log("dbFIND function in use!");
        MongoClient.connect(url, function(err, db) {
            if (err) reject(err);
            db.collection("users").findOne({id:id}, function(err, result) {
                if (err) reject(err);
                console.log(JSON.stringify(result));
                resolve(result);
                db.close();
            });
        });    
    });
}

【讨论】:

  • 修正了我在 server.js 中的错字。再试一次。
  • 它按预期工作!非常感谢!现在我需要研究到底发生了什么;)
【解决方案2】:

由于这是标记为 Promise,您可以只使用 async/await 并且 MongoClient 包含 Promise 的事实。否则这是this question的副本:

const dbFind = async (id) => {
  console.log("dbFIND function in use!");
  const db = await MongoClient.connect(url)); // no callback = return promise
  try {
    let user = db.collection("users").findOne({id}); // shorthand {id:id}
    return user; 
  } finally {
    db.close();
  }
}

这会让你这样做:

(async () =>
  let found = await modules.dbFind('7');
  console.log(found);
})()

另请注意,Mongo 连接应该是持久的,并且每个应用打开一次,而不是每个请求打开一次。

【讨论】:

  • 有一些错误,但即使我纠正了它们,我也会在控制台中得到:UnhandledPromiseRejectionWarning: Unhandled Promise RejectionWarning: Unhandled Promise Rejection (rejection id: 1): TypeError: module.dbFind is not a function 这是什么意思?谷歌对这个错误没有太多帮助
  • 您不需要其他文件作为模块
猜你喜欢
  • 2020-01-31
  • 1970-01-01
  • 2016-05-07
  • 1970-01-01
  • 2018-09-22
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多