在node.js应用程序中,我使用mysql库进行数据库连接。
当我启动节点服务器时,我可以很好地查询数据库-没有问题
当我在5分钟后查询数据库时,服务器返回以下错误:
{"code":"PROTOCOL_ENQUEUE_AFTER_FATAL_ERROR","fatal":false}
如果我重新启动我的node.js服务器,我可以再次查询没有问题…
这是我的密码
const mysql = require('mysql');
let connection = mysql.createPool({
host: config.mysql.host,
user: config.mysql.user,
password: config.mysql.password,
database: config.mysql.database
});
router.post('/subscription', (req, res) => {
const user = req.body;
const q = 'INSERT into Subscription SET ?';
connection.query(q, user, (err, results) => {
if (err)
return res.json(err);
return res.json(results);
});
});
我同时使用了mysql.createconnection和mysql.createpool…。还尝试使用connection.end…手动结束连接…。
两个结果都以相同的错误结束。
1条答案
按热度按时间oogrdqng1#
您需要从池中获取一个连接并使用它,而不是查询池本身。当您从池中获得连接时,池将确保您从池中获得有效连接。所以你的代码是:
更新:
您不需要单独执行pool.getconnection和connection.query,您可以将它们组合到pool.query中,pool.query将获得连接、执行查询并释放连接。因此,更新后的代码是: