PHPでCSVファイルを読み込む方法：fgetcsv関数の使い方を解説

CSVファイルは、データをシンプルに保存し、他のプログラムやシステムとデータをやり取りするために広く使用されています。PHPでCSVファイルを扱う際には、ファイルの読み込みや解析を効率的に行うために、標準ライブラリのfgetcsv関数が役立ちます。fgetcsvを利用すれば、複雑な文字列処理を行わなくても、CSVデータを簡単に分割して扱うことが可能です。

本記事では、fgetcsv関数の基本的な使い方から、さまざまな応用方法までを解説し、PHPを使ってCSVファイルを効果的に操作するための知識を提供します。CSVファイルの読み込みを自動化したい方や、データベースへのデータインポートを効率化したい方にも役立つ内容です。

CSVファイルとは
1. CSVファイルの特性と用途
PHPでCSVファイルを操作するメリット
fgetcsv関数の基本的な使い方
CSVデータの読み込み処理の流れ
カスタム区切り文字や囲み文字の使用
CSVデータのエラー処理と例外対応
大規模なCSVファイルの効率的な読み込み
読み込んだデータの加工と表示方法
応用例：CSVデータをデータベースにインポート
実践演習：サンプルコードを使ったハンズオン
まとめ

CSVファイルとは

CSV（Comma-Separated Values）ファイルは、データを表形式で保存するためのシンプルなテキスト形式のファイルです。各行がレコードを表し、カンマで区切られた各項目がフィールドを示します。例えば、顧客データや製品リスト、取引履歴など、多くのデータ形式に利用されており、さまざまなシステム間でのデータ交換にも適しています。

CSVファイルの特性と用途

CSVファイルの特性としては、以下のような点が挙げられます。

軽量でシンプル：テキスト形式であるため、ファイルサイズが小さく、処理が軽快です。
互換性が高い：ほとんどのプログラミング言語やソフトウェアでサポートされています。
人間が読みやすい：テキストエディタで内容を直接確認したり編集したりすることができます。

これらの特性から、CSVファイルはデータのインポート・エクスポート、ログファイルの保存、データ分析など、幅広い用途で使用されています。

PHPでCSVファイルを操作するメリット

PHPでCSVファイルを操作することには、いくつかのメリットがあります。特に、データを扱う際の柔軟性や簡便さが魅力です。以下に、その利点を詳しく説明します。

手軽にファイル操作ができる

PHPは組み込み関数を豊富に備えており、その中でもfgetcsv関数を使えば、簡単にCSVファイルを読み込むことができます。特別なライブラリを導入する必要がなく、標準の関数だけでデータ処理を始められる点が便利です。

Webアプリケーションとの連携が容易

PHPはサーバーサイドのスクリプト言語として、Webアプリケーションの開発に広く使用されています。CSVファイルを使ってデータをインポートしたりエクスポートしたりする機能を追加することが容易で、フォームからアップロードされたCSVファイルをそのまま処理できるため、データ管理の効率が向上します。

柔軟なデータ変換と加工が可能

CSVデータをPHPの配列として読み込むことで、柔軟なデータ加工が可能です。例えば、読み込んだデータをフィルタリングしたり、特定のカラムだけを抽出したり、データベースに保存するための形式に変換することも容易に行えます。

PHPでのCSV操作は、手軽さと柔軟性を活かして、さまざまなデータ処理の場面で役立つ選択肢となります。

fgetcsv関数の基本的な使い方

fgetcsv関数は、PHPでCSVファイルを読み込む際に使用される標準関数で、1行ずつデータを読み込み、カンマ区切りで分割して配列として返します。基本的な使い方を理解することで、CSVデータの処理がスムーズに行えます。

fgetcsv関数の構文

fgetcsv関数の基本的な構文は以下の通りです。

fgetcsv(resource $handle, int $length = 0, string $delimiter = ",", string $enclosure = '"', string $escape = "\\")

$handle: fopen関数で開いたファイルのリソースを指定します。
$length: 読み込む行の最大長さを指定します。0にすると無制限に読み込みます。
$delimiter: フィールドを区切る文字（通常はカンマ）を指定します。
$enclosure: フィールドを囲む文字（通常はダブルクオート）を指定します。
$escape: エスケープ文字を指定します。

基本的な使用例

以下は、fgetcsvを用いたシンプルなCSVファイルの読み込み例です。

<?php
$filename = 'data.csv';
if (($handle = fopen($filename, 'r')) !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        print_r($data);
    }
    fclose($handle);
}
?>

