本文旨在解决node.js express应用中，使用`mssql`库进行数据库操作时，`async/await`模式不生效的问题。核心在于将express路由处理函数本身声明为`async`函数，确保异步逻辑能够被正确执行。同时，文章还将探讨在数据库请求中使用异步操作的必要性及最佳实践，帮助开发者构建稳定高效的数据库交互。
理解异步操作与 async/await
在Node.js环境中，数据库操作属于典型的I/O密集型任务。为了避免阻塞主线程，影响应用的响应性能，这类操作必须以异步方式执行。async/await是ES2017引入的语法糖，它使得基于Promise的异步代码可以像同步代码一样编写和阅读，极大地提高了代码的可读性和可维护性。
当进行数据库连接或查询时，mssql库返回的是Promise对象。使用await关键字可以暂停当前async函数的执行，直到Promise被解析（resolved）或拒绝（rejected），从而获取其结果或捕获错误。因此，对于数据库这类耗时操作，采用async/await模式是现代Node.js开发的标准实践。
常见问题：async函数未被调用
开发者在使用mssql库与Express结合时，常遇到的一个问题是，即使定义了async函数，数据库操作却未能执行。这通常是因为async函数被定义了，但没有被实际调用。考虑以下示例代码中“不工作”的部分：
app.get('/', function (req, res) {
// 这是一个定义了但未被调用的async函数
async () => {
try {
await sql.connect(config)
var request = new sql.Request();
const result = await request.query(`exec spTest null`)
console.dir(result)
res.send(result.recordset)
} catch (err) {
console.dir(err)
}
}
// ... 此处可能还有其他同步代码或未被调用的异步逻辑
});在这段代码中，async () => { ... } 只是定义了一个匿名异步函数，但并没有立即执行它。因此，其中的sql.connect()和request.query()等操作永远不会被触发，导致路由请求无法得到响应，浏览器也无法加载任何内容。
正确的 async/await 使用方式
要解决上述问题，关键在于确保包含await关键字的异步操作在一个被调用的async函数内部。在Express路由处理函数中，最直接且推荐的做法是将路由处理函数本身声明为async函数。这样，当Express接收到请求并调用该处理函数时，其中的await操作就能正常工作。
以下是修正后的代码示例，它将Express路由处理函数声明为async函数：
var express = require('express');
var app = express();
const sql = require("mssql");
// 数据库连接配置
const config = {
user: 'sa',
password: 'password',
server: 'ipAddress', // 替换为你的SQL Server IP地址
database: 'DBName', // 替换为你的数据库名称
trustServerCertificate: true, // 仅用于本地测试环境，生产环境应设为false并配置TLS/SSL证书
encrypt: true, // 建议开启，加密传输
};
app.get('/', async (req, res) => { // 将路由处理函数声明为 async
try {
// 建立数据库连接
await sql.connect(config);
// 创建请求对象
var request = new sql.Request();
// 执行存储过程查询
const result = await request.query(`exec spTest null`);
console.dir(result);
// 发送查询结果
res.send(result.recordset);
} catch (err) {
// 错误处理：捕获连接或查询过程中可能发生的错误
console.error('数据库操作失败:', err);
res.status(500).send('数据库查询出错或连接失败');
} finally {
// 确保连接在请求处理完毕后关闭，或者在生产环境中使用连接池
// sql.close(); // 如果不使用连接池，可以在这里关闭，但生产环境不推荐每次请求都开关连接
}
});
var server = app.listen(5000, function () {
console.log('Server is running on port 5000...');
});代码解析：
- app.get('/', async (req, res) => { ... });: 这是核心改动。通过在函数定义前加上async关键字，Express路由处理函数现在可以内部使用await。当Express接收到/路径的请求时，它会调用这个async函数。
- await sql.connect(config);: 这会暂停async函数的执行，直到数据库连接成功建立。如果连接失败，Promise会被拒绝，catch块将捕获错误。
- var request = new sql.Request();: 创建一个用于执行SQL命令的请求对象。
- const result = await request.query(exec spTest null);: 执行SQL查询（这里是存储过程），并等待结果返回。同样，如果查询失败，错误将被catch块捕获。
- try...catch 块: 这是处理异步操作错误的关键。任何在try块中抛出的错误（例如连接失败、查询错误）都将被catch块捕获，防止应用崩溃并允许发送友好的错误响应。
- finally 块 (可选但重要): 尽管在示例中被注释，但在实际生产环境中，finally块常用于资源清理，例如关闭数据库连接。然而，对于mssql，更推荐使用连接池，避免频繁开关连接的开销。
生产环境注意事项与最佳实践
为了构建健壮、高效且安全的Node.js应用，与mssql进行数据库交互时应遵循以下最佳实践：
-
连接池 (Connection Pooling): 在生产环境中，每次HTTP请求都建立和关闭数据库连接是非常低效的。mssql库支持连接池，可以预先创建一组数据库连接，并在需要时重用它们。这显著提高了性能和资源利用率。
// 示例：使用连接池 const pool = new sql.ConnectionPool(config); // 在应用启动时连接到数据库池 pool.connect().then(() => { console.log('MSSQL Connection Pool Created and Connected'); }).catch(err => console.error('Database Pool Connection Failed', err)); app.get('/pooled-data', async (req, res) => { try { // 从连接池获取请求对象，无需每次都调用 sql.connect() const request = pool.request(); const result = await request.query(`SELECT * FROM YourTable`); res.send(result.recordset); } catch (err) { console.error('Pooled Query Failed:', err); res.status(500).send('数据库查询出错'); } }); // 在应用关闭时优雅地关闭连接池 process.on('SIGINT', () => { // 捕获 Ctrl+C pool.close(() => { console.log('MSSQL Connection Pool Closed'); process.exit(0); }); }); 错误处理: 始终使用try...catch来捕获异步操作中的错误。在catch块中，记录详细的错误信息到日志系统，并向客户端返回有意义但非敏感的错误信息（例如，避免暴露数据库内部的错误堆栈或连接字符串）。
-
安全性:
资源管理: 对于不使用连接池的场景，确保在完成数据库操作后调用sql.close()来释放连接资源。然而，如前所述，连接池是更优的解决方案。
总结
在Node.js Express应用中使用mssql进行异步数据库操作时，核心在于理解async/await的执行机制。确保包含await关键字的代码块位于一个被正确调用和执行的async函数中。对于Express路由，这意味着将路由处理函数本身声明为async。同时，为了构建健壮和高性能的应用，务必考虑使用连接池、完善错误处理机制，并严格遵守安全最佳实践。正确地运用这些技术，将使你的Node.js应用能够高效、安全地与SQL Server数据库进行交互。
