nodejs调用mysql数据库

const mysql = require('mysql2');

// 创建数据库连接
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 your_table';
  connection.query(sql, (err, results, fields) => {
    if (err) throw err;
    console.log('Query results:', results);

    // 关闭连接
    connection.end((err) => {
      if (err) throw err;
      console.log('Connection closed.');
    });
  });
});

const mysql = require('mysql2/promise');

async function queryDatabase() {
  const connection = await mysql.createConnection({
    host: 'localhost',
    user: 'your_username',
    password: 'your_password',
    database: 'your_database'
  });

  try {
    const [results] = await connection.execute('SELECT * FROM your_table');
    console.log('Query results:', results);
  } catch (err) {
    console.error('Error executing query:', err);
  } finally {
    await connection.end();
  }
}

queryDatabase();