この例では、data.csvファイルを開き、各行をfgetcsvで読み込んで配列として表示しています。fopenでファイルを開き、fcloseでファイルを閉じることを忘れないようにしましょう。

引数のカスタマイズ

必要に応じて、区切り文字や囲み文字をカスタマイズすることができます。例えば、セミコロンで区切られたCSVファイルの場合、次のように指定します。

fgetcsv($handle, 1000, ";")

これにより、様々なCSV形式に対応したデータ読み込みが可能になります。

CSVデータの読み込み処理の流れ

PHPでfgetcsv関数を使ってCSVファイルを読み込む際には、いくつかの基本的なステップを踏む必要があります。このセクションでは、CSVデータを効率的に読み込むための手順を解説します。

1. ファイルを開く

まず、fopen関数を使ってCSVファイルを開きます。ファイルを開く際には、読み込み専用モード（'r'）で開くことが一般的です。

$handle = fopen('data.csv', 'r');

ファイルを開けなかった場合のエラーチェックを行い、ファイルが存在するか、正しく読み取り可能かを確認するのがベストプラクティスです。

2. ループを使って行ごとにデータを取得する

ファイルを開いたら、whileループを使用してfgetcsvで1行ずつ読み込みます。各行が読み込まれると、その行は配列として返され、個々のフィールドが配列の要素になります。

while (($data = fgetcsv($handle, 1000, ",")) !== false) {
    // $data は現在の行のデータを格納する配列
    // ここでデータの処理を行う
}

3. 読み込みが完了したらファイルを閉じる

すべてのデータを読み込んだ後は、必ずfclose関数でファイルを閉じることが大切です。これにより、ファイルリソースの無駄な消費を防ぎます。

fclose($handle);

4. データの処理

各行を配列として取得した後、そのデータを適切に処理します。例えば、データベースに保存する、特定のフィールドをフィルタリングするなどの操作が考えられます。

注意点

ファイルのエンコーディングや特殊文字の処理、空行のチェックなども考慮する必要があります。エラーや例外処理を追加することで、より堅牢なCSV読み込みが実現できます。

この一連の流れを理解することで、fgetcsvを用いたCSVファイルの処理が効果的に行えます。

カスタム区切り文字や囲み文字の使用

fgetcsv関数は、デフォルトではカンマ（,）を区切り文字、ダブルクオート（"）を囲み文字としてCSVデータを解析します。しかし、CSVファイルによっては異なる区切り文字や囲み文字が使われている場合もあります。fgetcsvではこれらの設定をカスタマイズして対応できます。

区切り文字の変更

CSVファイルによっては、カンマの代わりにセミコロン（;）やタブ（\t）が使用されることがあります。fgetcsv関数の第3引数でカスタム区切り文字を指定することにより、柔軟に対応できます。

$handle = fopen('data.csv', 'r');
while (($data = fgetcsv($handle, 1000, ";")) !== false) {
    // セミコロン区切りのCSVを処理
    print_r($data);
}
fclose($handle);

この例では、セミコロン区切りのCSVファイルを読み込んでいます。タブ区切りの場合は、"\t"を第3引数に指定することも可能です。

囲み文字の変更

デフォルトではダブルクオートが囲み文字として扱われますが、場合によってはシングルクオート（'）や他の文字が使用されることがあります。第4引数を指定することで、囲み文字をカスタマイズできます。

$handle = fopen('data.csv', 'r');
while (($data = fgetcsv($handle, 1000, ",", "'")) !== false) {
    // シングルクオートを囲み文字として処理
    print_r($data);
}
fclose($handle);

この例では、シングルクオートで囲まれたフィールドを正しく処理しています。

カスタム設定を組み合わせる

区切り文字と囲み文字の両方を同時にカスタマイズすることも可能です。たとえば、セミコロン区切りでシングルクオート囲みのCSVファイルを扱う場合、次のように設定します。

$handle = fopen('data.csv', 'r');
while (($data = fgetcsv($handle, 1000, ";", "'")) !== false) {
    // セミコロン区切り、シングルクオート囲みのCSVを処理
    print_r($data);
}
fclose($handle);

このように、fgetcsv関数のカスタム設定を活用することで、様々な形式のCSVファイルに対応することができます。

CSVデータのエラー処理と例外対応

