Node.js执行MySQL JOIN查询返回异常Query对象无结果排查

拿不到有效结果和SQL本身没关系——你手动在数据库跑SQL能出结果，说明JOIN逻辑、参数匹配都没问题，问题出在Node侧的数据库调用写法上：

• 你用的原生mysqlnpm包，query方法如果传了第三个回调函数参数，本身不会返回Promise，你加await等不到结果，赋值给a的就是你控制台打印出来的那个Query实例对象，根本不是查询结果集。
• 回调里的判断逻辑写反了：if(err)是报错分支，走else说明查询执行成功没出错，你在成功分支只打了SO SAD，根本没读取rows参数里的实际查询数据，误以为没查到结果。

两种正确写法二选一即可，绝对不要混用回调和async/await：

写法1：纯回调模式（无需改依赖） #

去掉await，所有结果处理逻辑都放在回调内部：

exports.test = function(req, res, next) {
    const selectNameSql = `SELECT 
    data_db.assets.name_assets, data_db.assets.id_assets, 
    data_db.threats.name_threats, data_db.threats.id_threats, 
    data_db.vulns.name_vulns, data_db.vulns.id_vulns 
    FROM 
    data_db.threats 
    RIGHT JOIN data_db.assets 
    ON data_db.assets.id_assets=data_db.threats.id_assets 
    RIGHT JOIN data_db.vulns 
    ON data_db.vulns.id_assets=data_db.assets.id_assets 
    WHERE 
    data_db.assets.id_assets=? AND data_db.vulns.id_vulns=? AND data_db.threats.id_threats=?`;
    db.query(selectNameSql, [2, 3, 4], function(err, rows, fields) {
        if (err) {
            console.log('查询报错:', err);
            return res.status(500).send({msg: '查询失败'});
        }
        // rows就是你要的查询结果
        console.log('查询结果:', rows);
        res.send({data: rows});
    });
}

写法2：async/await模式（代码更整洁） #

原生mysql包默认不支持Promise返回，要么手动包装一层Promise，要么换成mysql2/promise依赖。
手动包装写法（不用换依赖）：

exports.test = async function(req, res, next) {
    const selectNameSql = `SELECT 
    data_db.assets.name_assets, data_db.assets.id_assets, 
    data_db.threats.name_threats, data_db.threats.id_threats, 
    data_db.vulns.name_vulns, data_db.vulns.id_vulns 
    FROM 
    data_db.threats 
    RIGHT JOIN data_db.assets 
    ON data_db.assets.id_assets=data_db.threats.id_assets 
    RIGHT JOIN data_db.vulns 
    ON data_db.vulns.id_assets=data_db.assets.id_assets 
    WHERE 
    data_db.assets.id_assets=? AND data_db.vulns.id_vulns=? AND data_db.threats.id_threats=?`;
    try {
        // 不要给query传第三个回调参数，手动包装成Promise
        const rows = await new Promise((resolve, reject) => {
            db.query(selectNameSql, [2, 3, 4], (err, results) => {
                if (err) return reject(err);
                resolve(results);
            });
        });
        console.log('查询结果:', rows);
        res.send({data: rows});
    } catch (err) {
        console.log('查询报错:', err);
        res.status(500).send({msg: '查询失败'});
    }
}

如果换mysql2/promise依赖写法更简单，初始化连接时直接引入Promise版本：

// 初始化db连接时替换依赖
const mysql = require('mysql2/promise');
const db = await mysql.createConnection({/* 你的数据库连接配置 */});
// 后续查询直接await拿结果，不需要写回调
const [rows] = await db.query(selectNameSql, [2,3,4]);

如果改完写法还是拿不到预期结果，检查两个细节：

• 确认Node服务连接的数据库实例、库名和你手动跑SQL的环境完全一致，避免连错测试/生产环境
• 后续调整查询参数时，保证传入的参数数组顺序和SQL里?占位符的顺序一一对应

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