js封装数据库操作

npm install mysql2

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

class Database {
  constructor(config) {
    this.config = config;
  }

  async connect() {
    this.connection = await mysql.createConnection(this.config);
  }

  async query(sql, params) {
    if (!this.connection) await this.connect();
    const [results] = await this.connection.execute(sql, params);
    return results;
  }

  async close() {
    if (this.connection) await this.connection.end();
  }
}

module.exports = Database;

const Database = require('./database');

const dbConfig = {
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'testdb'
};

async function main() {
  const db = new Database(dbConfig);

  try {
    const users = await db.query('SELECT * FROM users');
    console.log(users);
  } catch (error) {
    console.error('Database query error:', error);
  } finally {
    await db.close();
  }
}

main();