Array_chunkを使用してデータベース操作のバッチ挿入を実行する方法

M66 2025-04-26

データベース操作を実行するとき、データのバッチ挿入は、特に大量のデータを処理する場合、データを1つずつ挿入するよりもパフォーマンスを改善します。 PHPは、この操作を最適化するための多くの方法を提供します。Array_Chunkは、大きなアレイをより小さなアレイにカットし、効率的なバッチ挿入操作を可能にする非常に実用的なツールです。

1. array_chunkとは何ですか？

Array_chunkは、大規模な配列を複数の小さなアレイに分割するために使用されるPHPの配列関数です。各小さな配列の要素の数は、お客様が指定できます。その基本的な構文は次のとおりです。

 array_chunk(array $array, int $size, bool $preserve_keys = false): array

$配列：カットする必要がある配列。
$サイズ：各小さな配列のサイズ。
$ preserve_keys ：元の配列のキー名を保持するかどうか、デフォルトはfalseです。

2。array_chunkを使用して、バッチ挿入を実装します

データベースにデータのバッチを挿入する必要があるとします。 1つずつ挿入することは非効率的であるだけでなく、パフォーマンスのボトルネックを簡単に作成します。 Array_chunkを使用してデータを複数の小さなバッチにカットし、各小さなバッチを一度に挿入できます。

Array_chunkを使用してバッチ挿入を実装する例を次に示します。

 <?php
// データソースをシミュレートします
$data = [
    ['name' => 'Alice', 'email' => 'alice@m66.net'],
    ['name' => 'Bob', 'email' => 'bob@m66.net'],
    ['name' => 'Charlie', 'email' => 'charlie@m66.net'],
    // ...より多くのデータ
];

// 各バッチのサイズを設定します
$batchSize = 100;

// 使用 array_chunk データを小さなバッチに分割します
$dataChunks = array_chunk($data, $batchSize);

// データベースに接続します
$pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '');

// トランザクションを開始します
$pdo->beginTransaction();

foreach ($dataChunks as $chunk) {
    // バッチインサートをビルドします SQL 声明
    $placeholders = [];
    $values = [];
    
    foreach ($chunk as $row) {
        $placeholders[] = "(?, ?)";
        $values[] = $row['name'];
        $values[] = $row['email'];
    }

    // 準備する SQL 声明
    $sql = "INSERT INTO users (name, email) VALUES " . implode(", ", $placeholders);
    $stmt = $pdo->prepare($sql);

    // バッチ挿入を実行します
    $stmt->execute($values);
}

// トランザクションを送信します
$pdo->commit();

echo "データ挿入が完了しました！";
?>

3。コード解析

データソース：ユーザーの名前と電子メールアドレスを含むデータのセットをシミュレートし、電子メールドメインをM66.netに置き換えました。
バッチ処理： Array_chunkを使用して、指定されたサイズ（たとえば、100）でデータを分割し、100個のデータを一度に挿入できるようにし、多数の単一の挿入によって引き起こされるパフォーマンスの問題を回避できます。
トランザクション処理：データの一貫性とパフォーマンスを確保するために、データベーストランザクションを有効にします。このようにして、挿入プロセス中に障害がある場合、データの整合性を維持するためにすべての操作を巻き戻すことができます。
バッチ挿入SQL ：SQLステートメントを動的に構築することにより、バッチ挿入を実行します。この例では、各バッチのステートメントに挿入を生成し、SQLステートメントのプレースホルダーにデータを1つずつバインドします。

4。最適化の提案

バッチサイズを合理的に設定します。Array_chunkのバッチサイズは、パフォーマンスに影響を与える重要な要素です。バッチが小さすぎる場合、毎回データベースが挿入されすぎると、パフォーマンスの劣化につながります。バッチが大きすぎる場合、メモリが大きすぎたり、データベース接続がタイムアウトになったりする可能性があります。したがって、適切なバッチサイズを実際の状況に応じて調整する必要があり、共通のバッチサイズは100または1000です。
トランザクションの使用：上記のように、データベースは複数の挿入操作を1つの操作に組み合わせることができるため、トランザクションをオンにすると、データの一貫性が確保され、バッチインサートの実行時にパフォーマンスが向上します。
エラー処理：実際のプロジェクトでは、挿入が失敗したときにロールバック操作など、エラー処理メカニズムを検討する必要があります。

5。概要

array_chunkを使用すると、大量のデータを小さなバッチに削減し、効率的なバッチデータ挿入操作を可能にします。これにより、パフォーマンスが向上するだけでなく、メモリの過剰な消費も回避します。同時に、トランザクション処理に協力することで、データの一貫性と整合性を確保できます。これは、データを大規模に処理する場合、非常に効率的なソリューションです。

array_chunk