NodeJS中MySQL数据Upsert实现：避免重复插入

首先必须明确：ON DUPLICATE KEY UPDATE 生效的核心前提是 staffId 字段必须设置唯一约束（UNIQUE KEY）或主键（PRIMARY KEY）。你之前的重复插入问题，大概率是因为表中没有给staffId添加唯一约束，MySQL无法识别重复的行。

第一步：确保表结构正确 #

先给staff_data表的staffId添加唯一索引，执行这条SQL：

ALTER TABLE staff_data ADD UNIQUE KEY idx_staffId (staffId);

如果是新建表，直接把staffId设为主键更稳妥：

CREATE TABLE staff_data (
  staffId INT PRIMARY KEY COMMENT '员工唯一ID',
  name VARCHAR(255) COMMENT '员工姓名',
  age INT COMMENT '员工年龄'
);

第二步：正确实现Upsert逻辑 #

放弃REPLACE INTO（它的逻辑是删除旧行再插入，不是更新），改用INSERT INTO ... ON DUPLICATE KEY UPDATE，这才是MySQL标准的Upsert语法。

单条数据Upsert示例 #

const item = {staffId: 12345, name : "John Doe", age: 40};
const query = mysql.format(
  "INSERT INTO staff_data SET ? ON DUPLICATE KEY UPDATE name = VALUES(name), age = VALUES(age)",
  item
);
await connection.query(query);

这里VALUES(name)表示引用INSERT语句中要插入的name值，同理VALUES(age)会引用插入的age值。

批量数据Upsert（更高效） #

针对你提供的对象数组，推荐用批量插入的方式，减少数据库交互次数：

const connection = await mysql.createConnection({
  host: "xxxxx",
  user: "xxxxx",
  password: "xxxxx",
  database: "xxxxxx",
});

// 提取字段名（假设所有对象结构一致）
const fields = Object.keys(data[0]);
// 构造批量插入的值数组
const values = data.map(item => fields.map(field => item[field]));

// 生成批量Upsert语句
const query = mysql.format(
  `INSERT INTO staff_data (${fields.join(',')}) VALUES ? 
   ON DUPLICATE KEY UPDATE 
   name = VALUES(name), 
   age = VALUES(age)`,
  [values] // 注意这里要把values包在数组里，mysql.format处理VALUES ?时需要二维数组
);

await connection.query(query);
await connection.end(); // 记得关闭连接

你之前的错误点解析 #

1. REPLACE INTO 不能和 ON DUPLICATE KEY UPDATE 混用：REPLACE INTO本身的逻辑是当存在重复键时删除旧行再插入新行，和ON DUPLICATE的更新逻辑冲突，语法上也不支持。
2. 语法错误的原因：你写的REPLACE INTO staff_data VALUES staffId = 12345...完全不符合MySQL语法，VALUES后面应该跟括号包裹的字段值列表，而不是键值对。
3. 未设置唯一约束：这是核心问题，没有唯一约束的话，MySQL无法判断哪一行是重复的，无论用REPLACE还是ON DUPLICATE都会直接插入新行。

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