完全失去了承诺异步/等待

Question

我正在尝试在 NodeJS 11.6.x 上开发一个相对简单的测试。我不是真正的开发人员，但有时会尝试编写一些代码。

我的目标是创建一个 SQLite 数据库并在每次运行代码时重复一些步骤： 1. 删除一个表，如果它存在 2.创建表 3.插入N行 4.统计数据库中有多少行 5. 关闭数据库

我首先尝试了使用回调的基本方法，但无法找到实现步骤 3（插入 N 行）并寻找解决方案的方法，promise async/await 'pattern' 听起来是完成的方法一切。

但是，在重构代码之后，步骤 1（删除表）没有运行，我仍然无法执行步骤 3（插入 N 行）并且不知道发生了什么。我也尝试使用一个没有运气的承诺包。

有人可以对此进行查看并提供帮助，如果可能的话，请解释或提供一些建议？

提前致谢

已编辑：嗯，我不习惯在 SO 上发帖，也不知道在这里更新内容的“正确”方式。我相信我应该留下第一个代码作为参考，买我没有了。 现在我想我快到了。所有步骤都按顺序执行。只是我无法使其工作的第 3 步（插入 N 行）。或者它插入并停止不进入下一个'.then'，或者它只是插入 1 行，我无法想象正在发生的事情。 在代码中，我用“BUG 1:”和“BUG 2:”注释了两行。

1. 如果我俩都被评论了，我就会知道发生了什么，它只插入 1 行并且不继续承诺链
2. 如果我评论 BUG 1 并激活 BUG 2，它只插入一行并继续。我想我明白为什么
3. 如果我评论 BUG 2 并激活 BUG 1，它会插入所有行但不会再继续，我想我明白为什么
4. 如果我取消注释两者（我认为应该工作的方式。不要工作，并返回附加错误“分段错误”

下面的代码：

const sqlite3 = require('sqlite3')

let db = new sqlite3.Database('./test.db');

waitTime = 1

process.stdout.write('Starting...\n')
var test = new Promise((resolve, reject) => {
    process.stdout.write('Drop Table... ');
    db.run(`DROP TABLE IF EXISTS test`, (err) => {
        if (err) {
            process.stdout.write(`Dropping Error ${err.message}\n`)
            reject()
        } else {
            setTimeout(() => {
                process.stdout.write(`Dropped!\n`)
                resolve()
            }, waitTime)
        }
    })
})
test.then(() => {
    return new Promise((resolve, reject) => {
        process.stdout.write('Create Table... ')
        db.run(`CREATE TABLE IF NOT EXISTS test (data TEXT)`, (err) => {
            if (err) {
                process.stdout.write(`Creating Error ${err.message}\n`)
                reject()
            } else {
                setTimeout(() => {
                    process.stdout.write(`Created!\n`)
                    resolve()
                }, waitTime)
            }
        })
    })
}).then(() => {
    return new Promise((resolve, reject) => {
        process.stdout.write('Insert Line... ')
        lines = 10
        let loop = (async () => {
            for (let i = 0; i < lines; i++) {
                await new Promise(resolve =>
                    db.run(`INSERT INTO test (data) VALUES ('a')`, (err) => {
                        if (err) {
                            process.stdout.write(`Inserting Error ${err.message}\n`)
                            throw (err)
                        } else {
                            setTimeout(() => {
                                // process.stdout.write(`Line ${i} Inserted!\n`)
                                process.stdout.write(`, ${i+1}`)
                                resolve() // BUG 1: if this line is commented, comment it, it will insert only 1 line
                            }, waitTime)
                        }
                    })
                )
            }
        })()
        process.stdout.write(`, IDone\n`)
        resolve() // BUG 2: If this line is commented, the promise chain stops here
    })
}).then(() => {
    return new Promise((resolve, reject) => {
        process.stdout.write('Count Line(s)... ')
        db.all(`SELECT COUNT(*) AS totalLines FROM test`, [], (err, rows) => {
            if (err) {
                process.stdout.write(`Count Error ${err.message}\n`)
                reject()
            } else {
                setTimeout(() => {
                    process.stdout.write(` ${rows[0].totalLines} Count!\n`)
                    resolve()
                }, waitTime)
            }
        })
    })
}).then(() => {
    return new Promise((resolve, reject) => {
        process.stdout.write('Select Line(s)... ')
        db.all('SELECT data FROM test', [], (err, rows) => {
            if (err) {
                process.stdout.write(`Select Error ${err.message}\n`)
                reject()
            } else {
                rows.forEach((row) => {
                    console.log(row.data);
                })
                setTimeout(() => {
                    process.stdout.write(`${rows[0].totalLines} Select!\n`)
                    resolve()
                }, waitTime)
            }
        })
    })
}).then(() => {
    return new Promise((resolve, reject) => {
        process.stdout.write('Close DB... ')
        db.close((err) => {
            if (err) {
                process.stdout.write(`Closing Error ${err.message}\n`)
                reject()
            } else {
                setTimeout(() => {
                    process.stdout.write(`Closed!\n`)
                    resolve()
                }, waitTime)
            }
        })
    })
}).then(() => {
    console.log('Finished')
})

