MySQL如何获取INSERT...SELECT ON DUPLICATE KEY UPDATE影响的所有user_id

PDO::lastInsertId() 本身仅能返回最后一次插入操作生成的自增ID，MySQL原生没有提供直接返回批量INSERT ... ON DUPLICATE KEY UPDATE所有受影响行ID的接口，可通过以下两种方案实现需求：

方案1：批次标记法（兼容性最好，无版本限制，推荐） #

核心逻辑是给本次操作的所有待处理数据打唯一标识，执行完写入操作后通过标识反查所有关联ID，步骤如下：

• 给import_user源表、user目标表各加一个可空的batch_no字段，类型用varchar(32)即可，用来存储批次标识
• 执行写入操作前，先生成本次操作唯一的批次号（比如时间戳+随机数组合），先把待导入的符合条件的源数据全部更新上这个批次号
• 调整原INSERT语句，把batch_no字段加入写入列，ON DUPLICATE KEY UPDATE段也同步更新batch_no字段值
• 写入语句执行完成后，直接按批次号查询user表，就能取出本次所有新增、更新记录的user_id，组装成目标数组即可

参考实现代码：

// 生成本次操作唯一批次号
$batchNo = time() . mt_rand(1000, 9999);

// 给本次要处理的源数据打批次标记
$markStmt = $pdo->prepare("UPDATE import_user SET batch_no = ? WHERE name <> '' AND mobile <> ''");
$markStmt->execute([$batchNo]);

// 调整原写入SQL，同步写入批次号
$sql = "INSERT INTO user ( name
                         , mobile
                         , email
                         , sex
                         , username
                         , password
                         , batch_no
                         )
          SELECT u.name
               , u.mobile
               , u.email
               , u.sex
               , u.username
               , u.password
               , u.batch_no
          FROM import_user u 
          WHERE u.batch_no = ?
        ON DUPLICATE KEY UPDATE
              user_id     = LAST_INSERT_ID(user_id),
              name        = VALUES(name),
              mobile      = VALUES(mobile),
              email       = VALUES(email),
              sex         = VALUES(sex),
              batch_no    = VALUES(batch_no)";
$writeStmt = $pdo->prepare($sql);
$writeStmt->execute([$batchNo]);

// 直接查询本次批次关联的所有user_id
$uids = $pdo->query("SELECT user_id FROM user WHERE batch_no = '{$batchNo}'")->fetchAll(PDO::FETCH_COLUMN);

如果不需要长期保留批次标记，后续可以定期清理batch_no字段的历史值，不影响原有业务逻辑。

方案2：自增序列推算（仅适合特定场景，不推荐） #

如果你的MySQL版本 ≥ 8.0.20，且能保证写入时没有其他并发插入操作、本次操作全为新增记录无更新，可以通过自增ID连续性推算：

• 执行写入后通过$pdo->lastInsertId()拿到本次操作生成的第一个自增ID
• 通过$stmt->rowCount()拿到本次新增的总记录数
• 所有ID范围为[lastInsertId, lastInsertId + 新增记录数 - 1]，直接生成连续数组即可

注意：这个方案局限性极强，只要存在更新记录、并发写入、自增ID手动修改过的情况，结果就会完全错误，存在更新逻辑的场景不要用这个方法。

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