时间戳

首页 > 解决方案 > PHP/MySQL - 如果查询失败，如何删除插入？

php - PHP/MySQL - 如果查询失败，如何删除插入？

问题描述

我有这个代码

<?php
class Objekt{
// database connection and table name
private $conn;
private $table_name = "objects";
// object properties
public $id;
public $id_group;
public $title;
public $description;
public $lat;
public $lng;
public $icon;
public $tagsraw;
// constructor with $db as database connection
public function __construct($db){
    $this->conn = $db;
}

function create(){
    // query to insert record
    $query = "INSERT INTO
                " . $this->table_name . "
            SET
                id_group=:id_group, title=:title, description=:description, lat=:lat, lng=:lng, icon=:icon;
            SELECT max(id) AS id FROM objects;";
    // prepare query
    $stmt = $this->conn->prepare($query);
    // sanitize
    $this->id_group=htmlspecialchars(strip_tags($this->id_group));
    $this->title=htmlspecialchars(strip_tags($this->title));
    $this->description=htmlspecialchars(strip_tags($this->description));
    $this->lat=htmlspecialchars(strip_tags($this->lat));
    $this->lng=htmlspecialchars(strip_tags($this->lng));
    $this->icon=htmlspecialchars(strip_tags($this->icon));     
    // bind values
    $stmt->bindParam(":id_group", $this->id_group);
    $stmt->bindParam(":title", $this->title);
    $stmt->bindParam(":description", $this->description);
    $stmt->bindParam(":lat", $this->lat);
    $stmt->bindParam(":lng", $this->lng);
    $stmt->bindParam(":icon", $this->icon);

    // execute query
    if($stmt->execute()){
               
        //$stmt->execute();
    
/* 
      ERROR below here
      Uncaught PDOException: SQLSTATE[HY000]: General error
      stack trace:
      #0 PDOStatement -&gt;fetch(2)
      #1 Objekt-&gt;create()
*/

        $result = $stmt->fetch(PDO::FETCH_ASSOC);
        $this->id = $result['id'];
        echo "$this->id";
                    
        //get tags matches
        $tags = [];
        $this->tagsraw = preg_replace('/\s+/', '', $this->tagsraw);
        $tags = explode(',', $this->tagsraw);
        
        $id_tags = [];
        for ($i = 0; $i < sizeof($tags); $i++) {
            $query = "SELECT id FROM category WHERE title=" . tags[i];
            
            $stmt = $this->conn->prepare($query);
            
            $stmt->execute();
            
            $result = $stmt->fetch(PDO::FETCH_OBJ);
            $id_tags[i] = $result->id;
        }
        
        for ($i = 0; $i < sizeof($id_tags); $i++) {            
            $query = "INSERT INTO category_object SET id_object=" . $this->id . ", id_category=" . $id_tags[i];
            
            $stmt = $this->conn->prepare($query);
            
            $stmt->execute();
            
        }
        
        return true;
    }
    return false;
}

我想做的事：

插入对象并通过外键 id_object / id_category 创建与 category_object 表的关系

我想改进的地方：

如果插入失败，我该怎么做才能删除插入（我应该在哪里放置 try/catch 或其他东西）

我的获取有什么问题？我从 max(id) 中选择值来获取我插入的对象的值，为什么它会抛出异常

我有另一个警告为什么它告诉我

for ($i = 0; $i < sizeof($id_tags); $i++) {            
        $query = "INSERT INTO category_object SET id_object=" . $this->id . ", id_category=" . $id_tags[i];

        $stmt = $this->conn->prepare($query);

        $stmt->execute();

    }

将在未来的 php 版本中弃用..

标签： phpmysqlrest

解决方案

使用交易。

在您调用之前，事务中完成的任何插入/更新/删除操作都不会对数据库实际执行commit()，并且您始终可以回滚更改，在失败时放弃它们。

在您的代码中，您应该可以替换if($stmt->execute()){为

try {
    $this->conn->beginTransaction();
    $stmt->execute();

    // ...everything else from inside the if statement here...

    $this->conn->commit();
    return true;
} catch (\Exception $e) {
    $this->conn->rollback();
    return false;
}

推荐阅读