循环插入 - PHP Postgres 插入

Question

我正在通过循环进行插入，不幸的是，它似乎只插入了一些数据而忽略了一些数据。

我正在读取文件的内容并使用 PHP 将它们插入到 postgres 数据库中。

请参阅下面的代码。

$source='/Users/gsarfo/AVEC_ETL/TCCDec052016OSU.DAT';

$lines=file($source);

$len =sizeof($lines);

$connec = new PDO("pgsql:host=$dbhost;dbname=$dbname", $dbuser,    $dbpwd); 

$ins=$connec->query('truncate table tbl_naaccr_staging');

try {

    for ($x = 0; $x < $len; $x++) {
        $a1=substr($lines[$x],146,9);
        $a2=substr($lines[$x],2182,9);
        $a3=substr($lines[$x],192,3);
        $connec->beginTransaction();

        $sql2=$connec->prepare("INSERT INTO tbl_naaccr_staging
                                (addr,name, email) VALUES (?, ?, ?"); 

        $sql2->execute(array($a1,   $a2,    $a3));
        $connec->commit();     
    }
    $res=$connec->query($sql) ;
}

catch (PDOException $e) { 
    echo "Error : " . $e->getMessage() . "<br/>"; 
    die(); 
} 

if ($sql2)
{echo 'success';}
?>

Answer 1

我不明白插入任何东西会怎样！

此行不正确

$sql2=$connec->prepare("INSERT INTO tbl_naaccr_staging
                       (addr,name, email) VALUES (?, ?, ?"); 
                                                         ^ ^ here

更正为

$sql2=$connec->prepare("INSERT INTO tbl_naaccr_staging
                       (addr,name, email) VALUES (?, ?, ?)");

此外，您的事务没有多大意义，因为它会提交每次更新，如果您没有启动事务就会发生这种情况。所以也许这会是明智的，并且会实现全有或全无的 senario

此外，prepare 可以多次重复使用，因此也将其移出循环，您会发现脚本运行速度也更快。

try {

    $connec->beginTransaction();   

    // move this out of the loop
    $sql2=$connec->prepare("INSERT INTO tbl_naaccr_staging
                            (addr,name, email) VALUES (?, ?, ?)");  

    for ($x = 0; $x < $len; $x++) {
        $a1=substr($lines[$x],146,9);
        $a2=substr($lines[$x],2182,9);
        $a3=substr($lines[$x],192,3);

        $sql2->execute(array($a1,   $a2,    $a3));
    }
    $connec->commit();  

    // I do not see a `$sql` variable so this query seems to have no function
    //$res=$connec->query($sql) ;
}

catch (PDOException $e) { 
    $connec->rollback();     

    echo "Error : " . $e->getMessage() . "<br/>"; 
    die(); 
}

Answer 2

成功了，问题是由于插入的字符串中的未转义字符造成的，因此 pg_escape_string 在插入之前帮助清除了字符串

循环插入 - PHP Postgres 插入

Looping through Inserts - PHP Postgres Insert

php

postgresql

plpgsql

php-pgsql