CSVファイルの読み込み中にエラーが発生することがあります。これには、ファイル自体の問題やデータの不整合、ファイルアクセス権限の問題などが含まれます。fgetcsvを使ったエラー処理と例外対応を行うことで、堅牢なプログラムを作成できます。

ファイルを開けない場合の対処

最初に、fopenでファイルを開く際にエラーチェックを行います。ファイルが存在しない、または読み取り権限がない場合、fopenはfalseを返します。このケースに対応するため、次のようなエラーメッセージを表示する処理を追加します。

$filename = 'data.csv';
if (($handle = fopen($filename, 'r')) === false) {
    die("ファイルを開くことができませんでした: $filename");
}

この例では、ファイルを開けなかった場合にプログラムを停止し、エラーメッセージを表示します。

不正な行データの処理

CSVファイルに不完全な行や空行が含まれる場合、fgetcsvはfalseを返すことがあります。これをチェックすることで、不正な行をスキップすることができます。

while (($data = fgetcsv($handle, 1000, ",")) !== false) {
    if ($data === null || count($data) < 2) {
        // 不正な行または空行の場合はスキップ
        continue;
    }
    // 正常な行の処理
    print_r($data);
}

このコードでは、空の配列やフィールド数が2未満の行をスキップするようにしています。

データのバリデーションと型チェック

CSVファイルから読み込んだデータの形式が期待通りであることを確認するために、バリデーションを行うことが推奨されます。たとえば、数値が含まれるべきフィールドに文字列が入っていないか確認することができます。

while (($data = fgetcsv($handle, 1000, ",")) !== false) {
    if (!is_numeric($data[0])) {
        echo "不正なデータ形式が検出されました: {$data[0]}\n";
        continue;
    }
    // 正常なデータの処理
}

ここでは、最初のフィールドが数値でない場合にエラーメッセージを表示してスキップしています。

例外処理を活用する

PHPの例外処理を利用して、エラーが発生した際に適切な処理を行うこともできます。try-catch構文を使用して、ファイル操作やデータ処理で発生する例外をキャッチし、エラーメッセージを表示したり、再試行したりすることが可能です。

try {
    $handle = fopen('data.csv', 'r');
    if ($handle === false) {
        throw new Exception("ファイルを開けません: data.csv");
    }
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        // データ処理
    }
    fclose($handle);
} catch (Exception $e) {
    echo "エラーが発生しました: " . $e->getMessage();
}

この例では、fopenやfgetcsvが失敗した場合に例外を発生させ、適切なエラーメッセージを表示しています。

エラー処理と例外対応を適切に行うことで、CSVデータの読み込み処理がより安全で信頼性の高いものになります。

大規模なCSVファイルの効率的な読み込み

大規模なCSVファイルを扱う場合、ファイルのサイズがメモリに収まらない可能性があります。このような場合、効率的な読み込みと処理方法を用いることで、パフォーマンスを向上させることが重要です。以下の手法を活用して、大規模なCSVファイルを効率的に読み込む方法を解説します。

1. 一行ずつ読み込む

大規模なCSVファイルを一度にメモリに読み込むと、メモリ不足を引き起こす可能性があります。そのため、fgetcsvを使用して一行ずつ読み込む方法が推奨されます。この方法では、各行を読み込んで処理した後に次の行に進むため、メモリ消費を最小限に抑えることができます。

$handle = fopen('large_data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        // 行データの処理
    }
    fclose($handle);
}

この例では、fgetcsvで一行ずつ読み込み、処理を行っています。ファイル全体をメモリに読み込む必要がないため、大規模なファイルでも効率的に処理できます。

2. バッファを使用した分割処理

大きなCSVファイルを一度に処理するのではなく、データをバッファに分割して処理する方法もあります。たとえば、一定行数ごとにデータを一時保存してからまとめて処理することで、メモリ使用量を抑えることが可能です。

$batchSize = 1000;
$buffer = [];
$rowCount = 0;

$handle = fopen('large_data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        $buffer[] = $data;
        $rowCount++;

        if ($rowCount % $batchSize == 0) {
            // バッファ内のデータをまとめて処理
            processData($buffer);
            $buffer = []; // バッファをクリア
        }
    }
    // 残ったデータを処理
    if (!empty($buffer)) {
        processData($buffer);
    }
    fclose($handle);
}

function processData(array $data) {
    // データの処理ロジック
    echo "バッチ処理完了: " . count($data) . " 行\n";
}

この例では、batchSizeの設定により、1000行ごとにまとめて処理を行っています。

3. メモリ制限の設定を見直す

