Node.js中MySQL不存在则插入的异步查询问题求助

你的代码核心问题出在异步逻辑处理混乱和低效的先查后插模式，以下是具体问题拆解和修复方案：

核心问题分析 #

1. async/await与回调混用无效：con.query在回调模式下不会返回Promise，await完全起不到等待异步操作完成的作用，导致代码直接跳过检查执行插入。
2. 未等待异步函数执行：外层循环里的自执行(async function(){...})()没有被await，循环会直接进入下一次迭代，完全不等待异步操作结束。
3. 循环条件错误：for(let j=0; splitcat.length-1; j++)的条件是splitcat.length-1，只要数组长度大于1，这个条件永远为true，会造成无限循环。
4. SQL注入风险：查询语句直接拼接字符串"SELECT * from category where name = '" + splitcat[j] + "'"，存在严重的注入漏洞。
5. 非原子性操作：先查询再插入不是原子操作，高并发下可能出现重复插入，还多消耗一次数据库请求。

修复方案 #

第一步：改用支持Promise的MySQL库 #

推荐用mysql2/promise，它原生支持Promise，能完美配合async/await，避免回调嵌套问题。安装命令：

npm install mysql2

第二步：利用MySQL原生语法实现「不存在则插入」 #

先给category表的name字段添加唯一索引（确保字段值唯一）：

ALTER TABLE category ADD UNIQUE INDEX idx_name (name);

然后用INSERT ... ON DUPLICATE KEY UPDATE（或INSERT IGNORE，按需选择），这是数据库层面的原子操作，比先查后插更高效安全：

• INSERT IGNORE：遇到重复记录时直接忽略插入，不报错。
• INSERT ... ON DUPLICATE KEY UPDATE：遇到重复记录时可更新指定字段，不需要更新的话可以写UPDATE name = name（无实际操作）。

第三步：修正循环与异步逻辑 #

以下是完整修正代码：

const mysql = require('mysql2/promise');

// 建立数据库连接池（推荐用连接池而非单连接）
const pool = mysql.createPool({
  host: '你的数据库主机',
  user: '用户名',
  password: '密码',
  database: '数据库名',
  connectionLimit: 10
});

async function processCategories(finalRow) {
  // 遍历二维数组
  for (const row of finalRow) {
    // 修正数据示例的语法错误，确保子数组是['a > b']格式
    const splitcat = row[0].split(' > ');
    // 遍历拆分后的分类名
    for (const name of splitcat) {
      try {
        // 原子性实现「不存在则插入」
        await pool.execute(
          `INSERT INTO category (name, url, description, parent_id) 
           VALUES (?, ?, ?, ?) 
           ON DUPLICATE KEY UPDATE name = name`,
          [name, '', '', null]
        );
        console.log(`分类 ${name} 已存在或插入成功`);
      } catch (err) {
        console.error(`处理分类 ${name} 出错:`, err);
      }
    }
  }
}

// 修正语法后的输入数据
const finalRow = [['a > b'], ['a > c']];
// 执行处理函数
processCategories(finalRow);

关键说明 #

• 连接池优势：自动管理连接的创建与释放，比单连接更稳定高效。
• 原子操作：通过数据库唯一索引和原生语法，避免了先查后插的竞态问题，同时减少数据库请求次数。
• 异步等待：for...of循环配合await，确保每次异步操作完成后再进入下一次迭代，彻底解决循环不等待的问题。
• 安全查询：始终用?占位符传递参数，杜绝SQL注入风险。

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