Async-Await 仍在异步运行

Question

等待 Select * 函数，然后在打印完成后执行操作。 但是它在打印输出之后匆匆忙忙地完成了所有事情。所以它是这样的：调用 Await 函数，然后在调用 resolve 之前调用 await 之后的其他东西，然后打印出 await 函数。

老实说，我已经尝试了很多。制作匿名异步块以在函数内运行等待。我之前没有对函数使用 Promise，但后来添加它们认为我需要解决它们。但没有骰子。

var sqlite3 = require('sqlite3').verbose();

var db = new sqlite3.Database(__dirname+'/requestLog.db');

test();
async function test(){
    await selectAll();

    console.log('test')
}

function selectAll(){
    return new Promise((resolve, reject) => {
        try {
            db.serialize(function() {   
                db.each("SELECT rowid AS id,* FROM requests", function(err, row) {
                    console.log(row);  
                });
                resolve()
            });
        } catch (error) {
            console.log(`Error With Select ALL(): \r\n ${error}`)
            reject();
        }
    });
 }

我确定只是我错过了一些荒谬的事情。 现在我觉得我正在进入一个兔子洞并转圈圈 请不要评判我哈哈

我想将数据库中的所有内容打印到控制台。然后在我打印后执行（“测试”）或任何操作。

但一切都在等待中运行

Answer 1

问题是resolve() 在db.each() 之后被调用，放置解析的正确位置是完整的回调：Database#each(sql, [param, ...], [callback], [complete])，来自文档。 https://github.com/mapbox/node-sqlite3/wiki/API#databaseeachsql-param--callback-complete

function selectAll() {
    return new Promise((resolve, reject) => {
        try {
            db.serialize(function () {
                db.each("SELECT rowid AS id,* FROM requests", function (err, row) {
                    console.log(row);
                },
                    (err, rowCount) => {
                        if (err) reject(err);
                        resolve(rowCount);
                    }
                );
            });
        } catch (error) {
            console.log(`Error With Select ALL(): \r\n ${error}`)
            reject();
        }
    });
}

Answer 2

试试这个：

async function selectAll() {
    await  db.each("SELECT rowid AS id,* FROM requests", function (err, row) {
        console.log(row);
    });
}