NodeJS MSSQL首次调用时await SQL.connect未等待问题咨询

从你的代码和描述来看，这个问题大概率是异步竞态条件加上对mssql连接池初始化逻辑的不当处理导致的，我来帮你拆解原因和修复方案：

问题根源分析 #

1. 并发请求的竞态干扰
   当服务器首次启动后，如果有多个请求同时调用execStoredProc，第一个请求会设置this.isFirst = false，然后开始执行await SQL.connect(this.config)——但这个连接建立是异步的，在它完成之前，第二个请求进来时，this.pool仍然是undefined，此时代码会执行SQL.close()。
   而SQL.close()会关闭mssql当前的所有连接/连接池，这会直接中断第一个请求正在进行的连接初始化过程，导致this.pool始终无法被正确赋值，看起来就像是第一个await没等待直接跳过了。

2. 不必要的SQL.close()调用
   首次连接时，根本没有已打开的连接池，执行SQL.close()完全是多余的，反而会干扰mssql内部的连接初始化流程，尤其是在异步场景下，很容易破坏正在建立的连接。

修复方案 #

你需要确保只有一个连接初始化操作在执行，并且避免在首次连接前调用SQL.close()，这里有两种可行的修复方式：

方式一：用Promise缓存初始化过程（推荐） #

把连接池的初始化包装成一个Promise，确保多个并发请求只会触发一次初始化：

// 在类的属性中添加一个初始化Promise缓存
private poolInitPromise: Promise<any> | null = null;

async execStoredProc(spDescriptor: StoredProcedureDescriptor) { 
    if (!this.pool) { 
        // 如果没有初始化Promise，创建一个
        if (!this.poolInitPromise) {
            this.poolInitPromise = SQL.connect(this.config)
                .then(pool => {
                    this.pool = pool;
                    return pool;
                })
                .catch(err => {
                    // 初始化失败时清空缓存，允许后续重试
                    this.poolInitPromise = null;
                    throw err;
                });
        }
        // 等待初始化完成
        await this.poolInitPromise;
    } 
    try { 
        const request = new SQL.Request(this.pool) ; 
        spDescriptor.parms.forEach(function(sqlParm: SqlParm){ 
            request.input(sqlParm.name, sqlParm.sqlType, sqlParm.value) ; 
        }) 
        const qryresult = await request.execute(spDescriptor.storedProcedureName) 
        let result = {} ; 
        if (spDescriptor.multipleResultSets) { 
            result = qryresult.recordsets ; 
        } else { 
            result = qryresult.recordset ; 
        } 
        return result ; 
    } catch (err) { 
        console.log("SQL Error===>", err); 
        // 如果是连接相关错误，清空pool和初始化Promise，允许下次重试
        if (err.message.includes("connection")) {
            this.pool = null;
            this.poolInitPromise = null;
        }
        return [] ; 
    } 
}

方式二：简化连接池逻辑，移除不必要的SQL.close() #

如果你不需要处理连接池重启的场景，直接简化逻辑，确保首次连接不会被干扰：

async execStoredProc(spDescriptor: StoredProcedureDescriptor) { 
    if (!this.pool) { 
        // 直接建立连接，不需要isFirst和close逻辑
        this.pool = await SQL.connect(this.config); 
    } 
    try { 
        const request = new SQL.Request(this.pool) ; 
        spDescriptor.parms.forEach(function(sqlParm: SqlParm){ 
            request.input(sqlParm.name, sqlParm.sqlType, sqlParm.value) ; 
        }) 
        const qryresult = await request.execute(spDescriptor.storedProcedureName) 
        let result = {} ; 
        if (spDescriptor.multipleResultSets) { 
            result = qryresult.recordsets ; 
        } else { 
            result = qryresult.recordset ; 
        } 
        return result ; 
    } catch (err) { 
        console.log("SQL Error===>", err); 
        // 连接失败时重置pool，允许下次重试
        this.pool = null;
        return [] ; 
    } 
}

额外提示 #

• mssql的SQL.connect()本身会返回一个连接池实例，你只需要保存这个实例并复用即可，不需要手动关闭除非你明确要销毁连接池。
• 生产环境中，建议监听连接池的错误事件，及时处理连接异常：

this.pool.on('error', (err) => {
    console.error('Connection pool error:', err);
    this.pool = null; // 重置pool，允许重新初始化
});

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