经过@CertainPerformance 的精彩解释（非常感谢），我能够让它运行起来。我相信现在是“正确”的做法。可能有一些更好的方法，但现在对我来说没问题，下面是最终代码：

const sqlite3 = require('sqlite3')

let db = new sqlite3.Database('./test.db');

lines = 10

process.stdout.write('Starting... ')
var test = new Promise((resolve, reject) => { process.stdout.write(`Promise Created...!\n`)
        resolve()
})
test.then(() => { process.stdout.write('Drop Table... ')
    return new Promise((resolve, reject) => {
        db.run(`DROP TABLE IF EXISTS test`, (err) => {
            if (err) {
                reject(err)
            } else { process.stdout.write(`Dropped!\n`)
                resolve() }
        })
    })
}).then(() => { process.stdout.write('Create Table... ')
    return new Promise((resolve, reject) => {
        db.run(`CREATE TABLE IF NOT EXISTS test (data TEXT)`, (err) => {
            if (err) {
                reject(err)
            } else {
                process.stdout.write(`Created!\n`)
                resolve() }
        })
    })
}).then(() => { process.stdout.write('Insert Line... ')
    let insertLoop = (async () => {
        for (let i = 0; i < lines; i++) {
            await new Promise(resolve =>
                db.run(`INSERT INTO test (data) VALUES ('a')`, (err) => {
                    if (err) {
                        reject(err)
                    } else { ( i == 0 ) ? process.stdout.write(`${i + 1}`) : process.stdout.write(`, ${i + 1}`)
                        resolve() }
                })
            )
        }
        process.stdout.write(`, Inserted!\n`)
    })()
    return insertLoop
}).then(() => { process.stdout.write('Count Line(s)... ')
    return new Promise((resolve, reject) => {
        db.all(`SELECT COUNT(*) AS totalLines FROM test`, [], (err, rows) => {
            if (err) {
                reject(err)
            } else { process.stdout.write(` ${rows[0].totalLines} Counted!\n`)
                resolve()
            }
        })
    })
}).then(() => { process.stdout.write('Close DB... ')
    return new Promise((resolve, reject) => {
        db.close((err) => {
            if (err) {
                reject(err)
            } else { process.stdout.write(`Closed!\n`)
                resolve()
            }
        })
    })
}).then(() => {
    console.log('Finished')
}).catch((err) => {
    process.stdout.write(`The process did not finish successfully: ${err}`)
})

Answer 1

