在Node.js Express项目中，使用mssql模块操作SQL Server数据库时，异步操作是提升性能和代码可读性的关键。mssql模块原生支持Promise和async/await语法，能够很好地适配Express的异步请求处理流程，避免传统回调方式带来的代码嵌套问题。
mssql模块安装与基础配置
首先需要在项目中安装mssql依赖，执行以下命令：
npm install mssql
安装完成后，需要先配置数据库连接信息，推荐使用连接池的方式管理数据库连接，提升资源利用率。基础配置代码如下：
const sql = require('mssql');
// 数据库配置对象
const dbConfig = {
user: 'sa',
password: 'your_password',
server: 'localhost',
database: 'test_db',
port: 1433,
options: {
encrypt: false, // 本地开发可关闭加密
trustServerCertificate: true // 信任自签名证书
},
pool: {
max: 10, // 连接池最大连接数
min: 0, // 连接池最小连接数
idleTimeoutMillis: 30000 // 空闲连接超时时间
}
};
创建连接池并封装通用查询方法
为了避免重复创建连接，我们可以封装一个通用的查询方法，内部使用连接池执行操作：
// 创建连接池实例
const pool = new sql.ConnectionPool(dbConfig);
const poolConnect = pool.connect();
// 确保连接池初始化完成
poolConnect.then(() => {
console.log('数据库连接池初始化成功');
}).catch(err => {
console.error('数据库连接池初始化失败:', err);
});
/**
* 通用数据库查询方法
* @param {string} sqlQuery - SQL查询语句
* @param {Array} params - 查询参数数组，可选
* @returns {Promise} 查询结果
*/
async function executeQuery(sqlQuery, params = []) {
try {
// 等待连接池就绪
await poolConnect;
const request = pool.request();
// 添加参数（防止SQL注入）
params.forEach((param, index) => {
request.input(`param${index}`, param.value);
});
const result = await request.query(sqlQuery);
return result.recordset;
} catch (err) {
console.error('数据库查询失败:', err);
throw err;
}
}
Express路由中调用异步数据库操作
在Express的路由处理函数中，可以直接使用async/await调用封装好的查询方法，处理请求并返回数据：
查询数据示例
const express = require('express');
const app = express();
app.use(express.json());
// 查询用户列表接口
app.get('/users', async (req, res) => {
try {
const sqlStr = 'SELECT id, username, age FROM users WHERE age > @param0';
const params = [
{ value: 18 }
];
const users = await executeQuery(sqlStr, params);
res.json({
code: 0,
data: users,
msg: '查询成功'
});
} catch (err) {
res.status(500).json({
code: 500,
msg: '查询失败'
});
}
});
插入数据示例
// 新增用户接口
app.post('/users', async (req, res) => {
const { username, age } = req.body;
if (!username || !age) {
return res.status(400).json({
code: 400,
msg: '参数不完整'
});
}
try {
const sqlStr = 'INSERT INTO users (username, age) VALUES (@param0, @param1)';
const params = [
{ value: username },
{ value: age }
];
await executeQuery(sqlStr, params);
res.json({
code: 0,
msg: '新增成功'
});
} catch (err) {
res.status(500).json({
code: 500,
msg: '新增失败'
});
}
});
事务操作实现
当需要多个数据库操作保持原子性时，可以使用mssql的事务功能，示例如下：
// 转账事务示例
app.post('/transfer', async (req, res) => {
const { fromId, toId, amount } = req.body;
try {
await poolConnect;
const transaction = new sql.Transaction(pool);
await transaction.begin();
try {
const request = new sql.Request(transaction);
// 扣除转出方金额
await request.query(`UPDATE accounts SET balance = balance - ${amount} WHERE id = ${fromId}`);
// 增加转入方金额
await request.query(`UPDATE accounts SET balance = balance + ${amount} WHERE id = ${toId}`);
await transaction.commit();
res.json({
code: 0,
msg: '转账成功'
});
} catch (err) {
await transaction.rollback();
throw err;
}
} catch (err) {
console.error('转账失败:', err);
res.status(500).json({
code: 500,
msg: '转账失败'
});
}
});
注意事项
- 所有SQL参数都通过
request.input方法传入，避免直接拼接SQL字符串导致注入风险 - 连接池不需要手动关闭，Express应用运行期间保持连接池活跃即可，应用停止时连接池会自动释放资源
- 异步操作必须添加错误捕获，避免未处理的异常导致Express服务崩溃
- 生产环境需要开启encrypt选项，并且使用正式的SSL证书，保障数据传输安全