CakePHP3如何批量保存或更新记录（存在则更新，不存在则插入）

你碰到的重复键错误是因为saveMany()默认会执行纯插入操作，当主键id已经存在时就会触发MySQL的重复键冲突。要实现「存在则更新，不存在则插入」的Upsert逻辑，这里有两种靠谱的实现方式：

方法一：用Query Epilog 配合 ON DUPLICATE KEY UPDATE #

这就是你提到的思路，具体代码实现如下：

1. 构建批量插入查询 #

先创建一个插入查询，把你的$records数组作为数据源，然后通过epilog()方法追加MySQL的Upsert语句：

// 初始化查询
$query = $this->MyModel->query();

// 配置插入字段和数据，追加ON DUPLICATE KEY UPDATE逻辑
$query->insert(['id', 'data'])
    ->values($records)
    ->epilog('ON DUPLICATE KEY UPDATE data = VALUES(data)');

// 执行查询
$result = $query->execute();

关键说明：

• 必须保证id字段是表的主键或者唯一索引，这样MySQL才能检测到重复的键值
• VALUES(data)表示用当前插入行的data值去更新已存在的记录，如果需要更新多个字段，直接追加即可：data = VALUES(data), other_col = VALUES(other_col)

2. 处理执行结果 #

调用execute()后会返回一个StatementInterface对象，你可以通过rowCount()获取受影响的总行数（包含插入和更新的记录）：

$affectedRows = $result->rowCount();

方法二：使用CakePHP3.6+ 内置的upsert()方法（更简洁） #

如果你的项目用的是CakePHP3.6及以上版本，直接用框架封装好的upsert()方法更省心，不用自己写原生SQL片段：

$this->MyModel->upsert($records, ['id'], ['data']);

参数解释：

• 第一个参数$records：就是你要批量处理的记录数组
• 第二个参数$constraints：用于判断记录是否存在的字段（这里是主键id，也可以是其他唯一索引字段）
• 第三个参数$updateFields：当记录存在时需要更新的字段列表

这个方法会自动生成带ON DUPLICATE KEY UPDATE的SQL，既安全又符合CakePHP的ORM使用习惯。

注意事项 #

• 两种方法都依赖表结构中存在主键/唯一索引，否则MySQL无法识别重复记录
• 批量操作比循环调用单条save()效率高得多，适合处理大量数据
• 如果需要复杂的更新逻辑（比如字段值累加、字符串拼接），可以在epilog里写自定义SQL，比如：data = CONCAT(data, '_updated')

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