nodejs创建mysql数据库

// 引入MySQL模块
const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: '数据库主机地址',
  user: '数据库用户名',
  password: '数据库密码',
  database: '数据库名'
});

// 连接数据库
connection.connect((err) => {
  if (err) {
    console.error('数据库连接失败：', err);
    return;
  }
  console.log('数据库连接成功');
});

// 创建数据库表
const createTableSql = `
  CREATE TABLE IF NOT EXISTS users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(255) NOT NULL,
    age INT NOT NULL
  )
`;
connection.query(createTableSql, (err, results) => {
  if (err) {
    console.error('创建表失败：', err);
    return;
  }
  console.log('表创建成功');
});

// 插入数据
const insertDataSql = `
  INSERT INTO users (name, age) VALUES ('张三', 20)
`;
connection.query(insertDataSql, (err, results) => {
  if (err) {
    console.error('插入数据失败：', err);
    return;
  }
  console.log('数据插入成功');
});

// 查询数据
const queryDataSql = `
  SELECT * FROM users
`;
connection.query(queryDataSql, (err, results) => {
  if (err) {
    console.error('查询数据失败：', err);
    return;
  }
  console.log('查询结果：', results);
});

// 关闭数据库连接
connection.end((err) => {
  if (err) {
    console.error('关闭数据库连接失败：', err);
    return;
  }
  console.log('数据库连接已关闭');
});