GoLang Gorm框架Upsert查询中Where条件不生效问题排查

问题现象 #

在Go语言环境使用Gorm框架开发Upsert逻辑时，为clause.OnConflict配置的Where过滤条件未被拼接到最终生成的MySQL查询语句中，id触发唯一键冲突时会直接更新指定字段，不符合「仅当表中原有记录的timestamp字段值小于当前时间戳时才执行更新」的业务要求。

问题复现代码 #

onConflict := clause.OnConflict{
        Where:     clause.Where{Exprs: []clause.Expression{clause.Lte{Column: "timestamp", Value: time.Now()}}},
        DoUpdates: clause.AssignmentColumns([]string{"first_name", "last_name", "timestamp", "updated_at"}),
    }
insert := gormSQLDB.Clauses(onConflict).Create(&Users)

实际生成的SQL #

INSERT INTO `users` (`first_name`,`last_name`,`timestamp`,`updated_at`,`id`) VALUES ('Ram','Kumar','2022-05-03 03:59:16','2022-06-07 14:45:22.631','5befa85e-e642-11ec-89a5-acde48001122') ON DUPLICATE KEY UPDATE `first_name`=VALUES(`first_name`),`last_name`=VALUES(`last_name`),`timestamp`=VALUES(`timestamp`),`updated_at`=VALUES(`updated_at`)

问题根因 #

• 语法适配差异：clause.OnConflict结构体的Where字段，仅针对PostgreSQL、SQLite等原生支持ON CONFLICT ... DO UPDATE WHERE语法的数据库设计。MySQL的ON DUPLICATE KEY UPDATE语法本身不支持在更新子句后直接追加全局Where条件做整行更新判断，因此Gorm的MySQL驱动会直接忽略OnConflict层级配置的Where参数，这是条件未出现在最终SQL里的核心原因。
• 赋值方法限制：你使用的clause.AssignmentColumns是全量直接赋值的简化写法，本身不支持单字段级别的条件判断逻辑，无法实现带过滤的更新需求。

MySQL环境下的正确实现方案 #

不要在OnConflict层级配置无效的Where条件，改用clause.Set自定义每个字段的赋值逻辑，借助MySQL的IF函数在赋值时做条件判断，满足timestamp比较要求时才更新为新值，否则保留原有字段值，最终效果和预期的Where过滤逻辑完全一致：

currentTime := time.Now()
onConflict := clause.OnConflict{
    DoUpdates: clause.Set{
        {
            Column: clause.Column{Name: "first_name"},
            Value:  clause.Expr{SQL: "IF(users.timestamp <= ?, VALUES(first_name), first_name)", Vars: []any{currentTime}},
        },
        {
            Column: clause.Column{Name: "last_name"},
            Value:  clause.Expr{SQL: "IF(users.timestamp <= ?, VALUES(last_name), last_name)", Vars: []any{currentTime}},
        },
        {
            Column: clause.Column{Name: "timestamp"},
            Value:  clause.Expr{SQL: "IF(users.timestamp <= ?, VALUES(timestamp), timestamp)", Vars: []any{currentTime}},
        },
        {
            Column: clause.Column{Name: "updated_at"},
            Value:  clause.Expr{SQL: "IF(users.timestamp <= ?, VALUES(updated_at), updated_at)", Vars: []any{currentTime}},
        },
    },
}
// 执行Upsert
err := gormSQLDB.Clauses(onConflict).Create(&Users).Error

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