PHP如何将数据库查询的关联数组赋值变量后循环插入另一表并删除原数据

错误原因梳理 #

• foreach遍历参数顺序错误：foreach($row as $product_details=>$key) 写反了键和值的顺序，导致无法读取到正确的商品属性
• 字段赋值错误：
  • 分类字段错误赋值为商品名：$category=$product_details['pname'] 应该读取pcategory字段
  • 库存字段键名错误：数组对应字段是pstock，你写成了不存在的stock
  • 采购价变量未定义：绑定参数用到的$productprice没有从数组中赋值，实际应该读取purchaseprice字段
• 缺失插入执行逻辑：PDO预处理绑定参数后必须调用execute()才能实际执行写入操作
• 重复创建预处理语句：插入SQL结构固定，放在循环外预编译一次即可，不需要每次循环重新prepare

修正后完整代码 #

if(isset($_POST['btnaddproduct'])){
    try {
        // 开启事务，保证数据一致性
        $pdo->beginTransaction();

        // 读取待处理的pending数据
        $select = $pdo->prepare("select * from tbl_pending");
        $select->execute();
        $pendingList = $select->fetchAll(PDO::FETCH_ASSOC);

        if (empty($pendingList)) {
            throw new Exception("没有待导入的商品数据");
        }

        // 预编译插入语句，循环外只执行一次，性能更高
        $insert = $pdo->prepare("insert into tbl_product(pname,pcategory,purchaseprice,pstock,pdescription,pimage) values(:pname,:pcategory,:purchaseprice,:pstock,:pdescription,:pimage)");

        // 收集所有待删除的pid，用于后续批量删除
        $pendingPids = [];

        foreach($pendingList as $product) {
            // 正确赋值所有字段
            $productname = $product['pname'];
            $category = $product['pcategory'];
            $productprice = $product['purchaseprice'];
            $stock = $product['pstock'];
            $description = $product['pdescription'];
            $productimage = $product['pimage'];

            // 绑定参数并执行插入
            $insert->bindParam(':pname',$productname); 
            $insert->bindParam(':pcategory',$category);
            $insert->bindParam(':purchaseprice',$productprice);
            $insert->bindParam(':pstock',$stock);
            $insert->bindParam(':pdescription',$description);
            $insert->bindParam(':pimage',$productimage);
            $insert->execute();

            // 记录已处理的pid
            $pendingPids[] = $product['pid'];
        }

        // 所有插入成功后，批量删除已处理的pending记录
        $pidsPlaceholders = rtrim(str_repeat('?,', count($pendingPids)), ',');
        $delete = $pdo->prepare("DELETE FROM tbl_pending WHERE pid IN ($pidsPlaceholders)");
        $delete->execute($pendingPids);

        // 提交事务，所有操作生效
        $pdo->commit();
        echo "所有商品导入成功，待处理数据已清空";
    } catch (Exception $e) {
        // 出错回滚事务，不会残留半完成的数据
        $pdo->rollBack();
        echo "导入失败：" . $e->getMessage();
    }
}

逻辑说明 #

1. 用事务包裹整个操作，只要中间任意一步出错都会回滚，不会出现部分插入、部分删除的脏数据问题
2. 插入预处理语句放在循环外只编译一次，比循环内重复prepare性能提升明显
3. 收集所有已处理的pid后用IN语句批量删除，比循环单次删除效率更高

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