登录注册

当前位置：首页 > 文章列表 > 文章 > php教程 > PHPPDO导入CSV到MySQL方法

PHPPDO导入CSV到MySQL方法

2025-07-24 09:15:30 0浏览 收藏
推广推荐
免费电影APP ➜
支持 PC / 移动端，安全直达

golang学习网今天将给大家带来《PHP PDO导入CSV到MySQL教程》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习文章或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

如何使用PHP和PDO将CSV文件导入MySQL数据库

本文详细介绍了如何使用PHP和PDO将CSV文件导入MySQL数据库。教程涵盖了从数据库连接、文件上传处理、CSV数据读取（包括自定义分隔符）、到使用PDO预处理语句进行数据插入的完整流程。特别强调了预处理语句中参数占位符的正确使用，并提供了完整的代码示例及错误处理和最佳实践建议，旨在帮助开发者构建稳定高效的CSV数据导入功能。

1. 引言

在Web应用开发中，将外部数据（如CSV格式）导入到数据库是一个常见的需求。PHP结合PDO（PHP Data Objects）为与MySQL数据库交互提供了强大且安全的方式。本教程将引导您完成一个完整的CSV文件导入MySQL数据库的流程，并指出常见的错误及如何避免它们。

2. 前置准备

在开始之前，请确保您已具备以下环境和基础知识：

  • Web服务器环境： 如Apache或Nginx，并安装了PHP。
  • MySQL数据库： 确保MySQL服务正在运行。
  • PHP基础： 了解PHP语法、文件操作及表单处理。
  • PDO基础： 了解PDO的基本概念，如连接数据库、预处理语句等。

数据库表结构示例： 为了演示，我们假设有一个名为 users 的数据库表，包含以下字段：

CREATE TABLE `users` (
    `id` INT AUTO_INCREMENT PRIMARY KEY,
    `szam` VARCHAR(255) NOT NULL,
    `forras_szam` VARCHAR(255) NOT NULL
);

CSV文件格式示例： 假设您的CSV文件数据以分号（;）分隔，例如：

BGYR002217;FK-066
BGYR002218;FK-140

3. PHP脚本实现

整个导入过程可以分为几个主要步骤：数据库连接、文件上传处理、读取CSV数据并插入数据库。

3.1 数据库连接

首先，我们需要使用PDO建立与MySQL数据库的连接。为了提高安全性，建议将数据库凭据保存在配置文件中，但这里为了演示方便直接写入代码。

<?php
$dbHost = 'localhost';
$dbName = 'test';
$dbChar = 'utf8mb4'; // 推荐使用 utf8mb4 支持更广泛的字符集
$dbUser = 'root';
$dbPass = '';

try {
    $pdo = new PDO(
        "mysql:host=" . $dbHost . ";dbname=" . $dbName . ";charset=" . $dbChar,
        $dbUser,
        $dbPass,
        [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 启用异常模式
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认关联数组获取结果
            PDO::ATTR_EMULATE_PREPARES => false // 禁用模拟预处理，使用原生预处理
        ]
    );
} catch (Exception $ex) {
    // 捕获数据库连接异常
    exit("数据库连接失败: " . $ex->getMessage());
}
?>

注意事项：

  • PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION：这是非常重要的设置，它会使PDO在遇到错误时抛出异常，方便我们进行错误捕获和处理。
  • PDO::ATTR_EMULATE_PREPARES => false：禁用模拟预处理，确保使用数据库服务器的原生预处理功能，提高安全性和性能。
  • utf8mb4：推荐使用 utf8mb4 字符集，以支持更广泛的Unicode字符，包括表情符号等。

3.2 处理文件上传

CSV文件通常通过HTML表单上传到服务器。PHP通过 $_FILES 全局变量来处理上传的文件。

首先，您需要一个HTML表单来上传CSV文件：

<!DOCTYPE html>
<html lang="zh-CN">
<head>
    <meta charset="UTF-8">
    <title>CSV文件导入</title>
</head>
<body>
    <form action="import.php" method="post" enctype="multipart/form-data">
        <label for="upcsv">选择CSV文件:</label>
        &lt;input type=&quot;file&quot; name=&quot;upcsv&quot; id=&quot;upcsv&quot; accept=&quot;.csv&quot;&gt;
        <button type="submit">上传并导入</button>
    </form>
</body>
</html>

在 import.php 中，我们需要检查文件是否成功上传：

// ... (数据库连接代码) ...

if (!isset($_FILES["upcsv"]) || $_FILES["upcsv"]["error"] !== UPLOAD_ERR_OK) {
    exit("文件上传失败或未选择文件.");
}

$csvFilePath = $_FILES["upcsv"]["tmp_name"];
$fh = fopen($csvFilePath, "r");

if ($fh === false) {
    exit("无法打开上传的CSV文件.");
}

3.3 读取CSV数据并插入数据库

这是核心部分，我们将逐行读取CSV文件，并使用PDO预处理语句将数据插入到数据库中。

