超时后终止数据库查询

在Node.js应用程序中，可以使用超时定时器来解决此问题。如果某个查询需要花费太长时间，则可以强制停止该查询，以避免阻塞线程池或消耗太多资源。

以下是一个示例代码，演示如何使用Promise.race和setTimeout来实现超时处理。

const { promisify } = require('util');
const mysql = require('mysql');

const pool = mysql.createPool({
  connectionLimit: 10,
  host: 'localhost',
  user: 'root',
  password: '',
  database: 'mydb',
});

const query = promisify(pool.query).bind(pool);

function queryWithTimeout(sql, timeout) {
  return Promise.race([
    query(sql),
    new Promise((resolve, reject) => {
      setTimeout(() => reject(new Error('Query timeout')), timeout);
    }),
  ]);
}

(async () => {
  try {
    const result = await queryWithTimeout('SELECT * FROM mytable', 5000);
    console.log(result);
  } catch (err) {
    console.error(err);
  } finally {
    pool.end();
  }
})();

在上面的示例中，我们使用了promisify将pool.query转换为返回Promise对象的函数。然后，我们定义了一个queryWithTimeout函数，该函数接收两个参数：SQL语句和最大超时限制（毫秒）。函数返回一个Promise对象，该对象将首先和数据库查询的Promise竞争，然后与一个超时定时器Promise竞争，以确定哪个Promise最先完成。如果查询成功，则Promise返回查询结果；否则，它将抛出一个带有“查询超时”错误的异常。

最后，我们在async函数中调用queryWithTimeout函数，并对结果进行处理。我们还在finally语句块中调用pool.end()方法来释放池中的连接。