php mysqli/multi_query 不能进行多次

Question

我有一个字符串数组，它们是 sql "input into ..." 查询。我循环遍历这个数组，将其中的每 50 个组合成一个新字符串，然后发送到 mysql 数据库。之后，我重置了我的临时字符串并为新查询做好准备。

但是我的数组在第一次查询后停止并且不想在数据库服务器上发送所有内容所以我总是只有 50 条记录。如何修复我的代码并发送所有内容？

代码：

$data // array with sql queries 
$queryPartial = ''; // additional string for 50 queries to send

           foreach ($data as $index => $queryToSend) {

                $queryPartial .= $queryToSend;

                // send partials query
                if($index % 50 == 0)
                {

                    if($connection->multi_query($queryPartial))
                    {
                        $this->output->writeln('succesfull query number: '.$index);
                    } 
                    $queryPartial = ''; // clean string for next queries
                }


           }   
              //send the rest of the remaining queries
             if($queryPartial !== ''){

                 if($connection->multi_query($queryPartial))
                 {
                    $this->output->writeln('rest of the queries sended');
                 } 
             }

          $connection->close();

Answer 1

为了解决您的代码无法正常工作的原因，我建议您先查看 $queryPartial 的完整字符串，然后再将其作为查询提交。我敢打赌这是一个语法错误，因为您没有用 ; 或类似的东西分隔语句。

查看查询本身，而不是您的代码，可能会更清楚错误出在哪里。

您还应该检查 mysqli 函数 return 的错误状态。如果发生错误，大多数 mysqli 函数 return FALSE，您应该检查 $connection->error 以获取错误消息。如果您不这样做，可能会出现错误，但您永远不会知道。

我猜测您正在使用多查询来节省数据库调用，假设减少调用将有助于提高性能。

但是与插入数据的事务的成本相比，调用的成本很小。使用 multi_query().

实际上没有任何好处

下面的代码做同样的事情，具有几乎相同的性能，它的代码要简单得多：

foreach ($data as $index => $queryToSend) {
    $result = $connection->query($queryToSend);
    if ($result === false) {
        error_log("SQL: $queryToSend ERROR: {$connection->error}");
    }
}

（始终检查错误状态 return 由 mysqli 函数编辑！）

如果您试图加快批量插入的性能，与其他优化相比，使用 multi_query() 的好处微不足道：

将多行合并为一个 INSERT 语句
将多个语句合并为一个事务
使用LOAD DATA INFILE代替INSERT

有关性能比较，请参阅我的演示文稿 Load Data Fast!。

php mysqli/multi_query 不能进行多次

php mysqli/multi_query cannot be proceeded more then once

php

mysql

bulk-load