实现异步/等待node.js和mysql

const mysql = require('mysql');

// 创建MySQL连接池
const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'database',
});

// 封装查询函数
function query(sql, values) {
  return new Promise((resolve, reject) => {
    pool.getConnection((err, connection) => {
      if (err) {
        reject(err);
      } else {
        connection.query(sql, values, (err, results) => {
          connection.release();
          if (err) {
            reject(err);
          } else {
            resolve(results);
          }
        });
      }
    });
  });
}

// 使用async/await调用查询函数
async function getUser(id) {
  try {
    const sql = 'SELECT * FROM users WHERE id = ?';
    const values = [id];
    const results = await query(sql, values);
    return results[0];
  } catch (error) {
    console.error(error);
    throw error;
  }
}

// 调用异步函数
getUser(1)
  .then(user => {
    console.log(user);
  })
  .catch(error => {
    console.error(error);
  });