PHP实现MySQL与API数据同步：解决不存在数据误删问题

问题根源 #

你当前的删除逻辑完全走偏了！每次循环执行DELETE FROM basket WHERE fruitId NOT IN ('$fruitId')会导致：

• 第一次循环时，删掉所有不是当前ID的数据，只留下当前这条记录
• 第二次循环又会删掉所有不是第二个ID的数据，把上一次留下的那条也删了
• 循环到最后，数据库要么只剩最后一个ID，要么直接空掉——这就是你看到所有数据被删除的核心原因。

正确的删除逻辑 #

你需要先把API返回的所有fruitId收集成一个完整的集合，然后一次性删除不在这个集合里的数据，而不是循环逐条执行删除操作。

修复后的完整代码 #

<?php 
include 'import.php'; // 从API导入数据
include 'connect.php'; // 连接数据库

// 1. 收集所有API返回的有效fruitId，同时做防注入处理
$validFruitIds = [];
foreach ($query as $val) {
    // 转义特殊字符，避免SQL注入风险
    $validFruitIds[] = $conn->real_escape_string($val['fruitId']);
}

// 2. 批量新增/更新数据（用预处理语句更安全高效）
$stmt = $conn->prepare("INSERT INTO basket (fruitId) VALUES (?) ON DUPLICATE KEY UPDATE fruitId = ?");
// 假设fruitId是字符串类型，若为数字则把参数类型改成"ii"
$stmt->bind_param("ss", $fruitId, $fruitId);

foreach ($query as $val) {
    $fruitId = $val['fruitId'];
    if ($stmt->execute()) {
        echo "ID {$fruitId} 已添加/更新<br>";
    } else {
        echo "更新ID {$fruitId} 时出错: " . $stmt->error . "<br>";
    }
}
$stmt->close();

// 3. 一次性清理失效数据
if (!empty($validFruitIds)) {
    $idList = "'" . implode("','", $validFruitIds) . "'";
    $sql = "DELETE FROM basket WHERE fruitId NOT IN ($idList)";
    if ($conn->query($sql) === TRUE) {
        echo "已清理所有失效ID<br>";
    } else {
        echo "删除失效ID时出错: " . $conn->error . "<br>";
    }
} else {
    // 特殊情况：API未返回任何数据，可根据需求决定是否清空数据库
    echo "API未返回活跃数据，未执行删除操作<br>";
    // 若需要清空数据库，取消下面注释：
    // $conn->query("DELETE FROM basket");
}

$conn->close();
?>

关键改进点 #

• 删除逻辑修正：先收集所有有效ID，再一次性删除不在集合中的数据，彻底避免循环误删
• SQL注入防护：用mysqli_real_escape_string转义ID，或是用预处理语句（更推荐后者），防止恶意输入破坏数据库
• 性能优化：插入/更新用预处理语句，避免重复编译SQL，提升批量操作的效率
• 边界处理：考虑API返回空数据的情况，避免误删所有数据（可根据业务需求调整）

更简洁的进阶实现（可选） #

如果你的MySQL版本支持事务，可以用事务包裹所有操作，保证数据一致性：

1. 开启事务
2. 执行所有插入/更新操作
3. 执行删除操作
4. 所有操作成功则提交事务，否则回滚

这样能避免出现部分更新成功、部分失败的混乱状态。

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