mysql node.js间歇性连接问题

wwtsj6pe 于 2021-06-21 发布在 Mysql

关注(0)|答案(1)|浏览(385)

在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…手动结束连接…。
两个结果都以相同的错误结束。

mysql JavaScript node.js

来源：https://stackoverflow.com/questions/50801849/mysql-node-js-intermittent-connectivity-issue

1条答案

按热度按时间

oogrdqng1#

您需要从池中获取一个连接并使用它，而不是查询池本身。当您从池中获得连接时，池将确保您从池中获得有效连接。所以你的代码是：

const mysql = require('mysql');

let pool = 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 ?';
  pool.getConnection(function(err, connection) {
     if (err)
       return res.json(err);

     connection.query(q, user, (err, results) => {
       if (err)
         return res.json(err);
       return res.json(results);
     });
  })
});

更新：
您不需要单独执行pool.getconnection和connection.query，您可以将它们组合到pool.query中，pool.query将获得连接、执行查询并释放连接。因此，更新后的代码是：

const mysql = require('mysql');

let pool = 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 ?';
  pool.query(q, user, function(err, connection) {
     if (err)
       return res.json(err);

     return res.json(results);
  });
});

赞(0）回复(0）举报 2021-06-21

我来回答

mysql node.js间歇性连接问题

1条答案

相关问题

热门标签

最新问答