PHPでCSVファイルをアップロードしデータを処理する方法を徹底解説

名前,年齢,職業
田中,30,エンジニア
佐藤,28,デザイナー

file_uploads = On
upload_max_filesize = 2M
post_max_size = 8M

<form action="upload.php" method="post" enctype="multipart/form-data">
    <label for="csvFile">CSVファイルを選択してください:</label>
    <input type="file" name="csvFile" id="csvFile" accept=".csv">
    <input type="submit" value="アップロード">
</form>

<?php
// アップロード先のディレクトリ
$targetDirectory = "uploads/";

// アップロードされたファイルの情報
$uploadedFile = $_FILES['csvFile'];

// ファイル名の取得
$fileName = basename($uploadedFile['name']);

// ファイルの保存先パス
$targetFilePath = $targetDirectory . $fileName;

// CSV形式か確認
$fileType = pathinfo($targetFilePath, PATHINFO_EXTENSION);
if($fileType !== 'csv') {
    echo "エラー: CSVファイルのみアップロード可能です。";
    exit;
}

// ファイルアップロード処理
if (move_uploaded_file($uploadedFile['tmp_name'], $targetFilePath)) {
    echo "ファイルアップロードが成功しました: " . htmlspecialchars($fileName);
} else {
    echo "エラー: ファイルのアップロードに失敗しました。";
}
?>

<?php
// アップロードされたファイルのパス
$csvFile = 'uploads/' . basename($_FILES['csvFile']['name']);

// ファイルが存在するか確認
if (!file_exists($csvFile)) {
    echo "エラー: CSVファイルが見つかりません。";
    exit;
}

// CSVファイルの読み込み
if (($handle = fopen($csvFile, "r")) !== FALSE) {
    // 各行を読み込み
    while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
        // $dataには、CSVの1行分が配列として格納されます
        echo "<pre>";
        print_r($data); // データの内容を表示
        echo "</pre>";
    }
    // ファイルを閉じる
    fclose($handle);
} else {
    echo "エラー: ファイルの読み込みに失敗しました。";
}
?>

<?php
// 許可する最大ファイルサイズ（バイト単位）
$maxFileSize = 2 * 1024 * 1024; // 2MB

// アップロードされたファイルサイズの取得
$fileSize = $_FILES['csvFile']['size'];

// ファイルサイズのチェック
if ($fileSize > $maxFileSize) {
    echo "エラー: ファイルサイズが2MBを超えています。";
    exit;
}
?>

<?php
// 許可するファイル拡張子
$allowedExtension = 'csv';

// アップロードされたファイルの拡張子を取得
$fileExtension = pathinfo($_FILES['csvFile']['name'], PATHINFO_EXTENSION);

// 拡張子のチェック
if (strtolower($fileExtension) !== $allowedExtension) {
    echo "エラー: CSVファイルのみアップロード可能です。";
    exit;
}
?>

<?php
$maxFileSize = 2 * 1024 * 1024; // 2MB
$allowedExtension = 'csv';
$fileSize = $_FILES['csvFile']['size'];
$fileExtension = pathinfo($_FILES['csvFile']['name'], PATHINFO_EXTENSION);

// ファイルサイズと拡張子のバリデーション
if ($fileSize > $maxFileSize) {
    echo "エラー: ファイルサイズが2MBを超えています。";
    exit;
}
if (strtolower($fileExtension) !== $allowedExtension) {
    echo "エラー: CSVファイルのみアップロード可能です。";
    exit;
}

// バリデーション通過後の処理
echo "ファイルは有効です。アップロードを続けます。";
?>

CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50),
    age INT,
    occupation VARCHAR(50)
);

<?php
// データベース接続設定
$servername = "localhost";
$username = "root";
$password = "password";
$dbname = "test_db";

// データベースに接続
$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("接続失敗: " . $conn->connect_error);
}

// CSVファイルのパス
$csvFile = 'uploads/' . basename($_FILES['csvFile']['name']);

// CSVファイルを読み込み
if (($handle = fopen($csvFile, "r")) !== FALSE) {
    // 1行目を見出しとしてスキップ
    fgetcsv($handle);

    // 各行をデータベースに保存
    while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
        // データを変数に割り当て
        $name = $data[0];
        $age = $data[1];
        $occupation = $data[2];

        // データベースへのINSERTクエリ
        $sql = "INSERT INTO users (name, age, occupation) VALUES ('$name', $age, '$occupation')";
        if (!$conn->query($sql)) {
            echo "エラー: " . $conn->error;
        }
    }
    fclose($handle);
    echo "データの保存が完了しました。";
} else {
    echo "エラー: ファイルの読み込みに失敗しました。";
}

