使用 Async/Await for MySQL 同步 Node.js 结果
在 Node.js 中,处理异步操作可能具有挑战性,尤其是当您在继续之前需要同步结果。使用 async/await 关键字是实现此目的的便捷方法。
在提供的代码片段中,您的目标是从四个单独的查询中检索结果并将它们附加到连接的字符串中。然而,传统的基于回调的方法提出了一个挑战,因为变量保持空白,因为查询下面的代码首先执行。
为了克服这个问题,Node.js 版本 8 引入了本机 util.promisify() 函数。此函数允许您将基于回调的函数转换为基于承诺的函数。通过利用 util.promisify() 和 Node mysql 模块,您可以编写以下代码:
// Import required modules const mysql = require('mysql'); const util = require('util'); // Create a MySQL connection const conn = mysql.createConnection({/* connection parameters */}); // Promisify the query method using util.promisify(). // Remember to use .bind() to maintain the correct this context. const query = util.promisify(conn.query).bind(conn); // Execute queries concurrently using async/await const main = async () => { try { const rows1 = await query(/* query string */); const rows2 = await query(/* query string */); const rows3 = await query(/* query string */); const rows4 = await query(/* query string */); // Append the results to a single string let appendedText = `${rows1} ${rows2} ${rows3} ${rows4}`; // Use the appendedText as needed } catch (err) { // Handle errors } finally { // Close the connection conn.end(); } }; // Start the process main();
此代码将并发执行查询并等待结果可用,然后再继续。每个查询中的行将被追加到追加的文本字符串中,然后您可以使用该字符串进行进一步处理。
以上是Async/Await 如何同步 Node.js MySQL 查询结果?的详细内容。更多信息请关注PHP中文网其他相关文章!