Sequelize中afterBulkCreate钩子用updateOnDuplicate无法获取旧值问题

Sequelize的bulkCreate配合updateOnDuplicate时，底层执行的是INSERT ... ON DUPLICATE KEY UPDATE语句。这种操作不会主动查询旧数据，因此afterBulkCreate钩子中无法获取到_previousDataValues，且不会触发afterUpdate钩子——因为这不属于Sequelize定义的标准更新流程。

针对审计日志的需求，提供三种可行方案：

1. 预查询旧值+批量操作（应用层处理） #

先批量查询要操作的记录的旧值，再执行bulkCreate，最后对比新旧值生成审计日志。需注意用事务包裹操作，避免并发场景下数据不一致。

示例代码：

// 假设你的表用`id`作为唯一键
const createAuditLog = async (oldValues, newValues, operation) => {
  // 替换为你的审计日志创建逻辑
  await AuditLog.create({
    tableName: 'Table',
    recordId: newValues.id,
    oldValues: oldValues ? JSON.stringify(oldValues) : null,
    newValues: JSON.stringify(newValues),
    operationType: operation
  });
};

// 事务包裹查询与批量操作
await sequelize.transaction(async (t) => {
  // 提取要操作的记录ID
  const targetIds = params.map(item => item.id);
  // 查询旧数据
  const oldRecords = await Table.findAll({
    where: { id: targetIds },
    transaction: t
  });
  const oldDataMap = new Map(oldRecords.map(r => [r.id, r.dataValues]));

  // 执行批量创建/更新
  await Table.bulkCreate(params, {
    updateOnDuplicate: ["metrics", "status"],
    transaction: t
  });

  // 生成审计日志
  for (const item of params) {
    const oldValues = oldDataMap.get(item.id);
    if (oldValues) {
      // 对比字段变化
      const changed = Object.keys(item).filter(key => {
        if (key === 'id') return false;
        return JSON.stringify(oldValues[key]) !== JSON.stringify(item[key]);
      });
      if (changed.length > 0) {
        await createAuditLog(oldValues, item, 'UPDATE');
      }
    } else {
      await createAuditLog(null, item, 'CREATE');
    }
  }
});

2. 数据库触发器（底层处理） #

直接在数据库层面创建触发器，捕获INSERT ... ON DUPLICATE KEY UPDATE操作的新旧值，写入审计表。这种方式性能最优，且不受应用层逻辑限制。

以MySQL为例，触发器示例：

-- 先创建审计日志表（按需调整字段）
CREATE TABLE IF NOT EXISTS audit_log (
  id INT AUTO_INCREMENT PRIMARY KEY,
  table_name VARCHAR(50) NOT NULL,
  record_id INT NOT NULL,
  old_values JSON,
  new_values JSON NOT NULL,
  operation_type ENUM('CREATE', 'UPDATE') NOT NULL,
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

-- 创建触发器
DELIMITER //
CREATE TRIGGER table_after_upsert
AFTER INSERT ON `Table`
FOR EACH ROW
BEGIN
  -- 判断是更新还是插入：OLD存在则为更新（因为DUPLICATE KEY时会触发INSERT但OLD有值）
  IF OLD.id IS NOT NULL THEN
    INSERT INTO audit_log (table_name, record_id, old_values, new_values, operation_type)
    VALUES (
      'Table',
      NEW.id,
      JSON_OBJECT('metrics', OLD.metrics, 'status', OLD.status),
      JSON_OBJECT('metrics', NEW.metrics, 'status', NEW.status),
      'UPDATE'
    );
  ELSE
    INSERT INTO audit_log (table_name, record_id, new_values, operation_type)
    VALUES (
      'Table',
      NEW.id,
      JSON_OBJECT('metrics', NEW.metrics, 'status', NEW.status),
      'CREATE'
    );
  END IF;
END //
DELIMITER ;

3. 循环执行Upsert（适合小数据量） #

放弃bulkCreate，循环对每条数据执行upsert（findOne+update或直接用Model.upsert）。这种方式会触发afterUpdate和afterCreate钩子，能直接获取_previousDataValues，但性能较差，仅适合数据量较小的场景。

示例代码：

for (const item of params) {
  const [instance, created] = await Table.upsert(item, {
    updateOnDuplicate: ["metrics", "status"],
    individualHooks: true // 确保触发钩子
  });
  if (!created) {
    // 从instance中获取新旧值
    const oldValues = instance._previousDataValues;
    const newValues = instance.dataValues;
    await createAuditLog(oldValues, newValues, 'UPDATE');
  } else {
    await createAuditLog(null, instance.dataValues, 'CREATE');
  }
}

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