如何高效结合事件驱动回调使用MySQL查询？并重构验证查询函数

看起来你已经走在正确的路上了——用事件驱动模式处理异步SQL操作是Node.js里的最佳实践之一。把手机号存在性查询抽成独立的可复用函数其实很 straightforward，核心是把验证逻辑封装成一个独立的异步单元（推荐用Promise，比传统回调更易维护），然后在主逻辑里调用它就行。

下面是具体的重构步骤和代码示例：

1. 封装独立的手机号验证函数 #

我们先把“检查手机号是否存在”的逻辑单独拎出来，做成一个可以复用的函数。这个函数接收手机号参数，返回一个Promise：

// 封装手机号存在性检查函数
async function checkPhoneExists(db, phoneNumber) {
  try {
    const query = 'SELECT COUNT(*) AS count FROM users WHERE phone = ?';
    const [rows] = await db.query(query, [phoneNumber]);
    // 根据查询结果判断是否存在：count > 0 表示存在
    return rows[0].count > 0;
  } catch (error) {
    // 捕获数据库查询错误，抛出给调用方处理
    throw new Error(`验证手机号存在性失败: ${error.message}`);
  }
}

这里用了async/await语法（基于Promise的语法糖），比传统的回调链式调用更清晰。函数接收数据库连接实例db和要验证的手机号，返回布尔值表示是否存在；如果查询出错，会抛出错误，让调用方统一处理。

2. 重构主逻辑，调用验证函数 #

接下来，原来的业务逻辑就可以简化成调用这个验证函数，根据结果决定是否插入新数据：

// 主业务逻辑函数
async function handleUserRegistration(db, userData) {
  const { phone, name, email } = userData;
  try {
    // 调用独立的验证函数
    const phoneExists = await checkPhoneExists(db, phone);
    
    if (phoneExists) {
      console.log(`手机号 ${phone} 已存在，无需重复添加`);
      return; // 存在则直接返回，不执行后续插入
    }

    // 手机号不存在，执行插入操作
    const insertQuery = 'INSERT INTO users (phone, name, email) VALUES (?, ?, ?)';
    await db.query(insertQuery, [phone, name, email]);
    console.log(`成功添加新用户: ${phone}`);
  } catch (error) {
    // 统一处理所有错误（验证或插入时的错误）
    console.error('处理用户注册失败:', error.message);
    throw error; // 可以选择向上抛出，让上层调用方处理
  }
}

3. 为什么这么重构？ #

• 复用性：checkPhoneExists函数可以在任何需要验证手机号是否存在的场景复用（比如用户登录、修改手机号时），不用重复写相同的SQL查询和异步逻辑。
• 逻辑清晰：主业务逻辑只关注“验证-插入”的流程，验证细节被封装到独立函数里，代码可读性更高。
• 易维护：如果后续需要修改验证逻辑（比如改SQL语句、添加额外验证条件），只需要修改checkPhoneExists一个函数即可，不用到处找代码修改。
• 错误处理更集中：所有异步操作的错误都可以在主函数的catch块统一处理，避免回调地狱里的分散错误处理。

补充：如果习惯用回调式的事件驱动 #

如果你更倾向于传统的回调风格（符合早期Node.js的事件驱动回调模式），也可以把验证函数写成回调形式：

// 回调风格的验证函数
function checkPhoneExists(db, phoneNumber, callback) {
  const query = 'SELECT COUNT(*) AS count FROM users WHERE phone = ?';
  db.query(query, [phoneNumber], (error, rows) => {
    if (error) {
      return callback(new Error(`验证手机号存在性失败: ${error.message}`));
    }
    const exists = rows[0].count > 0;
    callback(null, exists);
  });
}

// 回调风格的主逻辑
function handleUserRegistration(db, userData, callback) {
  const { phone, name, email } = userData;
  checkPhoneExists(db, phone, (error, phoneExists) => {
    if (error) {
      return callback(error);
    }
    if (phoneExists) {
      console.log(`手机号 ${phone} 已存在`);
      return callback(null);
    }
    const insertQuery = 'INSERT INTO users (phone, name, email) VALUES (?, ?, ?)';
    db.query(insertQuery, [phone, name, email], callback);
  });
}

不过还是更推荐async/await的写法，它让异步代码看起来像同步代码，更易读和调试。

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