如何在Sequelize（PostgreSQL）中更新带外键关联的记录及子记录

需求明确 #

• 仅传入部分items值时，移除未传入的其他items关联记录
• 编辑部分items值时，返回已编辑的items值
• 新增items值时，返回原items值与新增值

示例场景与代码实现 #

初始数据示例 #

const record = {
  id: 1,
  name: "abc",
  items: [
    {id: 1, name: "abc", recordId: 1},
    {id: 2, name: "abcd", recordId: 1}
  ]
};

核心实现逻辑 #

ORM默认的update方法无法直接满足这类关联数据的复杂更新需求，需要拆分步骤处理：

1. 清理未传入的关联项：对比传入的items与数据库现有数据，删除未被传入的items记录
2. 区分更新与新增操作：遍历传入的items，根据是否存在ID判断是更新已有项还是新增新项
3. 按需求组装返回结果：根据操作类型（删除/更新/新增），返回对应的数据

以Sequelize为例的实现代码：

// 1. 获取原记录及关联的items
const originalRecord = await dbRecord.findByPk(req.params.id, { include: ['items'] });
const originalItems = originalRecord.items;
const incomingItems = req.body.items || [];

// 2. 删除未传入的items
const incomingItemIds = incomingItems.map(item => item.id).filter(Boolean);
const deleteIds = originalItems.filter(item => !incomingItemIds.includes(item.id)).map(item => item.id);
if (deleteIds.length) {
  await dbItem.destroy({ where: { id: deleteIds } });
}

// 3. 处理更新与新增，收集结果
const updatedItems = [];
const newItems = [];

for (const item of incomingItems) {
  if (item.id) {
    // 更新已有item
    const [_, [updatedItem]] = await dbItem.update(item, { 
      where: { id: item.id }, 
      returning: true 
    });
    updatedItems.push(updatedItem);
  } else {
    // 新增关联item
    const newItem = await dbItem.create({ ...item, recordId: req.params.id });
    newItems.push(newItem);
  }
}

// 4. 更新主记录
await dbRecord.update({ name: req.body.name }, { where: { id: req.params.id } });

// 5. 按需求返回对应结果
const response = {};
// 若有更新，返回已编辑的items
if (updatedItems.length) {
  response.updatedItems = updatedItems;
}
// 若有新增，返回原items与新增值
if (newItems.length) {
  response.originalItems = originalItems;
  response.newItems = newItems;
}
// 若有删除，返回更新后的完整记录（已移除未传入的items）
if (deleteIds.length) {
  response.updatedRecord = await dbRecord.findByPk(req.params.id, { include: ['items'] });
}

res.json(response);

关键细节 #

• 用returning: true确保ORM返回更新后的完整记录
• 先执行删除操作再处理更新/新增，避免数据不一致
• 按需返回结果，严格匹配三种需求场景

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