为何mssql官方异步SQL请求示例失效？async用法存疑

一、async/await写法无响应的核心原因及修复 #

你遇到的无响应问题，大概率是未处理异步操作的异常，或者没有确保响应方法被调用。Node.js的async函数抛出异常时，如果没被捕获，会导致请求一直挂起，不会返回任何响应。

错误示例（会导致无响应） #

app.get('/', async (req, res) => {
  const pool = await sql.connect(config);
  const result = await pool.request().execute('spTest');
  res.send(result.recordset);
});

如果sql.connect或execute过程中出错，异常会被抛出但没被捕获，Express无法处理这个未捕获的Promise拒绝，请求就会一直卡在那里。

正确写法（添加错误捕获与资源清理） #

// 推荐：提前初始化连接池，避免每次请求都创建连接
const pool = new sql.ConnectionPool(config);
pool.connect().catch(err => console.error('连接池初始化失败:', err));

app.get('/', async (req, res) => {
  try {
    // 从连接池获取连接执行存储过程
    const result = await pool.request().execute('spTest');
    res.send(result.recordset);
  } catch (err) {
    // 捕获所有异常，返回错误响应
    console.error('请求处理失败:', err);
    res.status(500).send(`执行失败: ${err.message}`);
  }
});

或者如果不用全局连接池，记得在finally里关闭连接：

app.get('/', async (req, res) => {
  let pool;
  try {
    pool = await sql.connect(config);
    const result = await pool.request().execute('spTest');
    res.send(result.recordset);
  } catch (err) {
    console.error(err);
    res.status(500).send('请求出错');
  } finally {
    // 确保连接被关闭，避免资源泄漏
    if (pool) await pool.close();
  }
});

二、为什么回调写法能正常运行？ #

回调写法之所以没问题，是因为它在每一步都做了错误处理，并且无论成功或失败都会调用响应方法：

app.get('/', (req, res) => {
  sql.connect(config, (connectErr) => {
    if (connectErr) {
      console.error(connectErr);
      res.status(500).send('数据库连接失败');
      return; // 终止后续逻辑
    }

    sql.request().execute('spTest', (execErr, result) => {
      if (execErr) {
        console.error(execErr);
        res.status(500).send('存储过程执行失败');
      } else {
        res.send(result.recordset);
      }
      sql.close(); // 不管结果如何，关闭连接
    });
  });

这种写法不会出现未捕获的异常，每一步的错误都会被处理并返回响应，所以请求不会挂起。

三、是否需要异步处理数据库请求？ #

必须要。数据库操作属于IO密集型任务，如果用同步方式处理，会阻塞Node.js的事件循环——这意味着在数据库返回结果之前，你的服务器无法处理任何其他请求，性能会暴跌。异步处理（回调、Promise、async/await）能让Node.js在等待数据库响应时，去处理其他请求，保证服务器的并发能力。

四、何时应该用async/await语法？ #

async/await是Promise的语法糖，适合这些场景：

• 避免回调地狱：当你需要执行多个依赖的异步操作（比如先查用户，再用用户ID查订单），嵌套回调会让代码变得混乱，async/await能让代码逻辑更线性、易读。

  async function getUserOrders(req, res) {
    try {
      const userResult = await pool.request()
        .input('userId', req.params.id)
        .query('SELECT * FROM Users WHERE Id = @userId');
      
      const orderResult = await pool.request()
        .input('userId', req.params.id)
        .query('SELECT * FROM Orders WHERE UserId = @userId');
      
      res.json({
        user: userResult.recordset[0],
        orders: orderResult.recordset
      });
    } catch (err) {
      res.status(500).send(err.message);
    }
  }
  

• 简化错误处理：用单个try/catch就能捕获所有异步操作的异常，不用在每个回调里写错误处理逻辑。
• 与Promise生态兼容：async函数本身返回Promise，方便和其他返回Promise的库或API集成。

内容的提问来源于stack exchange，提问作者TheMortiestMorty