Node.js使用mssql时Promise与Catch异常排查求助

让我帮你一步步拆解这个问题，你的代码里有几个关键的坑点导致了错误无法被捕获，甚至出现err为undefined的情况：

1. Promise链断裂导致错误被吞噬 #

最核心的问题出在insertHTTPRequest方法的pool.connect()分支里：

return pool.connect().then(() => {
  // ... 构建request和query的代码
  request.query(query); // 这里没有return这个Promise！
})

你在then块里执行了request.query(query)但没有返回它，这就导致这个分支返回的不是一个Promise，而是undefined。后续中间件里的.then((genid)=>{})拿不到正确的返回值，更严重的是：如果request.query执行出错，这个错误会被封闭在内部的Promise中，无法传递到外层的.catch，最终导致你捕获到的err是undefined。

2. 依赖私有属性判断连接状态不可靠 #

你用pool._connected来判断连接是否建立，但_connected是node-mssql的内部私有属性，官方并不推荐外部代码直接依赖它。它的状态可能和实际连接状态不同步（比如连接正在建立中，但_connected还是false），会导致逻辑分支错误。

3. 缺少边界错误处理 #

比如如果req.user不存在（未登录请求），req.user.displayName会直接抛出错误；如果数据库配置错误，连接池的错误也没有被监听，这些都会导致错误被吞噬，无法在控制台看到有效日志。

修复后的代码示例 #

数据库类修复版 #

"use strict"; 
var config = require('../../config/mainConfigs'); 
const mssql = require('mssql'); 

class db { 
    constructor(){ 
        this._pool = null; 
    } 

    get_pool(){ 
        if (!this._pool && config.Logging.DB.type === 'mssql'){ 
            const dbOptions = { 
                user: config.Logging.DB.user, 
                password: config.Logging.DB.password, 
                server: config.Logging.DB.mssql.server, 
                database: config.Logging.DB.mssql.database, 
                options: { 
                    encrypt: config.Logging.DB.encrypt 
                } 
            }; 
            this._pool = new mssql.ConnectionPool(dbOptions); 
            // 监听连接池错误，避免错误被吞噬
            this._pool.on('error', (err) => {
                console.error('数据库连接池错误:', err);
            });
        } 
        return this._pool; 
    } 

    insertHTTPRequest(req){ 
        const pool = this.get_pool(); 
        if (config.Logging.DB.type !== 'mssql') {
            return Promise.reject(new Error('不支持的数据库类型'));
        }

        // 直接使用pool.request()，它会自动处理连接状态
        const request = pool.request(); 
        const query = `INSERT INTO SD_LOG ( 
            MODULE, INSTANCE, REMOTE_ADDR, USERNAME, 
            USER_AGENT, HTTP_METHOD, HTTP_REQ_URL 
        ) OUTPUT Inserted.ID_SD_LOG 
        VALUES ( 
            @module, @instance, @remote_addr, @username, 
            @user_agent, @http_method, @http_req_url 
        )`; 

        // 增加可选链和默认值，避免空值报错
        request.input('module', 'tokenizer'); 
        request.input('instance', config.Deployment.instance); 
        request.input('remote_addr', req.ip || 'unknown'); 
        request.input('username', req.user?.displayName || 'anonymous'); 
        request.input('user_agent', req.headers['user-agent'] || 'unknown'); 
        request.input('http_method', req.method); 
        request.input('http_req_url', req.url); 

        // 返回完整的Promise链，确保错误能传递到外层
        return request.query(query)
            .then(result => {
                // 从recordset中取出插入的ID
                return result.recordset[0].ID_SD_LOG;
            });
    } 
}

中间件修复版 #

app.use(function(req, res, next){ 
    db_instance.insertHTTPRequest(req)
    .then((genid)=>{ 
        req.id = genid; 
        next(); 
    })
    .catch((err)=>{ 
        // 打印完整错误信息（包括调用栈），方便排查
        console.error('插入请求日志失败:', err.stack); 
        combinedLogger.error(err); 
        res.status(503).send('Database is unavailable.'); 
        res.end(); 
    }) 
});

额外排查建议 #

1. 检查数据库配置：确认config.Logging.DB里的用户名、密码、服务器地址、数据库名是否正确，encrypt选项是否符合你的MSSQL服务器要求（比如Azure SQL需要开启encrypt）。
2. 查看MSSQL服务器日志：如果连接失败，服务器端可能会有更详细的错误信息。
3. 测试基础连接：可以写一个简单的测试脚本，直接用node-mssql连接数据库并执行简单查询，确认连接本身没有问题。

内容的提问来源于stack exchange，提问作者Fede E.