使用 OOP 原理的带有 MySQL 包的 Node.js 类

Question

我正在学习如何在 Node 中使用 MySQL，这很痛苦。

npm 包是“mysql”。 我正在制作一个遵循 OOP 原则的应用程序，并且我正在尝试制作一个独立的类来处理我的数据库请求。我遇到的问题是我无法断开与数据库的连接，因为 connection.end() 或 connection.drop() 等方法即使将它们包装在 .then 中也无法正常工作

它的外观如下：

    class DB {
    constructor(dbname, dbpassword) {
        this.dbname = dbname;
        this.dbpassword = dbpassword;
    }

    connection() {
        return new Promise((resolve, reject) => {
            resolve(mysql.createConnection({
                host: "localhost",
                user: "root",
                password: this.dbpassword,
                database: this.dbname,
            }))
        })
    }

    connect() {
        this.connection().then(res => {
            res.connect(function (err) {
                if (err) throw err;
                console.log(res.state, "connected")
            })
        })
    }

    dropConnection() {
        this.connection().then(res => {
            res.end(); console.log(res.state, 'connection dropped');
        })
    }
}

由于某种原因，我无法按照我的意愿断开连接。方法res.end() 不起作用。 我只想知道是否： a）我通过尝试将所有内容放在一个类中并按方法调用我的操作方法来做正确的事情（我正在尝试遵循 OOP 原则，因为我可能有多个数据库将执行几乎相似的任务）。 b) 我的代码有问题，我看不到。

Answer 1

class DB {
  constructor(dbname, dbpassword) {
    this.establishedConnection = null;
    this.dbname = dbname;
    this.dbpassword = dbpassword;
  }

  connection() {
    return new Promise((resolve, reject) => {
      resolve(mysql.createConnection({
        host: "localhost",
        user: "root",
        password: this.dbpassword,
        database: this.dbname,
      }))
    })
  }

  connect() {
    if (!this.establishedConnection) {
      this.establishedConnection = this.connection().then(res => {
        res.connect(function(err) {
          if (err) {
            this.dropConnection();
            throw err;
          }
          
          console.log(res.state, "connected")
        })
      });
    }
  }

  dropConnection() {
    if (this.establishedConnection) {
      this.establishedConnection.then(res => {
        res.end();
        console.log(res.state, 'connection dropped');
      });
      
      this.establishedConnection = null;
    }
  }
}

• constructor() 有一个新的类属性 establishedConnection，它将是返回连接的承诺
• 当connect()被调用时，如果没有建立连接，它会建立一个新的
• 如果连接有问题，会调用dropConnection()方法
• 在调用dropConnection()方法时，如果有已建立的连接，它会尝试执行关闭，然后将其清空