我有一个字符串数组,它们是 sql“输入到...”查询。我循环遍历这个数组,将其中的每 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();
最佳答案
为了解决您的代码无法正常工作的原因,我建议您在将其作为查询提交之前查看完整的 $queryPartial
字符串。我敢打赌这是一个语法错误,因为您没有用 ;
或类似的东西分隔语句。
查看查询本身,而不是您的代码,可能会更清楚错误出在哪里。
您还应该检查 mysqli 函数返回的错误状态。如果发生错误,大多数 mysqli 函数返回 FALSE,您应该检查 $connection->error
以获取错误消息。如果您不这样做,可能会发生错误,但您永远不会知道。
我猜测您正在使用多查询来节省数据库调用,假设进行更少的调用将有助于提高性能。
但是与插入数据的事务的成本相比,调用的成本很小。使用 multi_query()
实际上没有任何好处。
下面的代码做同样的事情,具有几乎相同的性能,它是更简单的代码:
foreach ($data as $index => $queryToSend) {
$result = $connection->query($queryToSend);
if ($result === false) {
error_log("SQL: $queryToSend ERROR: {$connection->error}");
}
}
(始终检查 mysqli 函数返回的错误状态!)
如果您试图加快批量插入的性能,与其他优化相比,使用 multi_query()
的好处微不足道:
- 将多行组合成一个
INSERT
语句 - 将多个语句合并到一个事务中
- 使用
LOAD DATA INFILE
代替INSERT
查看我的演示 Load Data Fast!用于性能比较。
关于php mysqli/multi_query 不能进行多次,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48332917/