Mysql последовательное выполнение nodejs - PullRequest
Новая
       29

Mysql последовательное выполнение nodejs

0 голосов
/ 26 февраля 2019

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;

employeeController.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"] всегда оказываетсяnull в то время как он должен иметь коллекцию подкатегорий, так как он всегда доступен.Я попытался реализовать await/async, поместив await перед вторым pool.query и сделав первую pool.query функцию замыкания асинхронной.

Как с этим обращаться?

1 Ответ

0 голосов
/ 26 февраля 2019

Функция, переданная в качестве параметра pool.query, является обратным вызовом.Это означает, что вы не можете знать, когда это будет выполнено.

Вы можете использовать async / await, чтобы блокировать вызов, пока pool.query не даст вам результат.

Возможно, вам придется использовать util.promisify на pool.query, чтобы заставить его вернуть Обещание. 

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.

...