关键点：CSV分隔符fgetcsv() 函数默认使用逗号（,）作为分隔符。如果您的CSV文件使用其他分隔符（如本例中的分号 ;），您必须将其作为第二个参数（或第三个参数，如果指定了长度）传递给 fgetcsv()。

关键点：PDO预处理语句占位符 在PDO预处理语句中，参数占位符是问号 ? 或命名占位符 :name。原始代码中使用了 VALUES (?;?)，这是不正确的语法。正确的占位符应该是 VALUES (?,?)。

// ... (数据库连接和文件处理代码) ...

$rowCount = 0;
$errorCount = 0;

// 开始事务，确保数据一致性，如果导入过程中出现错误，可以回滚
$pdo->beginTransaction();

try {
    // 准备SQL插入语句
    // 注意：VALUES (?,?) 是正确的占位符语法
    $stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?,?)");

    // 循环读取CSV文件中的每一行
    // fgetcsv的第三个参数是分隔符，这里指定为分号 ';'
    while (($row = fgetcsv($fh, 0, ';')) !== false) {
        // 检查行数据是否符合预期，避免 Undefined array key 错误
        if (count($row) < 2) {
            echo "警告: 跳过无效行 (数据不足): " . implode(';', $row) . "<br>";
            $errorCount++;
            continue;
        }

        try {
            // 执行预处理语句，绑定CSV行中的数据
            $stmt->execute([$row[0], $row[1]]);
            $rowCount++;
        } catch (Exception $ex) {
            // 捕获每行插入时的数据库错误
            echo "插入数据失败 (行: " . implode(';', $row) . "): " . $ex->getMessage() . "<br>";
            $errorCount++;
            // 可以选择在这里中断导入或继续
        }
    }

    // 提交事务
    $pdo->commit();
    echo "数据导入完成。<br>";
    echo "成功导入 " . $rowCount . " 行。<br>";
    if ($errorCount > 0) {
        echo "有 " . $errorCount . " 行导入失败或被跳过。<br>";
    }

} catch (Exception $ex) {
    // 捕获整个导入过程中的异常，并回滚事务
    $pdo->rollBack();
    echo "导入过程中发生致命错误: " . $ex->getMessage() . "<br>";
    echo "所有更改已回滚。<br>";
} finally {
    // 确保文件句柄被关闭
    fclose($fh);
}

echo "DONE.";
?>

4. 完整代码示例

将上述所有部分组合起来，形成一个完整的 import.php 文件：

<?php

// 1. 数据库连接配置
$dbHost = 'localhost';
$dbName = 'test';
$dbChar = 'utf8mb4'; // 推荐使用 utf8mb4
$dbUser = 'root';
$dbPass = '';

try {
    $pdo = new PDO(
        "mysql:host=" . $dbHost . ";dbname=" . $dbName . ";charset=" . $dbChar,
        $dbUser,
        $dbPass,
        [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::ATTR_EMULATE_PREPARES => false
        ]
    );
} catch (Exception $ex) {
    exit("数据库连接失败: " . $ex->getMessage());
}

// 2. 处理文件上传
if (!isset($_FILES["upcsv"]) || $_FILES["upcsv"]["error"] !== UPLOAD_ERR_OK) {
    exit("文件上传失败或未选择文件.");
}

$csvFilePath = $_FILES["upcsv"]["tmp_name"];
$fh = fopen($csvFilePath, "r");

if ($fh === false) {
    exit("无法打开上传的CSV文件.");
}

// 3. 读取CSV数据并插入数据库
$rowCount = 0;
$errorCount = 0;

// 开始事务
$pdo->beginTransaction();

try {
    // 准备SQL插入语句，使用正确的占位符 '?'
    $stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?,?)");

    // 循环读取CSV文件中的每一行
    // fgetcsv的第三个参数是分隔符，这里指定为分号 ';'
    while (($row = fgetcsv($fh, 0, ';')) !== false) {
        // 简单的数据完整性检查
        if (count($row) < 2) {
            echo "警告: 跳过无效行 (数据不足): " . htmlspecialchars(implode(';', $row)) . "<br>";
            $errorCount++;
            continue;
        }

        try {
            // 执行预处理语句
            $stmt->execute([$row[0], $row[1]]);
            $rowCount++;
        } catch (Exception $ex) {
            // 捕获每行插入时的数据库错误
            echo "插入数据失败 (行: " . htmlspecialchars(implode(';', $row)) . "): " . $ex->getMessage() . "<br>";
            $errorCount++;
        }
    }

    // 提交事务
    $pdo->commit();
    echo "数据导入完成。<br>";
    echo "成功导入 " . $rowCount . " 行。<br>";
    if ($errorCount > 0) {
        echo "有 " . $errorCount . " 行导入失败或被跳过。<br>";
    }

} catch (Exception $ex) {
    // 捕获整个导入过程中的异常，并回滚事务
    $pdo->rollBack();
    echo "导入过程中发生致命错误: " . $ex->getMessage() . "<br>";
    echo "所有更改已回滚。<br>";
} finally {
    // 确保文件句柄被关闭
    if ($fh) {
        fclose($fh);
    }
}

