如何修改MySQLi插入代码实现ID存在时更新数据？

嘿，要搞定你这个需求，最靠谱高效的方式是利用MySQL原生的INSERT ... ON DUPLICATE KEY UPDATE语法（也就是常说的UPSERT操作），比先查库再判断执行插入/更新要稳妥得多——不仅能减少一次数据库查询的开销，还能避免高并发场景下的主键冲突问题。

第一步：改造你的INSERT查询语句 #

首先，你得把原来的INSERT语句改成带ON DUPLICATE KEY UPDATE的版本，前提是你的表中id字段是主键或者唯一索引，这样MySQL才能识别出重复的记录。

假设你原来的INSERT语句是这样的：

$query = "INSERT INTO your_table (id, name) VALUES ('$id', '$name')";

直接改成下面这样：

$query = "INSERT INTO your_table (id, name) VALUES ('$id', '$name') ON DUPLICATE KEY UPDATE name = VALUES(name)";

👉 解释：当数据库中已经存在对应id的记录时，MySQL会自动执行UPDATE操作，把name字段更新为这次插入的值（VALUES(name)指代INSERT语句中对应字段的传入值）。如果需要更新多个字段，直接用逗号分隔就行，比如col1 = VALUES(col1), col2 = VALUES(col2)。

第二步：调整代码逻辑，区分插入/更新/错误 #

接下来，修改你的IF-ELSE逻辑，利用mysqli->affected_rows来判断当前操作是插入了新记录、更新了现有记录，还是触发了错误：

// 保留你原来的变量声明
$success = $fail = ""; 
$success_count = $fail_count = 0;
// 新增两个变量，方便统计插入/更新的具体数量（可选）
$inserted_count = 0;
$updated_count = 0;

// 循环中处理每一行的逻辑（保留你原来的ID/NAME赋值）
$id = isset($Row[0]) ? $Row[0] : ''; 
$name = isset($Row[1]) ? $Row[1] : '';

// 构建UPSERT查询（先按你原来的拼接方式，后面会说安全问题）
$query = "INSERT INTO your_table (id, name) VALUES ('$id', '$name') ON DUPLICATE KEY UPDATE name = VALUES(name)";

if ($mysqli->query($query)) {
    // 根据受影响行数判断操作类型
    switch($mysqli->affected_rows) {
        case 1:
            // 成功插入一条新记录
            $success .= "<li>✅ 已插入：" . $name . "</li>";
            $inserted_count++;
            break;
        case 2:
            // 成功更新一条现有记录（MySQL对ON DUPLICATE KEY UPDATE的更新操作会返回2）
            $success .= "<li>🔄 已更新：" . $name . "</li>";
            $updated_count++;
            break;
        case 0:
            // 记录存在，但传入的值和现有值完全一致，不需要更新
            $success .= "<li>ℹ️ 无变化：" . $name . "</li>";
            break;
    }
    $success_count++; // 不管是插入/更新/无变化，都算成功
} else {
    // 这里才是真正的错误（比如语法错误、权限不足、非主键重复等）
    $fail .= "<li>❌ " . $name . "<br>错误信息：" . $mysqli->error . "</li>";
    $fail_count++;
}

关键提醒：一定要防止SQL注入！ #

你当前直接把$id和$name拼进SQL语句的写法，存在严重的SQL注入风险，很容易被攻击。强烈推荐使用**预处理语句（Prepared Statements）**来替代，这是PHP操作数据库的最佳实践：

// 预处理UPSERT语句（用?作为占位符）
$stmt = $mysqli->prepare("INSERT INTO your_table (id, name) VALUES (?, ?) ON DUPLICATE KEY UPDATE name = VALUES(name)");
// 绑定参数：第一个参数是类型标识（i=整数，s=字符串，根据你的字段类型调整），后面是对应变量
$stmt->bind_param("is", $id, $name);

if ($stmt->execute()) {
    // 同样判断操作类型
    switch($stmt->affected_rows) {
        case 1:
            $success .= "<li>✅ 已插入：" . $name . "</li>";
            $inserted_count++;
            break;
        case 2:
            $success .= "<li>🔄 已更新：" . $name . "</li>";
            $updated_count++;
            break;
        case 0:
            $success .= "<li>ℹ️ 无变化：" . $name . "</li>";
            break;
    }
    $success_count++;
} else {
    $fail .= "<li>❌ " . $name . "<br>错误信息：" . $stmt->error . "</li>";
    $fail_count++;
}
// 记得关闭语句释放资源
$stmt->close();

替代方案：先查询再执行插入/更新（不推荐） #

如果你因为某些限制不能用ON DUPLICATE KEY UPDATE，也可以先查询是否存在该ID，再执行插入或更新，但这种方式在高并发场景下可能出现主键冲突（比如两个请求同时查询到ID不存在，然后都执行插入），所以只作为备选：

// 先检查ID是否存在
$checkStmt = $mysqli->prepare("SELECT id FROM your_table WHERE id = ?");
$checkStmt->bind_param("i", $id);
$checkStmt->execute();
$checkStmt->store_result(); // 存储结果集，方便判断行数

if ($checkStmt->num_rows > 0) {
    // ID存在，执行更新
    $updateStmt = $mysqli->prepare("UPDATE your_table SET name = ? WHERE id = ?");
    $updateStmt->bind_param("si", $name, $id);
    if ($updateStmt->execute()) {
        $success .= "<li>🔄 已更新：" . $name . "</li>";
        $success_count++;
    } else {
        $fail .= "<li>❌ " . $name . "<br>更新错误：" . $updateStmt->error . "</li>";
        $fail_count++;
    }
    $updateStmt->close();
} else {
    // ID不存在，执行插入
    $insertStmt = $mysqli->prepare("INSERT INTO your_table (id, name) VALUES (?, ?)");
    $insertStmt->bind_param("is", $id, $name);
    if ($insertStmt->execute()) {
        $success .= "<li>✅ 已插入：" . $name . "</li>";
        $success_count++;
    } else {
        $fail .= "<li>❌ " . $name . "<br>插入错误：" . $insertStmt->error . "</li>";
        $fail_count++;
    }
    $insertStmt->close();
}
$checkStmt->close();

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