PHP中精确更新数据库中数组表示的记录：基于唯一ID的策略-php教程-PHP中文网

PHP中精确更新数据库中数组表示的记录：基于唯一ID的策略

本教程详细阐述了在php中如何通过利用数据库记录的唯一id，实现对数组形式数据（如订单关联地址）的精确更新。针对传统方法可能导致批量更新而非单条更新的问题，本文提供了一种改进方案，通过传递包含记录id的数据结构，结合预处理语句，确保每次更新操作只针对目标记录，从而提升数据操作的准确性和灵活性。

在开发基于PHP的数据库应用时，经常会遇到需要更新与主记录关联的子记录集合（例如，一个订单下的多个地址）的场景。这些子记录通常以数组的形式在应用层进行处理。然而，如果更新逻辑不当，可能会导致意外地批量修改所有符合特定条件的记录，而非仅更新目标记录。本教程将深入探讨如何通过引入唯一标识符（ID）来精确更新数据库中数组表示的数据。

传统更新方法的局限性

考虑一个常见的场景：一个订单（suppliersOrders）关联了多个地址（suppliersOrdersAddress），地址分为取货地址（addressType = 1）和送货地址（addressType = 2）。如果希望更新某个订单下的某个特定地址，但更新逻辑仅依赖于 orderId 和 addressType，则所有符合这两个条件的地址都将被更新。

以下是原始代码中更新地址部分的示例：

// ... (函数签名及主订单更新部分)

// 更新取货地址
for ($i=0; $i<count($addressPickup); $i++) {
    $address = $addressPickup[$i];
    $type = '1'; // 取货地址类型

    // 问题所在：WHERE子句仅使用 orderId 和 addressType
    $sql2 = "UPDATE suppliersOrdersAddress SET address = ?, operator = ? WHERE orderId = ? AND addressType = ?;";
    $stmt2 = mysqli_stmt_init($conn);
    if (!mysqli_stmt_prepare($stmt2, $sql2)) {
        header ("location: ../suppliersOrders?error=failedupdateaddress");
        exit();
    }
    mysqli_stmt_bind_param($stmt2, "siii", $address, $userid, $orderID, $type);
    mysqli_stmt_execute($stmt2);
    mysqli_stmt_close($stmt2);
}

// 更新送货地址 (逻辑类似)
for ($i=0; $i<count($addressDelivery); $i++) {
    $address = $addressDelivery[$i];
    $type = '2'; // 送货地址类型

    $sql2 = "UPDATE suppliersOrdersAddress SET address = ?, operator = ? WHERE orderId = ? AND addressType = ?;";
    $stmt2 = mysqli_stmt_init($conn);
    if (!mysqli_stmt_prepare($stmt2, $sql2)) {
        header ("location: ../suppliersOrders?error=failedupdateaddress");
        exit();
    }
    mysqli_stmt_bind_param($stmt2, "siii", $address, $userid, $orderID, $type);
    mysqli_stmt_execute($stmt2);
    mysqli_stmt_close($stmt2);
}

// ... (函数结束)

登录后复制

这段代码的缺陷在于，如果一个订单有多个取货地址，或者将来业务需求允许有多个相同类型的地址，那么对 $addressPickup[$i] 的更新将应用到所有 orderId 和 addressType 匹配的记录上，而非仅更新用户期望的那一个。为了实现精确更新，我们需要一个更具体的标识符。

立即学习“PHP免费学习笔记（深入）”；

基于唯一ID的精确更新策略

解决上述问题的关键在于为每个地址记录引入一个唯一的标识符（通常是数据库表的主键 id），并在更新时使用这个 id 作为 WHERE 子句的条件。这意味着在前端收集地址数据时，除了地址内容本身，还需要同时传递对应地址的 id。

假设我们现在从前端接收到的地址数据结构不再是简单的字符串数组，而是包含 id 和 address 的关联数组集合，例如：

$addressPickupData = [
    ['id' => 101, 'address' => '新的取货地址A'],
    ['id' => 102, 'address' => '新的取货地址B']
];

$addressDeliveryData = [
    ['id' => 201, 'address' => '新的送货地址X']
];

登录后复制

基于这种数据结构，我们可以修改 updateSupplierOrder 函数，使其接受这些更详细的地址数据，并利用 id 进行精确更新。

改进后的地址更新逻辑

以下是改进后的 updateSupplierOrder 函数中地址更新部分的示例：

硅基智能

基于Web3.0的元宇宙，去中心化的互联网，高质量、沉浸式元宇宙直播平台，用数字化重新定义直播

查看详情

