php和pdo跳过一些记录插入

Question

I am fetching rows from a CSV file but while inserting, some records were skipped. What is the solution for that?

while(($line = fgetcsv($file, 10000, ",")) !== FALSE){

            $total_data++;
             $sql="SELECT id FROM customers WHERE id ='".$line[0]."'";
            $db->query(  $sql);

            $check = $db->resultset();
            $num = $db->rowCount();

            if($num > 0){
                $update_data++;
                //$db->query("UPDATE customers SET name = :name, phone=:phone where id=:id");
                $db->bind(':name', $line[1]);
                $db->bind(':phone', $line[2]);
                $db->bind(':id', $line[0]);
                $db->execute();

            }else{
                   $insert_data++;
                $db->query("INSERT INTO customers(id,name,phone) VALUES (:id,:name,:phone)");
                    $db->bind(':id',$line[0]);
                    $db->bind(':name', $line[1]);
                    $db->bind(':phone', $line[2]);
                    $db->execute();
            }
        }

Answer 1

Typically with PDO you have to store results of calls to query(), etc. and call the methods on the returned prepared statements...

query() returns a PDOStatement object so save that in a variable, e.g. $statement, and then call methods like rowCount() on that variable:

while(($line = fgetcsv($file, 10000, ",")) !== FALSE){
    $total_data++;
    $sql="SELECT id FROM customers WHERE id ='".$line[0]."'";
    $statement = db->query(  $sql);

    $check = $statement->resultset();
    $num = $statement->rowCount();

    if($num > 0){
        $update_data++;
        $updateStatement = $db->query("UPDATE customers SET name = :name, phone=:phone where id=:id");
        $updateStatement->bind(':name', $line[1]);
        $updateStatement->bind(':phone', $line[2]);
        $updateStatement->bind(':id', $line[0]);
        $updateStatement->execute();

    }else{
        $insert_data++;
        $insertStatement = db->query("INSERT INTO customers(id,name,phone) VALUES (:id,:name,:phone)");
        $insertStatement->bind(':id',$line[0]);
        $insertStatement->bind(':name', $line[1]);
        $insertStatement->bind(':phone', $line[2]);
        $insertStatement->execute();
    }
}