NodeJS nedb 函数没有等待

编程问答 2022-05-17

问题描述

函数 checkExists 执行时间过长。尝试使用 await async 函数但没有效果。 var exists = await checkExists(data.email); 返回 undefined 因为没有等待 checkExists。

我有我的 index.js：

const express = require('express');
const app = express();

require('./private/signUpAPI')(app);

app.listen(80,() => console.log('listening on 80'));
app.use(express.static('public'));
app.use(express.json({limit: '1mb'}));

还有我的 signUpAPI.js：

const DataStore = require('nedb');
const express = require('express');

const database = new DataStore('private/database.db');
database.loadDatabase();

module.exports = function api(app){
    app.use(express.json({limit: '1mb'}));
    app.post('/signUpAPI',async (request,response) => {
        console.log("Sign Up Request received!");
        const data = request.body;

        var exists = await checkExists(data.email);

        console.log(exists)
        console.log(data);
        console.log("Added to DB");
        console.log('-------------------------' + '\n');
        database.insert(data);
        const testData = {"status": "success"};
        response.send(testData);
    });    
}

async function checkExists(email){
    var exists = false;

    database.find({"email": email},async function(err,docs){
        if (docs.length > 0){exists = true;}
        console.log(docs.length);
        return exists;
    });
}

这是运行 index.js 并调用 fetch('/signUpAPI') 时的节点输出：

Sign Up Request received!
undefined
{
  email: 'a',username: 'a',hashPass: 'da180265625ebeaf62f4ee1813bdc28faeaf79f0b2b329290758a1c095111ae8',salt: 'g8VkTBV$+Bh35K9ns7Zt*9^CH#M=VELSzKUX=H3^+5kpFV=bEbVfXFtF*GGYHOa#'
}
Added to DB
-------------------------

37

我目前在数据库中有 37 个条目具有相同的数据，因此 console.log(docs.length) 返回 37。

但是这是最后执行的，并且在它应该出现在顶部时出现在控制台的底部。

解决方法

使用https://www.npmjs.com/package/nedb-promise

因此您可以使用 await 进行数据库查询，并且可以像这样更改代码 -

async function checkExists(email) {
    const record = await database.findOne({ email });
    console.log(record);
    if (record) return true;
    return false;
}
,

你想要等待的函数应该返回一个 promise 以等待响应。 如果操作结果成功，您要么解决承诺，要么因错误而拒绝。

流程应该是这样的；

async function func1()
{
    try
    {
        var tmp = await func2();
        console.log(tmp);
    }
    catch(err)
    {
        console.log(err);
    } 
}

async funcion func2()
{
    return new Promise(async function (resolve,reject)
    {
        if(true)
        {
            resolve("success");
        }
        else
        {
            reject("error");
        }
    });
}
databasedatabasedatabaseexpressexpressexpressjavascriptnedb