非常に大規模なファイルを扱う際には、PHPのメモリ制限を調整する必要がある場合があります。php.iniファイルの設定や、ini_set関数でメモリの使用上限を変更することで、一時的にメモリ制限を緩和できます。

ini_set('memory_limit', '512M'); // メモリ制限を512MBに設定

この方法は、メモリの消費を抑えた手法を使用しても対処できない場合に限り、慎重に行うべきです。

4. ファイルの分割処理

非常に大きなCSVファイルを事前に分割して、複数の小さなファイルに分けて処理するのも一つの方法です。この方法では、個々の小さなファイルを別々に読み込み、順次処理を行います。Unixのsplitコマンドや、専用のファイル分割ツールを使用して事前にCSVファイルを分割することができます。

5. 並列処理の活用

大規模なCSVファイルのデータ処理を並列に行うことで、処理速度を向上させることも可能です。たとえば、ファイルを複数の部分に分け、それぞれを別々のプロセスやスレッドで同時に処理します。この方法は、サーバーのリソースを効率的に利用できる場合に有効です。

これらの方法を活用することで、大規模なCSVファイルの読み込みと処理を効率的に行い、パフォーマンスの向上を図ることができます。

読み込んだデータの加工と表示方法

CSVファイルをfgetcsvで読み込んだ後、データを適切に加工して表示することがよくあります。データの加工には、フィルタリング、並べ替え、特定のカラムの抽出などが含まれ、これによって必要な情報を抽出しやすくなります。ここでは、読み込んだCSVデータを加工して表示するいくつかの方法を紹介します。

1. データのフィルタリング

特定の条件に一致する行のみを処理することができます。たとえば、あるカラムの値が特定の条件に合致するデータだけを表示する場合は、以下のようにフィルタリングを行います。

$handle = fopen('data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        if ($data[2] === 'Tokyo') { // 第3カラムが'Tokyo'の行を選択
            print_r($data);
        }
    }
    fclose($handle);
}

この例では、CSVの第3カラムの値が「Tokyo」である行だけを表示します。

2. カラムの抽出

CSVファイルには複数のカラムが含まれることが多いですが、必要なカラムだけを取り出すことも可能です。以下のコードは、特定のカラム（例：名前と年齢）だけを抽出して表示する方法を示しています。

$handle = fopen('data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        $name = $data[0]; // 第1カラムを名前とする
        $age = $data[1];  // 第2カラムを年齢とする
        echo "名前: $name, 年齢: $age\n";
    }
    fclose($handle);
}

ここでは、CSVの第1カラムを「名前」、第2カラムを「年齢」として取り出し、出力しています。

3. データの並べ替え

CSVデータを配列に変換し、その後に並べ替えを行うこともできます。たとえば、年齢順に並べ替える場合は次のようにします。

$rows = [];
$handle = fopen('data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        $rows[] = $data;
    }
    fclose($handle);
}

// 年齢（第2カラム）で並べ替え
usort($rows, function ($a, $b) {
    return $a[1] <=> $b[1];
});

// 並べ替えた結果を表示
foreach ($rows as $row) {
    echo "名前: {$row[0]}, 年齢: {$row[1]}\n";
}

このコードでは、CSVデータを一旦配列に格納し、usort関数を使って年齢（第2カラム）の昇順で並べ替えています。

4. データの変換

CSVデータを加工する際に、文字列の形式を変換したり、数値を計算したりすることもよくあります。たとえば、金額のカラムに数値フォーマットを適用する場合は、以下のように行います。

$handle = fopen('data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        $price = number_format($data[3]); // 第4カラムを金額としてフォーマット
        echo "商品: {$data[0]}, 価格: ¥$price\n";
    }
    fclose($handle);
}

この例では、価格のカラムを日本円の数値形式で表示しています。

5. HTMLテーブルとして表示

読み込んだCSVデータをWebページに表示する場合、HTMLテーブル形式で整形すると見やすくなります。次のコードでは、CSVデータをHTMLのテーブルとして出力します。

echo "<table border='1'>";
echo "<tr><th>名前</th><th>年齢</th><th>住所</th></tr>";

$handle = fopen('data.csv', 'r');
if ($handle !== false) {
    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        echo "<tr>";
        echo "<td>{$data[0]}</td>"; // 名前
        echo "<td>{$data[1]}</td>"; // 年齢
        echo "<td>{$data[2]}</td>"; // 住所
        echo "</tr>";
    }
    fclose($handle);
}