有两个主要问题。首先，在第二个.then 中，您将loop 声明为立即调用的async 函数：这意味着loop 将解析为Promise。修剪后的代码如下所示：

}).then(() => {
    return new Promise((resolve, reject) => {
        let loop = (async () => {
            // do some asynchronus stuff
        })()
        resolve() // BUG 2
    })
}).then(() => {

单独声明Promise 不会导致当前线程等待它。上面的代码不能按预期工作，原因与此代码打印after 立即：

console.log('start');
const prom = new Promise((resolve) => {
  setTimeout(resolve, 500);
});
console.log('after');

您必须在Promise（或awaitPromise）上调用.then，以便在Promise 完成后安排其他操作。或者，如果您当前位于 .then 中，您可以返回 Promise，这意味着下一个 .then 将在返回的 Promise 解析后立即运行：

}).then(() => {
      let loop = (async () => {
        // do some asynchronus stuff
    })();
    return loop;
}).then(() => {
    // this block will run once `loop` resolves

请注意上面缺少 new Promise((resolve... 构造函数 - 在 .then 中，只是 return 下一个 Promise 通常是首选方法，因为这意味着更少的代码和 avoids an antipattern。

当前代码的另一个问题是无法捕获错误。例如，如果您的

db.run(`INSERT INTO test (data) VALUES ('a')`, (err) => {
  if (err) {
    process.stdout.write(`Inserting Error ${err.message}\n`)
    throw (err)
  // else call resolve()

抛出一个错误，此时 awaited 的 Promise 将永远无法解决，也不会拒绝 - 它将永远处于未决和未实现状态。您应该将reject 作为第二个参数传递给Promise 构造函数，并在出现错误时调用它（而不是throw），例如：

await new Promise((resolve, reject) => {
  db.run(`INSERT INTO test (data) VALUES ('a')`, (err) => {
    if (err) {
      process.stdout.write(`Inserting Error ${err.message}\n`)
      reject(err)
    } else {
      // ...

这样，awaited Promise 将被拒绝，这意味着整个 loop 将被拒绝，如果返回 loop，它将允许 .catch 捕获错误，因为示例：

var test = new Promise((resolve, reject) => {
  // ...
});
test.then(() => {
  return new Promise(...
    // ...
})
.then(() => {
  return new Promise(...
    // ..
})
.then(() => {
  return new Promise(...
    // ..
})
.catch((err) => {
  process.stdout.write(`The process did not finish successfully:`, err)
  // handle errors
});

请注意，除非每个 db. 函数调用都需要串行执行，否则最好一次发出所有请求，并在每个请求完成后解决 - 这可以显着减少脚本运行所需的时间.为每个异步调用创建一个 Promises 数组，然后在该数组上调用 Promise.all 以获得一个 Promise，当所有这些 Promises 完成时解析（或者，一旦 一个 就拒绝其中Promises 拒绝）。比如第二个.then：

}).then(() => {
  process.stdout.write('Insert Line... ')
  const proms = Array.from(
    { length: lines },
    (_, i) => new Promise((resolve, reject) => {
      db.run(`INSERT INTO test (data) VALUES ('a')`, (err) => {
        if (err) {
          process.stdout.write(`Inserting Error ${err.message}\n`)
          reject(err)
        } else {
          setTimeout(() => {
            // process.stdout.write(`Line ${i} Inserted!\n`)
            process.stdout.write(`, ${i+1}`)
            resolve()
          }, waitTime);
        }
      });
    })
  );
  return Promise.all(proms);
}).then(() => {

幸运的是，您的代码中没有其他东西可以处理异步循环。

您还可以考虑使用 Promisify 之类的实用函数，它将基于回调的函数转换为 Promises，而无需在每次异步调用时使用所有额外的 new Promise(... 样板。

Answer 2

promisifying db 可以进一步改进可重用功能，并充分利用async/await 而不是mixing it with then：

const sqlite3 = require('sqlite3')
let db = new sqlite3.Database('./test.db');

function runDbAsync(sql) {
    return new Promise((resolve, reject) => {
        db.run(sql, (err) => {
            if (err) reject(err);
            else resolve();
        });
    });
}
function getDbAsync(sql, val) {
    return new Promise((resolve, reject) => {
        db.all(`SELECT COUNT(*) AS totalLines FROM test`, [], (err, rows) => {
            if (err) reject(err);
            else resolve(rows);
        });
    });
}
function closeDbAsync() {
    return new Promise((resolve, reject) => {
        db.close((err) => {
            if (err) reject(err);
            else resolve();
        });
    });
}

function write(text) {
    process.stdout.write(text);
}
function writeLn(text) {
    write(text + "\n");
}

async function main() {
    const lines = 10
    writeLn('Starting... ')
    write('Drop Table... ');
    await runDbAsync(`DROP TABLE IF EXISTS test`);
    writeLn(`Dropped!`);
    write('Create Table... ');
    await runDbAsync(`CREATE TABLE IF NOT EXISTS test (data TEXT)`);
    writeLn(`Created!`);
    write('Insert Line... ');
    for (let i = 0; i < lines; i++) {
        await runDbAsync(`INSERT INTO test (data) VALUES ('a')`);
        write( i == 0 `${i + 1}` : `, ${i + 1}`);
    }
    writeLn(`, Inserted!`);
    write('Count Line(s)... ')
    const rows = getDbAsync(`SELECT COUNT(*) AS totalLines FROM test`, []);
    writeLn(` ${rows[0].totalLines} Counted!`)
    write('Close DB... ');
    await closeDbAsync();
    writeLn(`Closed!`);
}

main().then(() => {
    console.log('Finished')
}, err => {
    writeLn(`The process did not finish successfully: ${err}`)
});