nodejs mysql操作封装

const mysql = require('mysql');

class MySQL {
  constructor(config) {
    this.connection = mysql.createConnection(config);
  }

  connect() {
    return new Promise((resolve, reject) => {
      this.connection.connect((err) => {
        if (err) {
          reject(err);
        } else {
          resolve();
        }
      });
    });
  }

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

  close() {
    return new Promise((resolve, reject) => {
      this.connection.end((err) => {
        if (err) {
          reject(err);
        } else {
          resolve();
        }
      });
    });
  }
}

module.exports = MySQL;

const MySQL = require('./MySQL');

async function main() {
  const config = {
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'testdb'
  };

  const db = new MySQL(config);

  try {
    await db.connect();
    const results = await db.query('SELECT * FROM users');
    console.log(results);
  } catch (err) {
    console.error(err);
  } finally {
    await db.close();
  }
}

main();