javascript - Node MySQL—— promise 永无止境

Question

我在 Node 中的 promise 方面遇到了问题，特别是在下面的代码中，我编写这些代码是为了执行 MySQL 查询，以便我的所有其他 100 多个函数可以共享它，而不是内联编写它。来自 PHP 开发，了解 Promise 等的好处是一个学习曲线，现在我遇到了一些问题。以下函数将 query 作为参数，执行它并返回响应:

var mysql = require('mysql');
const myDBConnection = mysql.createPool({
    host: '127.0.0.1',
    user: "username",
    password: "password",
    database: "dbName",
    connectionLimit: 101,
});


class DBQueryRunner {
    query(query) {
        return new Promise((resolve, reject) => {
            myDBConnection.getConnection((err, connection) => {


                const myQuery = mysql.format(query.string, query.params);
                connection.query(myQuery, function(err, data) {
                    return (err ? reject(err) : resolve(data));
                    connection.release();
                });

            });

        });


    }
}

代码运行良好，并且值返回给调用者，但无论我尝试什么，它似乎都不会终止，而且我担心它会占用 CPU 资源。

这是一个示例函数，您可以在命令行中运行它与上面的函数一起使用，以查看发生了什么。

function test() {
let DBQueryRunner = require("./theAboveCode.js");
const myDB = new DBQueryRunner();

let query = {
    string: `SELECT 1+1 AS Output`,
    params: []
};


return myDB.query(query).then(rows => {
console.log(rows)
    return (rows);
});

}

问题:
- promise 是否有必要终止？
- 我的代码有错误吗？
- 有没有更好的方法来制作像我这样的可重用的数据库执行函数？

更新 - 我还尝试了使用 Bluebird 来“ promise ”mysql 库的替代方法。该函数仍然永远不会结束，我必须在终端中按 CTRL+C 才能退出它。

let mysql = require('mysql');
let Promise = require('bluebird');

Promise.promisifyAll(require("mysql/lib/Connection").prototype);
Promise.promisifyAll(require("mysql/lib/Pool").prototype);


let myDBConnection = mysql.createPool({
  host: '127.0.0.1',
  user: "username",
  password: "password",
  myDBConnection: "dbName",
  connectionLimit: 101,
});




class DBQueryRunner {
  query(query) {
    let pool = Promise.promisifyAll(mysql);

        return myDBConnection.getConnectionAsync()
            .then(function (conn) {
                 myDBConnection = Promise.promisifyAll(conn);
                 return myDBConnection.queryAsync(query.string, query.params);
            })
            .then(function (results) {
                 if (results.length < 1) {
                     return "No results were found";
                 } else {
                     return results;
                    //  resolve(results);  //This method doesn't work with resolve/reject so I already am confused by it.
                 }
            })
            .catch(function (err) {
                 console.log(err);
                 throw err;
            })
            .finally(function () {
                 if (myDBConnection) {
                     myDBConnection.release();
                     console.log("Released the connection")
                 }
            });
    }

}

Answer 1

我找到了解决我的问题的解决方案。

使用connection.destroy()允许函数正确结束，因此它们不再导致“挂起”。

我在原始帖子中发布的两组代码确实有效，因此将来可能会对其他人有所帮助。