node.js mysql2连接池执行问题

Question

我还是nodejs的新手，有些东西不能理解。我有带有代码的db.js文件：

function connection() {
  try {
    const mysql = require('mysql2');

    const pool = mysql.createPool({
      host: 'localhost',
      user: 'user',
      password: 'password',
      database: 'database',
      waitForConnections: true,
      connectionLimit: 15,
      queueLimit: 0,
      multipleStatements: true
    });

    const promisePool = pool.promise();

    return promisePool;
  } catch (error) {
    return console.log(`Could not connect - ${error}`);
  }
}

const pool = connection();

module.exports = {
  connection: async () => pool.getConnection(),
  execute: (...params) => pool.execute(...params)
};

当我尝试这样插入行时：

! async function() {
  var sql = {
    title: 'title',
    url: 'url',
    content: 'content'
  };
  const [query] = await db.execute("INSERT INTO content SET ?",[sql]);
}();

它会失败，并出现sql语法错误。为什么它失败了，它工作得很好，只是使用了稍微不同的db.js。我在这里寻找简短而正确的解决方案。

Answer 1

要获得正确的连接,请将以下代码添加到池所在的模块中：

var getConnection = function(callback) {
    pool.getConnection(function(err, connection) {
        callback(err, connection);
    });
};

module.exports = getConnection;

当您使用完连接时，不要忘记添加end连接：

connection.release();