function updateSupplierOrder($conn, $orderDate, $datePickup, $dateDelivery, $timePickup, $timeDelivery, $car, $carType, $goodsDescription, $paletChange, $paletNo, $supplier, $orderObservation, $paymentDate, $value, array $addressPickupData, array $addressDeliveryData, $userid, $orderID) {

    // ... (主订单 suppliersOrders 的更新逻辑，与原代码相同)
    $sql1 = "UPDATE suppliersOrders SET supplierId = ?, date = ?, datePickup = ?, timePickup = ?, goodsDescription = ?, dateDelivery = ?, timeDelivery = ?, carType = ?, carNo = ?, paletChange = ?, paletNo = ?, value = ?, invoice = ?, observations = ?, operator = ? WHERE id = ?;";
    $stmt1 = mysqli_stmt_init($conn);
    if (!mysqli_stmt_prepare($stmt1, $sql1)) {
        header ("location: ../suppliersOrders?error=failedupdateorder");
        exit();
    }
    mysqli_stmt_bind_param($stmt1, "isssssssisisssii", $supplier, $orderDate, $datePickup, $timePickup, $goodsDescription, $dateDelivery, $timeDelivery, $carType, $car, $paletChange, $paletNo, $value, $paymentDate, $orderObservation, $userid, $orderID);
    mysqli_stmt_execute($stmt1);
    mysqli_stmt_close($stmt1);

    // 遍历并更新取货地址
    foreach ($addressPickupData as $addressItem) {
        $addressId = $addressItem['id'];     // 获取地址记录的唯一ID
        $address = $addressItem['address'];  // 获取更新后的地址内容
        // $type = '1'; // 如果使用id作为唯一标识，addressType在WHERE子句中并非必需，但可作为额外的验证

        // WHERE子句现在使用唯一的 'id'
        $sql2 = "UPDATE suppliersOrdersAddress SET address = ?, operator = ? WHERE id = ?;";
        $stmt2 = mysqli_stmt_init($conn);
        if (!mysqli_stmt_prepare($stmt2, $sql2)) {
            header ("location: ../suppliersOrders?error=failedupdateaddress");
            exit();
        }
        // 绑定参数：s (address), i (operator), i (addressId)
        mysqli_stmt_bind_param($stmt2, "sii", $address, $userid, $addressId);
        mysqli_stmt_execute($stmt2);
        mysqli_stmt_close($stmt2);
    }

    // 遍历并更新送货地址
    foreach ($addressDeliveryData as $addressItem) {
        $addressId = $addressItem['id'];     // 获取地址记录的唯一ID
        $address = $addressItem['address'];  // 获取更新后的地址内容
        // $type = '2'; // 同上，addressType在WHERE子句中并非必需

        // WHERE子句现在使用唯一的 'id'
        $sql2 = "UPDATE suppliersOrdersAddress SET address = ?, operator = ? WHERE id = ?;";
        $stmt2 = mysqli_stmt_init($conn);
        if (!mysqli_stmt_prepare($stmt2, $sql2)) {
            header ("location: ../suppliersOrders?error=failedupdateaddress");
            exit();
        }
        // 绑定参数：s (address), i (operator), i (addressId)
        mysqli_stmt_bind_param($stmt2, "sii", $address, $userid, $addressId);
        mysqli_stmt_execute($stmt2);
        mysqli_stmt_close($stmt2);
    }

    header("location: ../suppliersOrders-edit.php?id=$orderID");
    exit(); // 确保重定向后停止脚本执行
}

登录后复制

代码解析：

函数参数调整： addressPickup 和 addressDelivery 参数被替换为 array $addressPickupData 和 array $addressDeliveryData，明确指出它们是数组，且预期包含更复杂的数据结构。
数据遍历： 使用 foreach 循环遍历包含 id 和 address 的关联数组，使得每次迭代都能获取到单个地址的唯一 id 及其内容。
WHERE 子句优化： UPDATE 语句的 WHERE 子句现在直接使用 id = ? 来精确匹配要更新的地址记录。这确保了每次更新操作都只影响数据库中对应 id 的那一行。
参数绑定： mysqli_stmt_bind_param 的参数类型和数量也相应调整，以匹配新的 WHERE 子句。

注意事项与最佳实践

数据源的可靠性： 确保从前端接收到的地址数据中 id 值是准确且安全的。通常，这些 id 会在页面加载时从数据库中获取并隐藏在表单字段中。
新增与删除操作： 上述示例仅处理了现有地址的更新。在实际应用中，还需要考虑以下情况：
- 新增地址： 如果用户在前端添加了新的地址，这些地址没有 id。在处理时，需要识别出这些新地址并执行 INSERT 操作。
- 删除地址： 如果用户在前端删除了某个地址，则需要根据其 id 在数据库中执行 DELETE 操作。一种常见策略是比较前端传回的 id 列表与数据库中原有的 id 列表，找出差异。

事务管理： 对于涉及多个数据库操作（如更新主订单和多个关联地址）的复杂逻辑，强烈建议使用数据库事务。如果任何一个更新失败，可以回滚所有操作，确保数据的一致性。

// 示例：使用事务
mysqli_autocommit($conn, FALSE); // 关闭自动提交
$success = true;

try {
    // 执行主订单更新
    // ...

    // 执行取货地址更新
    // ...

    // 执行送货地址更新
    // ...

    if ($success) {
        mysqli_commit($conn); // 所有操作成功，提交事务
    } else {
        mysqli_rollback($conn); // 出现错误，回滚事务
    }
} catch (Exception $e) {
    mysqli_rollback($conn); // 捕获异常，回滚事务
    // 记录错误或进行其他处理
} finally {
    mysqli_autocommit($conn, TRUE); // 恢复自动提交
}

登录后复制