0

mysqldb.js

const mysqlDatabasePool = mysql.createPool({
    connectionLimit: 50,
    host: process.env.MYSQL_HOST,
    user: process.env.MYSQL_USERNAME,
    password: process.env.MYSQL_PASSWORD,
    port: process.env.MYSQL_PORT,
    database: process.env.MYSQL_DATABASE
});

mysqlDatabasePool.getConnection({
  //Basic sanity checking code here
});

mysqlDatabasePool.query = util.promisify(mysqlDatabasePool.query);

module.exports = mysqlDatabasePool;

员工控制器.js

var pool = require("mysqldb");

pool.query("SELECT CategoryID, CategoryIcon FROM Categories WHERE CategoryName = ?", [categoryName], function(error, results, fields) {
    if(results !== null && results.length > 0) {

        for(var i = 0; i < results.length; i++) {
             outputData[i] = results[i];

             var subCategories = pool.query("SELECT SubcategoryID FROM Subcategories WHERE CategoryID = ?", [results[i].CategoryID], function(error, results, fields) {
                 return results;
             });

             if(subCategories.length > 0) 
                  outputData[i]["Subcategories"] = subCategories;
             else
                  outputData[i]["Subcategories"] = null;
        }
    }
});

outputData[i]["Subcategories"]always的内容结果是nullwhile 它应该有子类别的集合，因为它总是可用的。我尝试await/async通过将 await 放在第二个之前pool.query并使第一个pool.query闭包函数异步来实现。

这应该如何处理？

4

1 回答 1

0

作为参数传递给的函数pool.query是回调。这意味着你无法知道它何时会被执行。

你可以使用 async/await 来阻止你的调用，直到 pool.query 给你一个结果。

你可能需要使用util.promisifyonpool.query让它返回一个 Promise。

try {
   const results = await pool.query("SELECT CategoryID, CategoryIcon FROM Categories WHERE CategoryName = ?", [categoryName]);
   if(results !== null && results.length > 0) {

        for(var i = 0; i < results.length; i++) {
             outputData[i] = results[i];

             const subCategories = await pool.query("SELECT SubcategoryID FROM Subcategories WHERE CategoryID = ?", [results[i].CategoryID]);

             if(subCategories.length > 0) 
                  outputData[i]["Subcategories"] = subCategories;
             else
                  outputData[i]["Subcategories"] = null;
        }
    }
} catch(error) {
  console.log(error)
  // Deal with the error
}

以上是如何使用async/await语法的示例。记住要使用关键字await，周围的函数必须标记为async。

于 2019-02-26T14:59:48.450 回答