1

我制作了一个脚本，它创建一个原始查询字符串，然后在一个语句中插入数百行。它有效，但不提供准备好的语句所提供的保护。然后我修改了我的脚本以添加准备好的语句。它可以工作，但是速度要慢得多。与原始查询脚本相比，带有准备好的语句的脚本插入行的时间要长得多，因为脚本一次运行一行，而不是一次插入数百行。

这是准备好的语句代码的片段：

for( $j = 0; $j < $abilitiesMax - 2; $j++ ){
  $stmtAbility->bind_param('iiiii', $abilityArray[$i]["match_id"] , $abilityArray[$i]["player_slot"],
  $abilityArray[$i][$j]["ability"], $abilityArray[$i][$j]["time"], $abilityArray[$i][$j]["level"] );

  if(  !($stmtAbility->execute()) ){      
   echo "<p>$db->error</p>";
   echo "<p>ERROR: when trying to insert abilities query</p>";
  }
}

它完成了工作，但只有在数百次插入之后。有没有办法将列表或数组绑定到 bind_param() 参数，只需运行一次 $stmtAbility->execute 或其他可以提高性能的方法。

抱歉，如果以前有人问过并回答过这个问题。我环顾了一会，发现了一些类似的问题，但没有一个能明确回答我的要求。

4

1 回答 1

2

可以通过动态构建来准备批量插入语句查询，但这需要一些技巧。最重要的位是str_pad()用来构造可变长度的查询字符串，以及call_user_func_array()用来调用bind_param()可变数量的参数。

function insertBulkPrepared($db, $table, $fields, $types, $values) {
    $chunklength = 500;
    $fieldcount = count($fields);
    $fieldnames = '`'.join('`, `', $fields).'`';
    $prefix = "INSERT INTO `$table` ($fieldnames) VALUES ";
    $params = '(' . str_pad('', 3*$fieldcount - 2, '?, ') . '), ';
    $inserted = 0;

    foreach (array_chunk($values, $fieldcount*$chunklength) as $group) {
        $length = count($group);
        if ($inserted != $length) {
            if ($inserted) $stmt->close();
            $records = $length / $fieldcount;
            $query = $prefix . str_pad('', 3*$length + 2*($records - 1), $params);
            #echo "\n<br>Preparing '" . $query . "'";
            $stmt = $db->prepare($query);
            if (!$stmt) return false;
            $binding = str_pad('', $length, $types);
            $inserted = $length;
        }

        array_unshift($group, $binding);
        #echo "\n<br>Binding " . var_export($group, true);
        $bound = call_user_func_array(array($stmt, 'bind_param'), $group);
        if (!$bound) return false;
        if (!$stmt->execute()) return false;
    }

    if ($inserted) $stmt->close();
    return true;
}

这个函数将你$db作为一个mysqli实例，一个表名，一个字段名数组，以及一个对值的引用的平面数组。它在每个查询中最多插入 500 条记录，并尽可能重复使用准备好的语句。true如果所有插入都成功，或者false其中任何一个失败，则返回。注意事项：

  • 表名和字段名没有转义；我把它留给你，以确保它们不包含反引号。幸运的是，它们不应该来自用户输入。
  • 如果 的长度$values不是 的长度的偶数倍$fields，则最终块可能会在准备阶段失败。
  • 同样，在大多数情况下，$types参数的长度应该与 的长度相匹配，尤其是当它们中的一些不同时。$fields
  • 它没有区分三种失败的方式。它也不会跟踪成功插入的次数，也不会在出现错误后尝试继续。

定义此函数后，您的示例代码可以替换为以下内容：

$inserts = array();
for ($j = 0; $j < $abilitiesMax - 2; $j++) {
    $inserts[] = &$abilityArray[$i]['match_id'];
    $inserts[] = &$abilityArray[$i]['player_slot'];
    $inserts[] = &$abilityArray[$i][$j]['ability'];
    $inserts[] = &$abilityArray[$i][$j]['time'];
    $inserts[] = &$abilityArray[$i][$j]['level'];
}

$fields = array('match_id', 'player_slot', 'ability', 'time', 'level');
$result = insertBulkPrepared($db, 'abilities', $fields, 'iiiii', $inserts);
if (!$result) {
    echo "<p>$db->error</p>";
    echo "<p>ERROR: when trying to insert abilities query</p>";
}

这些 & 符号很重要，因为mysqli_stmt::bind_param需要引用，而call_user_func_array最新版本的 PHP 没有提供这些引用。

您没有给我们原始准备好的语句，因此您可能需要调整表和字段名称。看起来您的代码也位于循环内$i；在这种情况下，只有for循环需要在外循环内。如果您将其他行放在循环之外，您将使用更多的内存来构造$inserts数组，以换取更有效的批量插入。

也可以重写insertBulkPrepared()以接受多维数组，从而消除潜在错误的一个来源，但这需要在分块后将数组展平。

于 2013-02-13T21:20:57.353 回答