使用Sequelize JS插入唯一记录的更优方案探讨

嘿，你现在的做法虽然能实现基本功能，但在高并发场景下很容易踩坑——比如两个请求同时查询到「无该记录」，接着都执行插入操作，最后就会出现重复数据。给你几个更靠谱的方案，都是Sequelize官方推荐的最佳实践：

这个方法是Sequelize专门为「查询-不存在则插入」场景设计的，它会在数据库层面原子性地完成整个操作，彻底解决并发下的重复插入问题。

代码示例：

const addName = async function(name, amount) {
  try {
    // findOrCreate 返回一个数组：[实例对象, 是否为新创建的布尔值]
    const [nameRecord, created] = await NameModel.findOrCreate({
      where: { name: name }, // 用于判断记录是否存在的查询条件
      defaults: { amount: amount } // 若不存在，要插入的其他字段值
    });

    if (created) {
      console.log(`成功插入新记录：${name}`);
    } else {
      console.log(`记录已存在：${name}`);
    }
    return nameRecord;
  } catch (err) {
    console.error('操作失败：', err);
    throw err;
  }
};

关键补充：一定要给name字段加上数据库唯一约束！就算极端场景下出现意外，数据库也会直接拦截重复插入，从根源避免脏数据。

在模型定义里添加唯一约束的方式：

const NameModel = sequelize.define('Name', {
  name: {
    type: DataTypes.STRING,
    allowNull: false,
    unique: true // 这里添加唯一约束
  },
  amount: {
    type: DataTypes.INTEGER
  }
});

如果你希望当记录存在时，直接更新它的amount字段，而不是仅提示存在，可以用upsert方法，它会原子性完成「存在则更新，不存在则插入」的逻辑：

const addOrUpdateName = async function(name, amount) {
  try {
    // upsert 返回一个数组：[是否创建了新记录的布尔值, 实例对象]
    const [created, nameRecord] = await NameModel.upsert({
      name: name,
      amount: amount
    });

    if (created) {
      console.log(`插入新记录：${name}`);
    } else {
      console.log(`更新已有记录：${name}`);
    }
    return nameRecord;
  } catch (err) {
    console.error('操作失败：', err);
    throw err;
  }
};

你之前的思路属于应用层验证，但单独使用时，查询和插入之间存在时间窗口，并发场景下仍可能出现重复。如果一定要保留类似逻辑，记得结合数据库唯一约束，同时用async/await优化回调写法：

const addName = async function(name, amount) {
  try {
    const existingRecord = await NameModel.findOne({ where: { name: name } });
    if (existingRecord) {
      console.log(`记录已存在：${name}`);
      return existingRecord;
    }
    const newRecord = await NameModel.create({ name: name, amount: amount });
    console.log(`插入新记录：${name}`);
    return newRecord;
  } catch (err) {
    // 捕获唯一约束冲突的错误
    if (err.name === 'SequelizeUniqueConstraintError') {
      console.log(`记录已存在（数据库约束拦截）：${name}`);
    } else {
      console.error('操作失败：', err);
    }
    throw err;
  }
};

提醒：这个方法的可靠性远不如findOrCreate，仅适合低并发、对数据一致性要求不高的场景。

最后总结：优先选择findOrCreate+数据库唯一约束的组合，这是最安全高效的方案；需要更新记录时用upsert；原生查询+if的写法尽量避免，尤其是高并发场景。

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