我是NodeJS的新手(来自PHP背景)。与PHP的阻塞性质相比,我对NodeJS的异步性质具有基本的了解。我创建了一些连接到mysql的应用程序节点,并使它们正常工作。
我目前对在Node中执行查询的最佳方式的理解是:
创建一个连接池
当您需要执行查询时:
池中的getConnection()
执行查询
.release()连接
我处于需要迭代大量项目并将每个项目插入数据库的情况。进行上述操作无效。我的想法是,由于每个查询都是并行执行的,因此列表中的下一项正在尝试获取连接,但是由于先前的查询可能尚未完成,因此没有可用的连接。没有引发任何错误,似乎没有放入任何项目。通过日志记录,我发现它永远不会到达运行pool.getConnection()回调的地步。
所以我想我可以修改连接流程:
创建一个连接池
当您需要执行许多查询时:
池中的getConnection()
遍历需要查询的项目
执行查询
.release()连接
问题是,我怎么知道什么时候可以安全地释放连接?我不能只在我的.query()回调中执行此操作,因为它之后可能会有更多查询。但是我也不能在查询回调中这样做,因为我知道我需要等待所有查询完成。我是否要负责创建自己的逻辑,以弄清楚何时完成所有查询(以及所有可能的将来查询,即使尚未开始)?还是这只是未完成的事情?
在PHP中,这是很简单的,因为它具有阻塞性。我选择为此应用程序使用NodeJS,因为它有时有时需要异步。但这在我的应用不需要它的地方(在某些情况下不应该使用它)迫使我产生异步性。
我不愿意发布我的代码,因为它有点复杂,所以我不想分散这个特定主题的注意力。
最佳答案
您的连接流程很好。如果仅执行1个查询,则实际上不需要执行任何步骤,您可以直接在池中调用.query()
。 (其余在引擎盖下)。
大多数情况下,您需要在1个事务中执行多个查询,但是我要添加事务支持:
创建一个连接池
当您需要执行许多查询时:
池中的getConnection()
开始交易
遍历需要查询的项目
执行查询
如果有任何失败,请停止并回滚
如果一切成功,请提交
.release()连接
如果所有查询都已“完成”,则您知道何时释放连接。您怎么知道它完成了?有不止一种方法。我建议您使用Promise API,因此它可能如下所示:
async function doStuff(items) {
try {
const connection = await pool.getConnection();
await connection.beginTransaction();
for(const item of items) {
await connection.query('....');
}
await connection.commit();
} catch (e) {
await connection.rollback();
throw e;
} finally {
await connection.release();
}
}
这种模式有一些优点:
它将正确报告错误
成功和失败时,它将释放连接。
它要么完全失败,要么完全成功。在这里不要半途而废。
如果您不关心交易,则可以简化以下内容:
async function doStuff(items) {
try {
const connection = await pool.getConnection();
for(const item of items) {
await connection.query('....');
}
} finally {
await connection.release();
}
}
这样做的问题是,您可以获得部分成功,这通常是不希望的,尤其是对于API。但是,如果对您足够好,那就足够了。
并且,如果您愿意不进行交易,则理论上可以完全跳过
getConnection
步骤:async function doStuff(items) {
for(const item of items) {
await pool.query('....');
}
}
这意味着所有查询都可能在不同的连接上执行。这可能会给您带来较差的性能,但会使代码更简单。
如何实现承诺?
好吧,这有点争议。为此,您可能需要切换mysql软件包。有一个
mysql2
包具有一个非常好的mysql2/promise
导入(实际上与更流行的mysql
包共享代码)。超级建议切换到此。如果我不想换包裹怎么办?
好吧,这的回调版本要痛苦得多。在这种情况下,我建议您仍然使用Promise,但将您的回调转换为Promise模式,也许使用“ promisify”。
如果您真的不希望在任何地方做出承诺,则基本上必须将我的示例转换为基于回调的示例,这看起来会更加痛苦。