Promise-MySQL 无法释放连接回池

Question

我是 Node.js 开发的新手，我正在开发一个需要我从 mysql 数据库中提取用户的应用程序。我正在使用promise-mysql 库来查询 mysql 数据库。我正在尝试使用这样的连接池：

var pool = mysql.createPool({
  host:     hgh.host,
  user:     hgh.user,
  password: hgh.pw,
  database: hgh.name,
  connectionLimit: 10
});

作为我模块中的全局变量。

然后我有上面的函数从池中返回一个连接。

function connect() {
  return pool.getConnection().then(function(connection) {
    return connection
  }).catch(function(error) {
    console.log("Connect failed");
    throw ErrorModel.generateErrorObject(error, 500);
  });
}

下面是我用来查询数据库的函数：

function getUser(username) {
  var sql_query = `SELECT * FROM userstable WHERE userName = ` + `'` + username + `'`;
  return connect().then(function(conn) {
    return conn.query(sql_query).then(function(rows) {
      console.log("HGH getUser Then");
      console.log(pool);
      conn.release();
      return rows;
    });
  }).catch(function(error) {
      console.log("HGH getUser Catch");
      console.log(error);
      throw ErrorModel.generateErrorObject(error, 500);
  });
}

我遇到了这个问题：

conn.release 在尝试将我当前的连接释放到池中时不是一个函数。我的逻辑在这里错了吗？我的目标是拥有一个包含一堆连接（最多一定数量）的池，如果用户需要查询，getConnection() 函数只是从池中获取一个免费连接，或者创建一个。问题是我不能以free 的形式将其释放回池中。每次我使用conn.end() 而不是release 发出请求时，连接仍保留在池的_allConnections 数组中解决它，_freeConnections 数组中绝对没有任何连接。

有谁知道我怎样才能让连接再次免费？

Answer 1

查看模块的代码，我找到了从池中释放连接的函数：

pool.prototype.releaseConnection = function releaseConnection(connection) {
    //Use the underlying connection from the mysql-module here:
    return this.pool.releaseConnection(connection.connection);
};

因此，如果所有这些函数都存在于同一个文件中，您可以在 getUser 函数中执行以下操作： 替换

conn.release();

与

pool.releaseConnection(conn);

Answer 2

查看代码，promise-mysql 包装了原始连接对象，它没有公开release 方法。但是，原始文件被公开为一个名为 connection 的属性，所以这很有效：

conn.connection.release();

一些随意的想法：

• 你可能应该escape你的查询输入：

  var sql_query = `SELECT * FROM userstable WHERE userName = ${ pool.escape(username) }`;
  

• 发生错误时您的代码不会释放连接（因为不会调用.then() 回调中的代码）；最好使用.finally() 进行发布，因为已解决的和 被拒绝的案例都会调用它：

  function connect() {
    var conn = null;
    return pool.getConnection().then(function(connection) {
      conn = connection;
      return connection;
    }).catch(function(error) {
      console.log("Connect failed", error);
    }).finally(function() {
      if (conn) {
        conn.connection.release();
      }
    });
  }