购物车开发问题：SESSION商品转存用户数据库（含循环代码）

嘿，我看你正在搞定电商里游客购物车同步到登录用户数据库的逻辑，这个需求太典型了！先帮你梳理下核心逻辑：未登录时把商品存在SESSION临时存储，登录后将这些商品合并到用户专属的数据库购物车——已有的商品更新（比如数量累加），没有的就新增。

先说说你现有代码片段的小问题：你现在是先遍历数据库里的用户商品，再循环SESSION列表，这样容易搞反逻辑，效率也低。咱们应该反过来，以SESSION里的商品为核心，逐个去数据库校验是否存在，再执行新增/更新操作。

下面给你补全并优化后的完整实现代码，和你用的PDO技术栈匹配：

// 假设用户登录后已获取到用户ID，比如 $user_id = $_SESSION['user_id'];
if (!isset($_SESSION['user_id']) || empty($_SESSION['product_checkout_list'])) {
    // 用户未登录 或者 SESSION购物车为空，直接跳过同步
    exit;
}

$user_id = $_SESSION['user_id'];
$core = new Core(); // 假设这是你的核心类，包含日志和数据库连接

try {
    // 开启事务，确保同步操作的原子性
    $core->db->beginTransaction();

    // 遍历SESSION中的购物车商品（这才是正确的遍历顺序）
    foreach ($_SESSION['product_checkout_list'] as $cartItem) {
        $product_id = $cartItem['product_id'];
        $quantity = $cartItem['quantity']; // 假设SESSION里存了商品数量
        $core->testLog("处理SESSION商品: {$product_id}，数量: {$quantity}");

        // 第一步：检查用户数据库中是否已存在该商品
        $checkStmt = $core->db->prepare("SELECT quantity FROM user_cart WHERE user_id = ? AND product_id = ?");
        $checkStmt->execute([$user_id, $product_id]);
        $existingItem = $checkStmt->fetch(PDO::FETCH_ASSOC);

        if ($existingItem) {
            // 商品已存在：更新数量（这里是累加，你也可以替换成覆盖，看业务需求）
            $newQuantity = $existingItem['quantity'] + $quantity;
            $updateStmt = $core->db->prepare("UPDATE user_cart SET quantity = ? WHERE user_id = ? AND product_id = ?");
            $updateStmt->execute([$newQuantity, $user_id, $product_id]);
            $core->testLog("商品 {$product_id} 已存在，更新数量为 {$newQuantity}");
        } else {
            // 商品不存在：插入新记录
            $insertStmt = $core->db->prepare("INSERT INTO user_cart (user_id, product_id, quantity, created_at) VALUES (?, ?, ?, NOW())");
            $insertStmt->execute([$user_id, $product_id, $quantity]);
            $core->testLog("新增商品 {$product_id} 到用户购物车");
        }
    }

    // 提交事务
    $core->db->commit();
    $core->testLog("SESSION购物车同步到数据库完成！");

    // 可选：同步完成后清空SESSION里的临时购物车
    unset($_SESSION['product_checkout_list']);

} catch (PDOException $e) {
    // 出错回滚事务
    $core->db->rollBack();
    $core->testLog("同步失败: " . $e->getMessage());
    // 这里可以根据业务需求抛出错误或者提示用户
}

关键细节说明： #

• 事务处理：用beginTransaction()、commit()、rollBack()确保同步过程中如果某一步出错，所有操作都会回滚，避免数据不一致。
• 预处理语句：全程用PDO预处理，彻底防止SQL注入，这是电商系统的基本安全要求。
• 逻辑顺序：以SESSION商品为核心遍历，而不是数据库商品，这样能保证SESSION里的所有商品都被处理到，不会遗漏。
• 业务灵活性：更新数量的时候用了累加逻辑，你可以根据需求改成直接覆盖SESSION里的数量（比如游客选了3个，登录后数据库里原来有2个，是变成3还是5，看你业务规则）。

对你原有代码的修正建议： #

你原来的while($row = $query->fetch(...))遍历数据库商品的方式，适合把数据库商品同步到SESSION的场景，但咱们现在是反过来，所以一定要调整遍历顺序，不然会出现SESSION里的商品没被全部处理的情况。

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