Node.js中MySQL查询无法在循环内执行的问题求助

我是Node.js新手，尝试在while循环中执行MySQL查询以获取层级结构的成员数据：先根据初始member_id查询关联成员，存入数组后，循环查询reference_id在成员ID数组中的新成员，直到无数据为止。但循环内的MySQL查询始终不执行，仅其他代码正常运行。我先后尝试了回调函数、Promise结合async/await的写法，问题依旧。

回调函数写法代码：

const membersPiramid2 = (request, response) => {
 let member_id = request.params.member_id;
 let members_ids = [];
 let members = [];
 let aux = true;

 db.query(`SELECT member_id FROM structures WHERE reference_id = '${member_id}'`, (error, results) => {
 if (error) throw error;

 if (results.length > 0) {
   members_ids = results.map(r => r.member_id);
   members.push(results);
  
   while (aux) {
    db.query(`SELECT member_id FROM structures WHERE reference_id IN ('${members_ids}')`, (err, newMembers) => {
      if (err) throw err;

      if (newMembers.length > 0) {
        members.push(newMembers);
        members_ids.length = 0
        members_ids = newMembers.map(m => m.member_id)

      } else {
        aux = false
      }
    })
  }
}
response.send(members);

Promise结合async/await写法代码：

function submembersPiramid(members_ids) {
  return new Promise((resolve, reject) => {
    db.query(`SELECT member_id FROM structures WHERE reference_id IN ('${members_ids}')`, (err, newMembers) => {
    console.log('hola2')
    if (newMembers.length > 0) {
     resolve(newMembers)
    } else {
     reject('No data found')
    }
   })
})
}

 const membersPiramid = (request, response) => {
  let member_id = request.params.member_id;
  let members_ids = [];
  let members = [];
  let aux = true;

  db.query(`SELECT member_id FROM structures WHERE reference_id = '${member_id}'`, (error, results) => {
  if (error) throw error;

  if (results.length > 0) {
    members_ids = results.map(r => r.member_id);
    members.push(results);
  
    async function doFunction() {
      await submembersPiramid(members_ids).then(response => {
        if (response != 'No data found') {
          members.push(response);
          members_ids.length = 0;
          members_ids = response.map(r => r.member_id)
        } else {
          aux = false;
        }
      }).then()
    }
    while(aux){

      doFunction()
    }


  }
  response.send(members);
})
}

核心问题：同步循环阻塞异步任务执行 #

Node.js是单线程事件循环模型，同步代码会优先占用线程，异步任务会被放到事件队列等待执行。你的两种写法都犯了同一个错误：用同步while循环包裹异步MySQL查询，导致异步任务永远得不到执行机会。

1. 回调写法的问题 #

• while(aux)是同步死循环，会一直霸占线程，db.query的回调函数被放到事件队列后，根本没机会执行，aux永远不会被设为false，循环无限运行。
• response.send(members)会在循环还没开始执行任何异步查询时就被调用，返回的只有初始查询的结果。

2. Promise+async/await写法的问题 #

• 同步while(aux)循环依然会无限执行，每次调用doFunction()只是发起了一个异步请求，但循环不会等待异步请求完成就继续下一次迭代，瞬间发起大量无效请求。
• aux的修改发生在异步回调里，同步循环根本感知不到，同样陷入死循环，response.send(members)也会提前返回。

正确写法：异步循环+参数化查询 #

我们需要用异步循环配合async/await，让每次查询完成后再进行下一次迭代，同时必须使用参数化查询避免SQL注入风险。

步骤1：封装Promise化的数据库查询 #

// 封装带参数的查询，用?占位符防止SQL注入
function getMembersByReferenceIds(referenceIds) {
  return new Promise((resolve, reject) => {
    const query = 'SELECT member_id FROM structures WHERE reference_id IN (?)';
    // mysql模块会自动处理数组参数的转义与拼接
    db.query(query, [referenceIds], (err, results) => {
      if (err) return reject(err);
      resolve(results);
    });
  });
}

步骤2：改写主函数为异步函数，使用异步循环 #

const membersPiramid = async (request, response) => {
  try {
    const memberId = request.params.member_id;
    const members = [];
    let currentIds = [memberId];

    // 异步循环：等待每次查询完成后再执行下一轮
    while (currentIds.length > 0) {
      const results = await getMembersByReferenceIds(currentIds);
      if (results.length === 0) break;
      
      members.push(results);
      // 更新下一轮要查询的成员ID
      currentIds = results.map(item => item.member_id);
    }

    response.send(members);
  } catch (error) {
    console.error('查询出错:', error);
    response.status(500).send('服务器内部错误');
  }
};

关键说明 #

• 异步循环：await会暂停当前函数执行，等待查询完成后再继续，确保currentIds能被正确更新，循环能正常终止。
• 参数化查询：绝对不能用字符串拼接SQL语句，否则会导致严重的SQL注入漏洞，参数化查询由mysql模块自动处理转义，更安全。
• 错误处理：用try/catch捕获异步操作的错误，避免程序崩溃并返回合理的错误响应。

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