Node.js操作SQL数据库时邮箱重复校验逻辑不生效问题求助

该问题由Node.js的异步执行逻辑导致：connection.query() 属于异步IO操作，你传入的回调函数要等数据库查询结果返回后才会执行，而回调外的if(error.length === 0)判断会在调用query方法后立刻执行，此时数据库查询还没完成，error.push操作根本还没运行，所以长度判断永远会通过。

方案1：回调嵌套写法 #

把插入数据、错误返回的逻辑全部放到query的回调函数内部，保证查询完成后再执行校验判断：

connection.query(
  "SELECT * FROM `employees` WHERE `email`= ?",
  [employee.email],
  function (err, row) {
    if (err) throw err;
    // 邮箱已存在的判断逻辑
    if (row && row.length) {
      error.push("请重新输入邮箱");
      res.status(400).send(error);
      console.log("Error");
      return;
    }
    // 走到此处说明邮箱无重复，直接执行插入逻辑
    // insert data in the table
  }
);

方案2：async/await写法（更推荐，避免回调嵌套混乱） #

先把回调风格的query方法包装成Promise，或者直接使用支持Promise的mysql2库：

// 封装Promise版本的查询方法
const queryAsync = (sql, params) => {
  return new Promise((resolve, reject) => {
    connection.query(sql, params, (err, rows) => {
      if (err) return reject(err);
      resolve(rows);
    })
  })
}

// 业务逻辑需要放在async函数内执行
async function handleFormSubmit() {
  const error = [];
  try {
    const rows = await queryAsync("SELECT * FROM `employees` WHERE `email`= ?", [employee.email]);
    if (rows && rows.length) {
      error.push("请重新输入邮箱");
    }
    if (error.length === 0) {
      // 执行插入数据逻辑
    } else {
      res.status(400).send(error);
      console.log("Error");
    }
  } catch (err) {
    throw err;
  }
}

• 给数据库employees表的email字段添加唯一索引，就算代码逻辑漏判，数据库也会阻止重复数据插入，做双重保障
• 无需重启服务重连数据库，修改完逻辑代码后重载生效即可

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