MySQLi：用一条准备好的语句插入多行

Question

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

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 one time或其他可以提高性能的方法。

抱歉，如果这是问和回答之前。我四处看了一会儿，发现了一些类似的问题，但没有什么能明确地回答我的要求。

Answer 1

通过动态构造一个大容量insert语句查询来准备它是可能的，但是需要一些技巧。最重要的是使用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数组，以获得更高效的批量插入。