Gorm批量Upsert关联重复报错：cannot affect row a second time

问题原因 #

你遇到的ERROR: ON CONFLICT DO UPDATE command cannot affect row a second time错误，核心原因是同一批次INSERT语句中包含了多条相同URN的Resource记录。PostgreSQL规定，同一冲突行在单次INSERT的ON CONFLICT逻辑中只能被更新一次，多次触发同一行的冲突更新就会触发这个错误。

解决方案（Gorm v1.24.3适用） #

要解决这个问题，需要先对要插入的Resource进行去重，确保每个唯一的URN只被处理一次，再关联到对应的Access记录中执行批量操作，具体步骤如下：

1. 提取并去重Resource的URN
   从待插入的Access列表中，把所有Resource的URN提取出来，通过哈希表去重，得到唯一的Resource集合。

2. 批量Upsert去重后的Resource
   对去重后的Resource执行Upsert，获取每个Resource的ID（如果是已存在的记录，会返回原有ID；新记录则生成新ID）。

3. 关联Resource到Access
   建立URN到Resource实例的映射，把原Access列表中的Resource替换为去重后的实例，确保所有关联相同URN的Access都指向同一个Resource对象。

4. 批量插入Access
   最后执行Access的批量Upsert操作。

完整代码示例：

// 1. 提取并去重URN
urnMap := make(map[string]bool)
var uniqueResources []*Resource
for _, access := range data {
    urn := access.Resource.URN
    if !urnMap[urn] {
        urnMap[urn] = true
        uniqueResources = append(uniqueResources, access.Resource)
    }
}

// 2. 批量Upsert去重后的Resource，指定冲突列为URN，更新updated_at
err := db.Clauses(clause.OnConflict{
    Columns: []clause.Column{{Name: "urn"}},
    DoUpdates: clause.Assignments(map[string]interface{}{
        "updated_at": clause.CurrentTimestamp,
    }),
}).Create(&uniqueResources).Error
if err != nil {
    // 处理错误逻辑
    panic(err)
}

// 3. 构建URN到Resource的映射
urnToResource := make(map[string]*Resource)
for _, res := range uniqueResources {
    urnToResource[res.URN] = res
}

// 4. 更新原Access列表中的Resource引用
for _, access := range data {
    access.Resource = urnToResource[access.Resource.URN]
}

// 5. 批量Upsert Access
err = db.Clauses(clause.OnConflict{UpdateAll: true}).Create(data).Error
if err != nil {
    // 处理错误逻辑
    panic(err)
}

补充说明 #

• 如果你不需要更新Resource的updated_at，可以把DoUpdates部分去掉，改用DoNothing，但这样只会返回已存在的Resource ID，不会更新字段。
• Access的Upsert逻辑可以根据你的业务需求调整OnConflict的规则，比如指定冲突列（如user和resource_id的组合）来避免重复插入Access记录。

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