// データベース接続を閉じる
$conn->close();
?>

<?php
// データベース接続設定
$servername = "localhost";
$username = "root";
$password = "password";
$dbname = "test_db";

// データベースに接続
$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("接続失敗: " . $conn->connect_error);
}

// 年齢の平均値を計算するSQLクエリ
$sql = "SELECT AVG(age) AS average_age FROM users";
$result = $conn->query($sql);

if ($result && $result->num_rows > 0) {
    $row = $result->fetch_assoc();
    echo "年齢の平均値: " . round($row['average_age'], 2);
} else {
    echo "データがありません。";
}

// データベース接続を閉じる
$conn->close();
?>

<?php
// データベース接続設定
$servername = "localhost";
$username = "root";
$password = "password";
$dbname = "test_db";

// データベースに接続
$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("接続失敗: " . $conn->connect_error);
}

// 職業ごとの人数を集計するSQLクエリ
$sql = "SELECT occupation, COUNT(*) AS count FROM users GROUP BY occupation";
$result = $conn->query($sql);

if ($result && $result->num_rows > 0) {
    echo "<h3>職業ごとの人数</h3>";
    while ($row = $result->fetch_assoc()) {
        echo $row['occupation'] . ": " . $row['count'] . " 人<br>";
    }
} else {
    echo "データがありません。";
}

// データベース接続を閉じる
$conn->close();
?>

<?php
// アップロードエラーチェック
$fileError = $_FILES['csvFile']['error'];

if ($fileError !== UPLOAD_ERR_OK) {
    switch ($fileError) {
        case UPLOAD_ERR_INI_SIZE:
        case UPLOAD_ERR_FORM_SIZE:
            echo "エラー: ファイルサイズが上限を超えています。";
            break;
        case UPLOAD_ERR_NO_FILE:
            echo "エラー: ファイルが選択されていません。";
            break;
        case UPLOAD_ERR_PARTIAL:
            echo "エラー: ファイルの一部のみがアップロードされました。";
            break;
        default:
            echo "エラー: ファイルのアップロードに失敗しました。";
    }
    exit;
}

<?php
$servername = "localhost";
$username = "root";
$password = "password";
$dbname = "test_db";

// データベース接続
$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("エラー: データベース接続に失敗しました。" . $conn->connect_error);
}

// データ挿入クエリ
$sql = "INSERT INTO users (name, age, occupation) VALUES ('田中', 30, 'エンジニア')";
if (!$conn->query($sql)) {
    echo "エラー: データの挿入に失敗しました。" . $conn->error;
}
$conn->close();
?>

<?php
try {
    $conn = new PDO("mysql:host=localhost;dbname=test_db", "root", "password");
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // データ挿入クエリ
    $sql = "INSERT INTO users (name, age, occupation) VALUES ('佐藤', 28, 'デザイナー')";
    $conn->exec($sql);
    echo "データが正常に挿入されました。";
} catch (PDOException $e) {
    echo "エラー: " . $e->getMessage();
}
$conn = null;
?>

<?php
// MIMEタイプの確認
$mimeType = mime_content_type($_FILES['csvFile']['tmp_name']);
if ($mimeType !== 'text/plain' && $mimeType !== 'text/csv') {
    echo "エラー: 不正なファイル形式です。";
    exit;
}
?>

# uploadsディレクトリ内のファイル実行を防止
<Directory "/path/to/uploads">
    Order Deny,Allow
    Deny from all
</Directory>

<?php
// 一意のファイル名に変更して保存
$uniqueFileName = uniqid() . '.csv';
$targetFilePath = 'uploads/' . $uniqueFileName;
move_uploaded_file($_FILES['csvFile']['tmp_name'], $targetFilePath);
?>

<?php
$conn = new mysqli($servername, $username, $password, $dbname);
$stmt = $conn->prepare("INSERT INTO users (name, age, occupation) VALUES (?, ?, ?)");
$stmt->bind_param("sis", $name, $age, $occupation);

// CSVファイルの読み込みとデータ挿入
if (($handle = fopen($csvFile, "r")) !== FALSE) {
    fgetcsv($handle); // 見出し行をスキップ
    while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
        $name = $data[0];
        $age = $data[1];
        $occupation = $data[2];
        $stmt->execute();
    }
    fclose($handle);
}
$stmt->close();
$conn->close();
?>

<?php
// データの検証
if (!is_numeric($age) || $age < 0 || $age > 120) {
    echo "エラー: 年齢が無効です。";
    exit;
}

