使用PHP脚本执行SQL文件并导入数据库

花开有时

发布时间：2026-10-14| 8人浏览过

原创

在处理数据迁移或系统初始化时，通过PHP脚本自动执行.sql文件是一种高效的数据库导入方式。本文将详细解析如何利用PHP读取并执行SQL文件，包括连接设置、语句分割、注释过滤及批量执行的核心逻辑，同时指出传统mysql扩展的兼容性风险并提供现代替代方案。

实现原理与目标

核心目标是将一个包含建表、插入数据等指令的文本文件（.sql）转换为数据库可执行的命令流。主要步骤包括：建立数据库连接、完整读取SQL文本、按分号分割独立语句、清理无效字符（如注释和空行），最后通过数据库接口逐一提交。

准备条件

服务器环境：运行支持PHP 7.0+的版本（原示例代码基于PHP 5，部分函数已废弃）。
数据库权限：拥有目标库的写入权限，建议先在测试库验证。
SQL文件：标准的MySql导出格式，以;作为语句结束符。

第1步：连接数据库

首先需要在PHP中建立与MySQL服务器的连接。注意，原代码使用的是即将移除的mysql扩展，现代开发应改用mysqli或PDO。

示例代码

<?php
$host = 'localhost';
$user = 'username';
$password = 'password';
$dbname = 'your_database';

// 推荐使用 PDO 连接，更简洁且支持预处理
$pdo = new PDO("mysql:host=$host;dbname=$dbname;charset=utf8", $user, $password);
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
?>

第2步：读取并预处理SQL文件

读取整个SQL文件内容，并按行或特定规则进行处理。需要剔除注释（--或#开头）和多余空行，防止执行报错。

<?php
$sqlPath = 'data.sql'; // SQL文件路径
if (!file_exists($sqlPath)) {
    die('SQL file not found');
}

$sqlContent = file_get_contents($sqlPath);

// 简单的正则去除单行注释（注意：多行注释 /* ... */ 需更复杂处理）
$sqlLines = explode("\n", $sqlContent);
$pureStatements = [];
$currentStmt = '';

foreach ($sqlLines as $line) {
    $trimmed = trim($line);
    // 跳过空行和纯注释行
    if (empty($trimmed) || preg_match('/^--|^#/', $trimmed)) {
        continue;
    }
    $currentStmt .= $line . "\n";
    
    // 如果当前片段以 ; 结尾，则认为是一条完整的SQL语句
    if (preg_match('/;$/', $trimmed)) {
        $pureStatements[] = trim($currentStmt);
        $currentStmt = '';
    }
}
?>

第3步：执行SQL语句

将分割好的SQL语句数组遍历，并通过数据库连接执行。对于大型SQL文件，建议分批执行以避免内存溢出。

<?php
try {
    foreach ($pureStatements as $stmt) {
        if (empty($stmt)) continue;
        $pdo->exec($stmt);
    }
    echo "SQL execution completed successfully.";
} catch (PDOException $e) {
    echo "Error: " . $e->getMessage();
}
?>

关键注意事项与优化

编码问题：确保PHP文件、SQL文件和数据库均使用相同的字符集（如utf8mb4），避免乱码。
事务控制：如果SQL文件涉及多个关联操作，建议开启事务：$pdo->beginTransaction()，执行完后 $pdo->commit()，若出错则 $pdo->rollback()，保证数据一致性。
前缀替换：若需为表名添加前缀（如从users变为wp_users），需在解析阶段结合正则表达式对特定关键字（如CREATE TABLE, INSERT INTO）后的标识符进行替换，需谨慎处理反引号。`table_name`。

完成判断

脚本无报错输出，且数据库中新增了对应的表和记录。可通过查询语句 SHOW TABLES; 或在应用层检查数据是否存在来验证。

总结

通过PHP执行SQL文件是实现自动化数据导入的有效手段。虽然原始示例代码展示了基本逻辑，但在实际生产环境中，务必升级至MySQLi或PDO，并加入异常处理与事务机制，以确保数据导入的稳定性和安全性。以上就是使用PHP执行SQL文件导入数据库的详细内容，更多关于PHP数据库操作的资料请关注本站其它相关文章！