时间戳

首页 > 解决方案 > 如何使用 Mysql2 Promise 结束数据库连接？

javascript - 如何使用 Mysql2 Promise 结束数据库连接？

问题描述

以下代码按预期工作，但我似乎无法弄清楚如何调用con.end();

db.js：

const
mysql = require('mysql2/promise'),
config = {
  host: 'localhost',
  port: 3306,
  user: 'root',
  password: '',
  database: 'webhooks'
};

module.exports = async () => {
  const
  con = await mysql.createConnection(config),
  sql = 'SELECT * FROM table',
  data = [];

  let [rows, fields] = await con.execute(sql);

  return rows;
}

应用程序.js：

const test = require('./db.js');

test.then(console.log);

我之前尝试过添加con.end();，return rows;我也尝试过各种组合test.then(...).catch(...).then(() => con.end());但没有结果。

我在这里想念什么？

标签： javascriptmysqlnode.js

解决方案

在async 导出函数中，因为正在等待所有异步操作（连接、获取）。理想情况下，它con.end()应该是一个async操作，并且可以简单地等待，因为之前获取并解决了结果。

module.exports = async () => {
  const
  con = await mysql.createConnection(config),
  sql = 'SELECT * FROM table',
  data = [];

  let [rows, fields] = await con.execute(sql);
  await con.end();
  return rows;
}

然后在app.js中获取返回的行：

const test = require('./db.js');

test.then(rowsResults => console.log(rowsResults)); //only rows were returned
  • con对象也可以作为其中的一部分发送returned promise，rows随后可以在测试中关闭，但在这种情况下看起来更冗长。

推荐阅读