如何在Node.js版Azure Function中正确执行SQL查询函数

核心问题分析 #

你的代码里有几个关键问题导致Azure Function中SQL查询没返回结果：

1. 异步函数未等待：入口函数调用GetDetails()时没有加await，导致后续的axios请求在SQL查询完成前就执行了，此时GUID等变量还是初始空值。
2. 全局变量滥用：用全局变量存储查询结果（dataSQL、GUID等），在Azure Function的无服务器环境中，全局变量可能被多个请求复用，而且异步赋值的时机完全不可控。
3. 错误处理缺失：GetDetails()的catch块是空的，SQL连接或查询出错时没有任何日志输出，根本无法排查问题。
4. 连接字符串语法错误：连接字符串中Encrypt=true后面缺少分号，这可能直接导致数据库连接失败。

修复后的完整代码 #

1. 重构GetDetails函数，改为返回查询结果（摒弃全局变量） #

const sql = require("mssql"); 

// 改为接收参数并返回查询结果的异步函数，不再依赖全局变量
async function GetDetails(email, password) { 
    try { 
        console.log("Starting SQL query...");
        // 修复连接字符串的语法错误：给Encrypt=true后补充分号
        await sql.connect( 
            "Server=tcp:app.windows.net,1433;Database=BHUB_TEST;User Id=AppUser;Password=password;Encrypt=true;MultipleActiveResultSets=False;TrustServerCertificate=False;ConnectionTimeout=30;" 
        ); 
        // 使用传入的请求参数，不再硬编码账号密码
        const result = await sql.query`select * from users where email = ${email} AND password = ${password}`; 
        if (result.rowsAffected[0] >= 1) { 
            console.log("SQL query returned a valid user");
            // 直接返回查询到的用户对象，不需要JSON.stringify
            return result.recordset[0]; 
        } else { 
            console.log("No user matched the provided credentials");
            return null;
        } 
    } catch (err) { 
        // 添加上错误日志，方便在Azure Portal中排查问题
        console.error("SQL operation failed:", err);
        throw err; // 抛出错误让调用方统一处理
    } finally {
        // 确保数据库连接关闭，避免连接泄漏
        await sql.close();
    }
}

2. 修改Azure Function入口函数，等待SQL查询完成并处理结果 #

// 把axios移到顶部，避免在函数内部重复require
const axios = require("axios");

module.exports = async function (context, req) { 
    try {
        // 从请求参数中获取账号密码
        const email = req.query.email;
        const password = req.query.password;

        // 参数校验，避免空值传入
        if (!email || !password) {
            context.res = {
                status: 400,
                body: "Missing email or password in query parameters"
            };
            return;
        }

        // 等待SQL查询完成，拿到用户数据
        const userData = await GetDetails(email, password);

        if (!userData) {
            context.res = {
                status: 401,
                body: "Invalid email or password"
            };
            return;
        }

        // 从返回的用户对象中解构需要的字段
        const { userGUID, navServiceKey, navUserName } = userData;
        console.log("Retrieved nav service key:", navServiceKey);

        // 构建axios请求的鉴权信息
        const cred = "YAMEN" + ":" + "jbdv******"; 
        const encoded = Buffer.from(cred, "utf8").toString("base64"); 
        const credbase64 = "Basic " + encoded; 
        const headers = { 
            Authorization: credbase64, 
            "Content-Type": "application/json", // 去掉前面的多余空格
        }; 

        // 使用已赋值的userGUID构建请求URL
        const url = `https://tegos/BC19-NUP/QryEnwisAppUser?filter=UserSecurityID eq ${userGUID}`; 
        const response = await axios.get(url, { headers }); 

        console.log("Received response from external service:", response.data);
        context.res = { 
            status: 200,
            body: response.data, 
        }; 
    } catch (e) { 
        console.error("Function execution failed:", e); 
        // 返回明确的错误响应
        context.res = {
            status: 500,
            body: "Internal server error: " + e.message
        };
    }
};

关键修复点说明 #

• 等待异步操作：入口函数中用await GetDetails(...)确保SQL查询完成后再执行后续逻辑，保证userGUID等数据已正确赋值。
• 移除全局变量：GetDetails直接返回查询结果，调用方通过返回值获取数据，避免全局变量带来的并发冲突和不可控性。
• 完善错误处理：添加详细的错误日志，方便在Azure Portal的监控日志中排查问题；入口函数统一捕获所有错误，返回符合HTTP规范的错误响应。
• 修复连接字符串：补全Encrypt=true后的分号，解决可能的数据库连接失败问题。
• 参数化与校验：从请求参数中获取账号密码并做校验，符合Azure Function的实际使用场景，避免硬编码的安全问题。
• 关闭数据库连接：在finally块中关闭SQL连接，避免连接泄漏导致后续请求失败。

测试建议 #

1. 部署修改后的代码到Azure Function。
2. 在Postman中请求时，确保URL带上email和password查询参数，例如：https://your-function-url/api/your-function-name?email=yamen@gmail.com&password=password。
3. 查看Azure Function的日志（进入Azure Portal -> 你的Function -> 监控 -> 日志），通过日志信息排查可能的执行问题。

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