PHP中更新MySQL表并存储受影响行order_id的实现方法

嘿，我来帮你搞定这个问题！你需要同时完成两个任务：更新符合条件的记录，还要把这些记录的order_id存进数组对吧？下面给你两种靠谱的实现方式，都是PHP里常用的做法：

方法一：先查询获取ID，再执行更新（适合需要先拿ID做前置操作的场景） #

这种方式先把所有order_status = 'S'的order_id捞出来存数组，再批量更新对应的记录。好处是你可以在更新前用这些ID做其他操作，而且兼容性好，不管什么MySQL版本都能用。

用PDO实现的示例代码（PDO比mysqli更安全灵活，优先推荐）：

// 假设你已经通过PDO建立了数据库连接，连接对象为$pdo
$orderIds = [];

// 第一步：查询所有符合条件的order_id
$selectQuery = "SELECT order_id FROM your_table_name WHERE order_status = 'S'";
$stmt = $pdo->prepare($selectQuery);
$stmt->execute();

// 循环结果集，把ID存入数组
while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    $orderIds[] = $row['order_id'];
}

// 第二步：如果数组不为空，执行更新操作
if (!empty($orderIds)) {
    // 生成IN子句的占位符，避免SQL注入
    $placeholders = implode(',', array_fill(0, count($orderIds), '?'));
    $updateQuery = "UPDATE your_table_name 
                    SET is_placement = 1, date_updated = CURDATE() 
                    WHERE order_id IN ($placeholders)";
    
    $updateStmt = $pdo->prepare($updateQuery);
    $updateStmt->execute($orderIds);
    
    echo "成功更新了 " . $updateStmt->rowCount() . " 条记录";
}

如果担心查询和更新之间，有其他操作修改了order_status导致数据不一致，可以用事务包裹整个流程：

try {
    $pdo->beginTransaction();
    
    // 上面的查询ID代码
    // 上面的更新代码
    
    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
    echo "操作失败：" . $e->getMessage();
}

方法二：先执行更新，再获取被更新的ID（高效版，MySQL 8.0+适用） #

如果你的MySQL版本是8.0及以上，可以用RETURNING子句，在更新语句执行后直接返回被修改的order_id，一步到位，少一次数据库查询，效率更高：

$updateQuery = "UPDATE your_table_name 
                SET is_placement = 1, date_updated = CURDATE() 
                WHERE order_status = 'S'
                RETURNING order_id";
$stmt = $pdo->prepare($updateQuery);
$stmt->execute();

// 直接获取所有被更新的order_id，存进数组
$orderIds = $stmt->fetchAll(PDO::FETCH_COLUMN, 0);

echo "成功更新了 " . count($orderIds) . " 条记录，对应的ID列表：" . implode(',', $orderIds);

如果你用的是mysqli（兼容旧项目） #

如果你的项目还在使用mysqli，也可以这么写：

// 假设已经建立mysqli连接，连接对象为$conn
$orderIds = [];

// 查询ID
$selectQuery = "SELECT order_id FROM your_table_name WHERE order_status = 'S'";
$result = $conn->query($selectQuery);
while ($row = $result->fetch_assoc()) {
    $orderIds[] = $row['order_id'];
}

// 执行更新
if (!empty($orderIds)) {
    // 对每个ID做转义，防止SQL注入
    $escapedIds = array_map(function($id) use ($conn) {
        return $conn->real_escape_string($id);
    }, $orderIds);
    $placeholders = implode(',', $escapedIds);
    
    $updateQuery = "UPDATE your_table_name 
                    SET is_placement = 1, date_updated = CURDATE() 
                    WHERE order_id IN ($placeholders)";
    
    $conn->query($updateQuery);
    echo "成功更新了 " . $conn->affected_rows . " 条记录";
}

最后提醒下：不管用哪种方式，都要注意防止SQL注入，PDO的参数绑定或者mysqli的转义都是必须的，别直接把ID拼进SQL语句里哦！

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