echo "</table>";

このコードは、CSVのデータをHTMLテーブルとして表示し、各フィールドを適切にセルに配置します。

これらの方法を活用することで、CSVファイルから取得したデータを柔軟に加工し、さまざまな形式で表示することが可能になります。

応用例：CSVデータをデータベースにインポート

CSVファイルから読み込んだデータをデータベースに保存することは、データ管理の効率化に役立ちます。PHPを使って、CSVデータをMySQLなどのデータベースにインポートする方法を解説します。このセクションでは、基本的な手順を示し、データベースへの挿入における注意点を紹介します。

1. データベース接続の設定

まず、PDOを使用してMySQLデータベースに接続します。以下のコードは、データベース接続を確立する基本的な方法です。

$dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8';
$username = 'root';
$password = '';

try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
    die("データベース接続エラー: " . $e->getMessage());
}

ここでは、localhost上のtestdbデータベースに接続しています。PDO::ERRMODE_EXCEPTIONを設定することで、エラーが発生した場合に例外をスローします。

2. CSVファイルを読み込む

次に、fgetcsvを使用してCSVファイルを開き、データを一行ずつ読み込みます。

$handle = fopen('data.csv', 'r');
if ($handle === false) {
    die("CSVファイルを開けませんでした。");
}

このコードは、data.csvファイルを開きます。開けなかった場合はエラーメッセージを表示して終了します。

3. データベースにデータを挿入する

読み込んだCSVデータをデータベースに挿入します。適切なSQLステートメントを用意し、PDOのプリペアドステートメントを使用して安全にデータを挿入します。

$sql = "INSERT INTO users (name, age, city) VALUES (:name, :age, :city)";
$stmt = $pdo->prepare($sql);

while (($data = fgetcsv($handle, 1000, ",")) !== false) {
    // CSVの各フィールドを変数にマッピング
    $name = $data[0];
    $age = $data[1];
    $city = $data[2];

    // データベースに挿入
    $stmt->bindParam(':name', $name);
    $stmt->bindParam(':age', $age);
    $stmt->bindParam(':city', $city);
    $stmt->execute();
}
fclose($handle);

echo "CSVデータのインポートが完了しました。";

この例では、usersテーブルにname、age、cityのデータを挿入しています。bindParamメソッドでパラメータをバインドし、SQLインジェクションを防止します。

4. トランザクションを使用してエラーを管理する

大量のデータをインポートする場合、トランザクションを利用してエラーが発生したときにロールバックする方法が推奨されます。これにより、データの一貫性が保たれます。

try {
    $pdo->beginTransaction();

    $sql = "INSERT INTO users (name, age, city) VALUES (:name, :age, :city)";
    $stmt = $pdo->prepare($sql);

    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        $name = $data[0];
        $age = $data[1];
        $city = $data[2];

        $stmt->bindParam(':name', $name);
        $stmt->bindParam(':age', $age);
        $stmt->bindParam(':city', $city);
        $stmt->execute();
    }

    $pdo->commit();
    echo "CSVデータのインポートが正常に完了しました。";

} catch (Exception $e) {
    $pdo->rollBack();
    echo "エラーが発生したため、インポートを中止しました: " . $e->getMessage();
}
fclose($handle);

このコードでは、トランザクションを使用してすべての挿入が成功するか、失敗した場合にはロールバックを実行してデータの一貫性を保っています。

5. 重複データのチェックと更新

既存データとの重複を防ぐため、挿入前にデータの存在チェックを行うか、重複する場合はUPDATE文を使ってデータを更新します。次のコードは、既存のユーザー名でレコードを更新する方法です。

$sql = "INSERT INTO users (name, age, city) VALUES (:name, :age, :city)
        ON DUPLICATE KEY UPDATE age = :age, city = :city";
$stmt = $pdo->prepare($sql);

ON DUPLICATE KEY UPDATEを使用することで、重複したデータがある場合でも適切に更新が行われます。

このように、CSVファイルをデータベースにインポートする手順を理解することで、データ管理が効率的になり、さまざまなアプリケーションで活用できるようになります。

実践演習：サンプルコードを使ったハンズオン

ここでは、実際にfgetcsvを用いてCSVファイルを読み込み、データベースにインポートする一連の作業をサンプルコードで練習します。このハンズオンを通じて、基本的なCSV操作からデータベースとの連携までの流れを理解しましょう。

1. サンプルCSVファイルの準備

