NodeJS nedb 函数不等待

Question

函数 checkExists 执行时间过长。尝试使用 await async 函数但没有效果。 var exists = await checkExists(data.email); 正在返回未定义，因为没有等待 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。

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

Answer 1

使用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;
}

Answer 2

您要等待的函数应该return 一个 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");
        }
    });
}

NodeJS nedb 函数不等待

NodeJS nedb function not awaiting

javascript

database

node.js

express

nedb