Node.js中MySQL异步查询结果/错误返回时机问题求助

你当前的问题核心是MySQL的con.query是异步操作，而你的返回逻辑是同步执行的，导致return语句在数据库操作完成前就已经执行，自然拿不到正确结果。以下是具体分析和修复方案：

问题代码分析 #

你的原代码依赖全局变量output存储异步操作结果，但l().then(...)会在con.query的回调函数执行前运行，此时output还未被赋值，所以返回的是未定义或初始值。

原代码：

let sql = "INSERT INTO ZUTAT (ZUTATENNR, BEZEICHNUNG, EINHEIT, NETTOPREIS, BESTAND, LIEFERANT, KALORIEN, KOHLENHYDRATE, PROTEIN, Gelistet, Bild) VALUES ?";
let values = [
  [data.pNr, data.pName, data.pUnit, data.pPrice, data.pCount, '101', data.pKa, data.pKo, data.pPr, data.pListed, data.pImage]
];
let output;

con.query(sql, [values], function(err, result) {
  if (err) {
    console.log('Error: ' + err);
    returnBack(err);
  } else {
    console.log('Result: ' + result);
    returnBack(result);
  }
});

function returnBack(returnValue) {
  console.log('Return: ' + returnValue);
  output = returnValue;
}

l().then({
  function() {
    console.log('t: ' + output);
    return output;
  }
})
}

修复方案：用Promise包裹异步操作 #

解决异步问题最可靠的方式是将con.query包装成Promise，再用async/await控制执行顺序，确保数据库操作完成后再返回结果。

修正后的代码 #

// 把数据库插入操作包装成Promise函数
function createProduct(data) {
  return new Promise((resolve, reject) => {
    let sql = "INSERT INTO ZUTAT (ZUTATENNR, BEZEICHNUNG, EINHEIT, NETTOPREIS, BESTAND, LIEFERANT, KALORIEN, KOHLENHYDRATE, PROTEIN, Gelistet, Bild) VALUES ?";
    let values = [
      [data.pNr, data.pName, data.pUnit, data.pPrice, data.pCount, '101', data.pKa, data.pKo, data.pPr, data.pListed, data.pImage]
    ];

    con.query(sql, [values], function(err, result) {
      if (err) {
        console.log('Error: ' + err);
        reject(err); // 抛出错误
      } else {
        console.log('Result: ' + result);
        resolve(result); // 返回成功结果
      }
    });
  });
}

// 使用async/await调用，确保拿到结果后再返回
async function handleCreateProduct(data) {
  try {
    const result = await createProduct(data);
    console.log('t: ' + result);
    return result;
  } catch (err) {
    console.error('操作失败: ', err);
    throw err; // 可根据需求自定义错误处理逻辑
  }
}

// 调用示例
// handleCreateProduct(yourData).then(result => { ... }).catch(err => { ... });

关键说明 #

1. Promise包装：将异步的con.query放入Promise中，用resolve返回成功结果、reject抛出错误，让异步操作可以被async/await等待。
2. async/await：在调用函数前加async关键字，内部用await等待Promise完成，确保后续代码在数据库操作结束后再执行。
3. 移除全局变量：不再依赖output存储结果，直接通过Promise的返回值传递数据，避免异步操作中变量赋值顺序混乱的问题。

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