主页 / 问题 / 681399
Accepted
Александр
Asked:2020-06-20 16:14:57 +0800 CST2020-06-20 16:14:57 +0800 CST

MySQL PHP写入问题

  • 772

在程序中，我得到一个包含arr1000 个值的数组，我想使用 PDO 写入数据库

输出：Warning: Error while sending QUERY packet. PID=8448

foreach ($arr as $v => $k){
    $sql = "INSERT INTO table (value, key) VALUES (:value, :key);
    $data = [
        ":value" => $v;
        ":key"   => $k
    ];
    $db->query($sql,$data);
};

我还尝试拆分 25 和 50 个请求：

$sql = "";
$i = 0;
foreach ($arr as $k => $v) {
    $i++;
    if ($i % 50 == 0){
        $db->query($sql);
        sleep(5);
        $sql = "";
    }
    $sql .= "INSERT INTO table(link,price) VALUES ('" . $k . "','" . $v . "'); ";
}
$db->query($sql);

输出：

Warning: PDOStatement::execute(): MySQL server has gone away in ....\Connection.php on line 53

连接类：

....
public function query(string $sql, array $data = [])
{
    51 set_time_limit(0);
    52 $sth = $this->link->prepare($sql);
    53 $sth->execute($data);
    54 $result = $sth->fetchAll();
    55 if (false === $result) {
        return [];
    }

    return $result;
}

结果，没有任何内容写入数据库。尝试使用较小的值（~70-80）一切正常，帮助解决问题。Openserver MySQL 5.5 PHP7

更新：错误已MySQL server has gone away in ...通过对连接类进行少量添加来解决：

$this->link = new \PDO($dns, $config['***'], $config['***']);
$this->link->query("SET wait_timeout=9999;");

query("SET wait_timeout=9999;");

php

1 个回答

  1. Best Answer

    为了提高性能，您可以使用具有多个 VALUES 的单个 INSERT：

    INSERT INTO table (x,y,z) VALUES(1,2,3),(1,2,3),(1,2,3);

    这就是您如何形成与数组中的元素一样多的请求。

    INSERT和VALUES也必须分块！并且您不应向一个 INSERT 添加超过 1024 条记录

    function placeholders($text, $count=0, $separator=","){
    $result = array();
    if($count > 0){
        for($x=0; $x<$count; $x++){
            $result[] = $text;
        }
    }

    return implode($separator, $result);
}

    通过@HerbertBalagtas

    foreach($arr as $k){
    $arrValues = array_merge($arrValues, array_values($k));
    $sumParams[] = '('.placeholders('?', sizeof($k)).')';
}

    在 VALUE 的查询中，将问号替换为“?”。

    "INSERT INTO table(link,price) VALUES " . implode(',', $sumParams);

    之后将$arrValues代入execute($arrValues)

    • 2

相关问题