nodejs查询mysql

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

// 连接到数据库
connection.connect((err) => {
  if (err) throw err;
  console.log('Connected to the MySQL server.');

  // 执行查询
  const sql = 'SELECT * FROM users WHERE id = ?';
  connection.query(sql, [1], (err, results) => {
    if (err) throw err;
    console.log('User:', results[0]);

    // 关闭连接
    connection.end();
  });
});

const query = (sql, values) => {
  return new Promise((resolve, reject) => {
    connection.query(sql, values, (err, results) => {
      if (err) return reject(err);
      resolve(results);
    });
  });
};

(async () => {
  try {
    const results = await query('SELECT * FROM users WHERE id = ?', [1]);
    console.log('User:', results[0]);
  } catch (err) {
    console.error('Error:', err);
  } finally {
    connection.end();
  }
})();