Вставка данных, когда запись не найдена, иначе обновите предыдущую запись с последним вставленным идентификатором, используя PHP Mysql

Question

У меня есть 2 свойства таблицы как родительская таблица и sale_listings как дочерняя.Я хочу программно вставить или обновить запись списка продаж в таблицу sale_listings, пока вставлены данные таблицы свойств.

Если предыдущая запись найдена в таблице sale_listings, обновить запись или вставить новую запись списка продаж.

Данные обеих таблиц успешно вставлены без проверки предыдущих записей в sale_listing (дочерняя таблица).

Когда я пытаюсь проверить предыдущую запись в sale_listing с использованием rowCount, приложение не влияет ни на одну строку ввсе.

Я хочу знать, как этого добиться с помощью PHP-Mysql?

Ниже приведен исходный код:

//Assign Property Values
$property_type = isset($_POST["property_type"] ) ? $_POST["property_type"]: '';
$agent = isset($_POST["agent"] ) ? $_POST["agent"]: '';
$suburb = isset($_POST["suburb"] ) ? $_POST["suburb"]: '';
$street_no = isset($_POST["street_no"] ) ? $_POST["street_no"]: '';
$street_name = isset($_POST["street_name"] ) ? $_POST["street_name"]: '';
$desc = isset($_POST["desc"] ) ? $_POST["desc"]: '';             
$property_status = isset($_POST["property_status"] ) ? $_POST["property_status"]: '';
$num_bathrooms = isset($_POST["num_bathrooms"] ) ? $_POST["num_bathrooms"]: '';
$num_beds = isset($_POST["num_beds"] ) ? $_POST["num_beds"]: '';
$num_garages = isset($_POST["num_garages"] ) ? $_POST["num_garages"]: '';
$num_lounges = isset($_POST["num_lounges"] ) ? $_POST["num_lounges"]: '';
$air_con = isset($_POST["air_con"] ) ? $_POST["air_con"]: '';
$pool = isset($_POST["pool"] ) ? $_POST["pool"]: '';
$cottage = isset($_POST["cottage"] ) ? $_POST["cottage"]: '';
$price = isset($_POST["price"] ) ? $_POST["price"]: '';

if((!empty($agent)) || (!empty($suburb)) || (!empty($property_type)) || 
  (!empty($street_no)) || (!empty($street_name)) ||(!empty($desc)) || 
  (!empty($property_status)) || (!empty($num_bathrooms)) || 
  (!empty($num_beds)) || (!empty($num_garages)) || (!empty($num_lounges)) || 
  (!empty($air_con)) || (!empty($pool)) || (!empty($cottage)) || 
  (!empty($price))){

    //Insert data into Properties table
    $query = "INSERT INTO properties (agent_id, suburb_id, property_type, 
    property_status, street_no, street_name, property_desc, num_bathrooms, 
    num_beds, num_garages, num_lounges, air_con, pool, cottage, price)
    VALUES('$agent', '$suburb', '$property_type', '$property_status', 
    '$street_no', '$street_name', '$desc', '$num_bathrooms', '$num_beds', 
    '$num_garages', '$num_lounges', '$air_con', '$pool', '$cottage', 
    '$price')";

     $row_count = $this->conn->exec($query);

    //Retrieve the last inserted Property ID
    $last_insert_property_id = $this->conn->lastInsertId(); 

    if($row_count){
        $query = "UPDATE suburbs SET total_properties = total_properties + 1
                  WHERE suburb_id = '$suburb'";
        $row_count = $this->conn->exec($query);

        //Check if the last inserted property ID exists   
        if($last_insert_property_id){

        //If the last property_id exists, make it equal to property ID                                
        $property_id = $last_insert_property_id;

        //Check if previous sale listing exist
        $query_sel = "SELECT sale_listing_id, property_id, 
        sale_listing_amount, discount_percent, total_listing
        FROM sale_listings"; 

        $result = $this->conn->query($query_sel); 

        if($result->rowCount() > 0){
            $query = "UPDATE sale_listings SET total_listing = total_listing + 1             WHERE property_id = '$property_id'";
            $row_count = $this->conn->exec($query);
        }else{
            $sale_amount = 65;
            $discount = 0;
            $total_listing = 1;

            $sql = "INSERT INTO sale_listings (property_id, 
                    sale_listing_amount, discount_percent, total_listing)
                    VALUES('$property_id', '$sale_amount', '$discount', 
                    '$total_listing')";
            $row_count = $this->conn->exec($sql);
            }                           

       }else{
            echo("Unable to insert or update record!"); 
          }
        }

        return $row_count;
    }

Answer 1

Вы пропустили очень важную часть вашего запроса UPDATE, сейчас ваш запрос на обновление обновит все записи в вашей таблице вместо этого, вы должны добавить оператор WHERE, чтобы было только то поле, которое вы хотитеобновляется.Например:

UPDATE sale_listings 
       SET total_listing = total_listing+1 
       WHERE sale_listing_id = 'current_sale_listing_id'

Я также пропускаю инструкцию where в вашем выборе, чтобы проверить, существует ли предыдущий список, поэтому ваш счетчик строк всегда будет неправильным.Это должно быть:

SELECT sale_listing_id, property_id, 
        sale_listing_amount, discount_percent, total_listing
        FROM sale_listings WHERE property_id = 'last_property_id'

Также обратите внимание на SQL-инъекцию , вставлять переменные непосредственно в ваш запрос никогда не стоит.

Вы используете property_id дляпроверять / обновлять списки продаж, однако каждый раз, когда появляется новое свойство, оно генерирует новый уникальный идентификатор.Это приводит к тому, что ваша вставка всегда создает новое свойство, а не обновляет старое, потому что вновь созданный идентификатор никогда не будет в списках продаж.Я бы порекомендовал добавить адрес в список продажи и выполнить предложение where в этом столбце / этих столбцах, чтобы обновить списки продажи.