<form action="multi_upload.php" method="post" enctype="multipart/form-data">
    <label for="csvFiles">CSVファイルを選択してください（複数選択可）:</label>
    <input type="file" name="csvFiles[]" id="csvFiles" accept=".csv" multiple>
    <input type="submit" value="アップロード">
</form>

<?php
// アップロード先のディレクトリ
$targetDirectory = "uploads/";

// ファイルが選択されているか確認
if (!isset($_FILES['csvFiles']) || empty($_FILES['csvFiles']['name'][0])) {
    echo "エラー: ファイルが選択されていません。";
    exit;
}

// アップロードされたファイルを処理
foreach ($_FILES['csvFiles']['tmp_name'] as $index => $tmpFilePath) {
    $fileName = basename($_FILES['csvFiles']['name'][$index]);
    $targetFilePath = $targetDirectory . uniqid() . "_" . $fileName;

    // ファイル形式の確認
    $fileType = pathinfo($targetFilePath, PATHINFO_EXTENSION);
    if ($fileType !== 'csv') {
        echo "エラー: {$fileName}はCSVファイルではありません。";
        continue;
    }

    // ファイルのアップロード処理
    if (move_uploaded_file($tmpFilePath, $targetFilePath)) {
        echo "ファイルアップロード成功: " . htmlspecialchars($fileName) . "<br>";
    } else {
        echo "エラー: {$fileName}のアップロードに失敗しました。<br>";
    }
}
?>

/csv_project
├── index.html      // アップロードフォーム
├── upload.php      // ファイルアップロード処理
├── process.php     // データベース挿入と集計処理
├── config.php      // データベース接続設定
└── uploads/        // アップロードされたCSVファイルの保存ディレクトリ

<?php
$servername = "localhost";
$username = "root";
$password = "password";
$dbname = "test_db";

$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("エラー: データベース接続に失敗しました。" . $conn->connect_error);
}
?>

<!DOCTYPE html>
<html lang="ja">
<head>
    <meta charset="UTF-8">
    <title>CSVファイルアップロード</title>
</head>
<body>
    <form action="upload.php" method="post" enctype="multipart/form-data">
        <label for="csvFiles">CSVファイルを選択してください（複数選択可）:</label>
        <input type="file" name="csvFiles[]" id="csvFiles" accept=".csv" multiple>
        <input type="submit" value="アップロード">
    </form>
</body>
</html>

<?php
include 'config.php'; // データベース設定を読み込む
$targetDirectory = "uploads/";

foreach ($_FILES['csvFiles']['tmp_name'] as $index => $tmpFilePath) {
    $fileName = basename($_FILES['csvFiles']['name'][$index]);
    $targetFilePath = $targetDirectory . uniqid() . "_" . $fileName;
    $fileType = pathinfo($targetFilePath, PATHINFO_EXTENSION);

    if ($fileType !== 'csv') {
        echo "エラー: {$fileName}はCSVファイルではありません。<br>";
        continue;
    }

    if (move_uploaded_file($tmpFilePath, $targetFilePath)) {
        echo "ファイルアップロード成功: " . htmlspecialchars($fileName) . "<br>";
        include 'process.php'; // アップロード後にデータ処理を呼び出し
    } else {
        echo "エラー: {$fileName}のアップロードに失敗しました。<br>";
    }
}
?>

<?php
include 'config.php'; // データベース設定を読み込む
$csvFile = $targetFilePath;

if (($handle = fopen($csvFile, "r")) !== FALSE) {
    fgetcsv($handle); // 見出し行をスキップ
    while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
        $name = $data[0];
        $age = $data[1];
        $occupation = $data[2];

        $stmt = $conn->prepare("INSERT INTO users (name, age, occupation) VALUES (?, ?, ?)");
        $stmt->bind_param("sis", $name, $age, $occupation);
        $stmt->execute();
    }
    fclose($handle);
    echo "データベースにデータが挿入されました。<br>";
}

// 年齢の平均値
$result = $conn->query("SELECT AVG(age) AS average_age FROM users");
$row = $result->fetch_assoc();
echo "年齢の平均値: " . round($row['average_age'], 2) . "<br>";

// 職業ごとの集計
$result = $conn->query("SELECT occupation, COUNT(*) AS count FROM users GROUP BY occupation");
echo "<h3>職業ごとの人数</h3>";
while ($row = $result->fetch_assoc()) {
    echo $row['occupation'] . ": " . $row['count'] . " 人<br>";
}

$conn->close();
?>