以下のような内容のCSVファイルを作成します。ファイル名は「sample_data.csv」とし、名前、年齢、都市のデータが含まれているとします。

John Doe,30,New York
Jane Smith,25,Los Angeles
Mike Johnson,35,Chicago
Emily Davis,28,Houston

このCSVファイルには、名前、年齢、都市の3つのカラムがあり、それぞれがカンマで区切られています。

2. データベースとテーブルの作成

MySQLで以下のSQLコマンドを実行して、ユーザー情報を格納するテーブル「users」を作成します。

CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT NOT NULL,
    city VARCHAR(100) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

このテーブルには、id、name、age、city、およびcreated_atの5つのフィールドがあり、idは自動的にインクリメントされるプライマリキーです。

3. PHPスクリプトの作成

次に、PHPスクリプトを作成してCSVファイルを読み込み、データをデータベースにインポートします。以下のコードを「import_csv.php」という名前で保存します。

<?php
$dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8';
$username = 'root';
$password = '';

try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    $handle = fopen('sample_data.csv', 'r');
    if ($handle === false) {
        die("CSVファイルを開けませんでした。");
    }

    $pdo->beginTransaction();
    $sql = "INSERT INTO users (name, age, city) VALUES (:name, :age, :city)";
    $stmt = $pdo->prepare($sql);

    while (($data = fgetcsv($handle, 1000, ",")) !== false) {
        $name = $data[0];
        $age = $data[1];
        $city = $data[2];

        $stmt->bindParam(':name', $name);
        $stmt->bindParam(':age', $age);
        $stmt->bindParam(':city', $city);
        $stmt->execute();
    }

    $pdo->commit();
    fclose($handle);
    echo "CSVデータのインポートが正常に完了しました。";

} catch (Exception $e) {
    $pdo->rollBack();
    echo "エラーが発生したため、インポートを中止しました: " . $e->getMessage();
}
?>

このスクリプトでは、CSVファイルを読み込んで各行をusersテーブルに挿入します。トランザクションを使用して、エラーが発生した場合にロールバックするようにしています。

4. スクリプトの実行

コマンドラインまたはブラウザを使用して「import_csv.php」を実行します。スクリプトが正しく実行されると、「CSVデータのインポートが正常に完了しました。」というメッセージが表示され、データベースにCSVの内容が挿入されます。

php import_csv.php

または、Webサーバー上で実行する場合は、ブラウザで「http://localhost/import_csv.php」を開いてください。

5. データの確認

MySQLクライアントやPHPMyAdminなどを使用して、usersテーブルにデータが正しくインポートされていることを確認します。以下のSQLコマンドを実行することで、テーブル内のすべてのデータを確認できます。

SELECT * FROM users;

このコマンドにより、インポートされたユーザーデータが表示されます。

6. エラーハンドリングの強化

実践的なシナリオでは、すべてのCSVデータが正しい形式であるとは限りません。以下のようにデータのバリデーションを追加することで、エラーデータを無視するか、別の処理を行うことができます。

while (($data = fgetcsv($handle, 1000, ",")) !== false) {
    if (count($data) < 3 || !is_numeric($data[1])) {
        echo "無効なデータが検出されました: " . implode(", ", $data) . "\n";
        continue; // この行をスキップ
    }

    $name = $data[0];
    $age = (int)$data[1];
    $city = $data[2];

    $stmt->bindParam(':name', $name);
    $stmt->bindParam(':age', $age);
    $stmt->bindParam(':city', $city);
    $stmt->execute();
}

このコードでは、CSVの行が適切なカラム数を持っていない、または年齢フィールドが数値でない場合にエラーメッセージを表示し、その行をスキップします。

このハンズオンを通じて、CSVデータの読み込みからデータベースへのインポートまでの一連の流れを学びました。これにより、データ処理の自動化が実現し、実用的なアプリケーション開発に役立つでしょう。

まとめ

本記事では、PHPでfgetcsv関数を用いてCSVファイルを読み込み、データを効率的に処理する方法について解説しました。CSVファイルの基本的な扱い方から、カスタム区切り文字の使用、エラー処理、大規模ファイルの読み込みの最適化、データベースへのインポートの応用例まで、幅広くカバーしました。

これらの手法を理解することで、CSVデータの取り扱いがより効果的になり、実践的なWebアプリケーション開発やデータ処理業務に応用できる知識を習得できたと思います。CSV操作の基本を押さえ、実際のプロジェクトで活用してください。