echo "DONE.";
?>

5. 注意事项与最佳实践

  • 错误处理： 使用 try-catch 块捕获所有可能的异常，包括数据库连接、文件操作和SQL执行错误。
  • 事务： 对于批量数据导入，强烈建议使用事务（beginTransaction(), commit(), rollBack()）。这样可以确保数据的一致性，如果导入过程中发生任何错误，可以回滚所有已执行的操作，避免部分数据导入成功而导致的数据不完整。
  • CSV分隔符： 务必根据您的CSV文件实际使用的分隔符，正确设置 fgetcsv() 的第三个参数。
  • 数据验证： 在 $stmt->execute() 之前，对从CSV读取的数据进行严格的验证（如数据类型、长度、格式等），以防止无效数据插入数据库或SQL注入风险。
  • 安全性：
    • 永远不要直接将用户输入拼接到SQL查询中。使用PDO预处理语句是防止SQL注入的最佳实践。
    • 限制上传文件的大小和类型，防止恶意文件上传。
    • 上传的文件应存储在Web服务器不可直接访问的目录中，处理完成后及时删除。
  • 性能优化：
    • 对于非常大的CSV文件，可以考虑分批次导入（例如，每1000行提交一次事务），以减少内存消耗和提高效率。
    • 如果数据量巨大，LOAD DATA INFILE 是MySQL原生提供的一种更高效的导入方式，但它需要文件在数据库服务器上可访问。
  • 用户反馈： 在导入完成后，向用户提供清晰的反馈，说明导入结果、成功行数、失败行数及原因。

6. 总结

通过本文的详细教程，您应该已经掌握了如何使用PHP和PDO安全高效地将CSV文件导入MySQL数据库。核心要点在于正确使用PDO预处理语句的占位符 ?，以及根据CSV文件的实际分隔符配置 fgetcsv() 函数。遵循上述最佳实践，可以帮助您构建一个健壮、安全且高效的数据导入功能。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于文章的相关知识，也可关注golang学习网公众号。

电脑启动慢？启动项优化技巧大全电脑启动慢？启动项优化技巧大全
上一篇
电脑启动慢？启动项优化技巧大全
Linux防火墙流量控制方法详解
下一篇
Linux防火墙流量控制方法详解
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • ChatExcel酷表：告别Excel难题，北大团队AI助手助您轻松处理数据
    ChatExcel酷表
    ChatExcel酷表是由北京大学团队打造的Excel聊天机器人，用自然语言操控表格，简化数据处理，告别繁琐操作，提升工作效率！适用于学生、上班族及政府人员。
    3204次使用
  • Any绘本：开源免费AI绘本创作工具深度解析
    Any绘本
    探索Any绘本（anypicturebook.com/zh），一款开源免费的AI绘本创作工具，基于Google Gemini与Flux AI模型，让您轻松创作个性化绘本。适用于家庭、教育、创作等多种场景，零门槛，高自由度，技术透明，本地可控。
    3417次使用
  • 可赞AI：AI驱动办公可视化智能工具，一键高效生成文档图表脑图
    可赞AI
    可赞AI，AI驱动的办公可视化智能工具，助您轻松实现文本与可视化元素高效转化。无论是智能文档生成、多格式文本解析，还是一键生成专业图表、脑图、知识卡片，可赞AI都能让信息处理更清晰高效。覆盖数据汇报、会议纪要、内容营销等全场景，大幅提升办公效率，降低专业门槛，是您提升工作效率的得力助手。
    3446次使用
  • 星月写作：AI网文创作神器，助力爆款小说速成
    星月写作
    星月写作是国内首款聚焦中文网络小说创作的AI辅助工具，解决网文作者从构思到变现的全流程痛点。AI扫榜、专属模板、全链路适配，助力新人快速上手，资深作者效率倍增。
    4555次使用
  • MagicLight.ai：叙事驱动AI动画视频创作平台 | 高效生成专业级故事动画
    MagicLight
    MagicLight.ai是全球首款叙事驱动型AI动画视频创作平台，专注于解决从故事想法到完整动画的全流程痛点。它通过自研AI模型，保障角色、风格、场景高度一致性，让零动画经验者也能高效产出专业级叙事内容。广泛适用于独立创作者、动画工作室、教育机构及企业营销，助您轻松实现创意落地与商业化。
    3824次使用
查看更多
相关文章
关于我们 免责声明 意见反馈 联系我们 内容提交
Golang学习网：公益在线Go学习平台，帮助Go学习者快速成长！
技术交流群
Copyright 2023 http://www.17golang.com/ All Rights Reserved ｜ 苏ICP备2023003363号-1
  • Golang学习网
    关注公众号
    Golang学习网
微信登录更方便
  • 密码登录
  • 注册账号
忘记密码
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码
发送验证码