在Node.js中使用MySQL和async/await运行多个查询可以通过以下步骤实现:
npm install mysql2
const mysql = require('mysql2');
const pool = mysql.createPool({
host: 'your_host',
user: 'your_user',
password: 'your_password',
database: 'your_database',
waitForConnections: true,
connectionLimit: 10,
queueLimit: 0
});
const promisePool = pool.promise();
请注意,上述示例中的your_host
、your_user
、your_password
和your_database
应替换为实际的数据库连接信息。
async function runMultipleQueries() {
try {
const [result1, fields1] = await promisePool.query('SELECT * FROM table1');
console.log('Query 1 Result:', result1);
const [result2, fields2] = await promisePool.query('SELECT * FROM table2');
console.log('Query 2 Result:', result2);
// 在这里可以继续添加更多的查询
return [result1, result2]; // 返回查询结果
} catch (error) {
console.error('Error executing queries:', error);
throw error;
}
}
// 调用异步函数运行多个查询
runMultipleQueries()
.then(results => {
console.log('All queries executed successfully.');
console.log('Results:', results);
})
.catch(error => {
console.error('Error running queries:', error);
});
上述代码中的table1
和table2
应替换为实际的表名。
这样,您就可以在Node.js中使用async/await和MySQL运行多个查询了。您可以根据需要添加更多查询,并在最后的返回语句中返回查询结果。记得适当处理错误,以便在出现问题时进行适当的处理。
领取专属 10元无门槛券
手把手带您无忧上云