ThinkPHP8.2执行sql文件如何批量插入-ThinkPHP-PHP中文网

thinkphp 8.2 不支持直接执行 sql 文件，需解析文件、拆分语句、过滤非 insert 内容，再按每 500–1000 行分块拼成多值 insert，用 db::execute() 在事务中执行；或转 csv 后用 load data infile（mysql 专属）提升性能。

thinkphp8.2执行sql文件如何批量插入

ThinkPHP 8.2 本身不提供直接执行 SQL 文件（如 .sql 脚本）的内置命令，批量插入需通过「解析 SQL 文件内容 → 拆分语句 → 分批执行」来实现。核心思路是：**避免一次性 load 全量 SQL 导致内存溢出或超时，改用流式读取 + 事务分块插入**。

一、推荐方式：用 Db 类分批执行 INSERT 语句

适用于已导出为标准 INSERT INTO ... VALUES (...) 格式的 SQL 文件（如 mysqldump 生成），且不含 CREATE / DROP / SET 等非数据语句。

先用 PHP 读取文件，按分号 ; 拆分语句，过滤掉空行和注释行
识别出所有 INSERT INTO `table_name` ... 语句，提取表名和 VALUES 部分
将大批 VALUES 拆成每 500–1000 行一组，拼成单条多值 INSERT（如 INSERT INTO t VALUES (...),(...),(...)）
用 Db::execute() 执行，包裹在事务中提升性能并保证原子性

示例代码（放在命令行指令或控制器中）：

php
use think\facade\Db;

$sqlFile = './data/init_data.sql';
$content = file_get_contents($sqlFile);
$statements = preg_split('/;\s*[\r\n]+/', $content);

Db::transaction(function () use ($statements) {
  foreach ($statements as $stmt) {
    $stmt = trim($stmt);
    if (empty($stmt) || str_starts_with($stmt, '--') || str_starts_with($stmt, '/*')) {
      continue;
    }
    if (stripos($stmt, 'INSERT INTO') === 0) {
      // 提取 VALUES 部分，再按 ),( 拆分单条记录（需更健壮可引入 SQL 解析器）
      $values = []; // 此处需实际解析逻辑，略去细节
      // 每 500 条合为一条 INSERT
      $chunks = array_chunk($values, 500);
      foreach ($chunks as $chunk) {
        $sql = 'INSERT INTO ... VALUES ' . implode(',', $chunk);
        Db::execute($sql);
      }
    }
  }
});
?>

二、更稳妥方案：用原生 PDO + LOAD DATA INFILE（仅限 MySQL）

若数据源是纯 CSV/TSV 格式（比 SQL 文件更轻量），且数据库有文件读取权限，可用 MySQL 原生命令 LOAD DATA INFILE，速度远超逐条 INSERT。

PHP

编写健壮的PHP代码，规避类型转换陷阱、数组怪癖及常见安全漏洞。

下载

确保 MySQL 配置启用 secure_file_priv，且文件路径在该目录下
SQL 文件需先转为标准 CSV（字段用 \t 或 , 分隔，无引号/转义也可）
执行：LOAD DATA INFILE '/var/lib/mysql-files/data.csv' INTO TABLE user FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n';
ThinkPHP 中调用：Db::execute($sql);

三、生产环境避坑要点

直接 exec('mysql -u root -p... 或 <code>shell_exec 方式不推荐，存在安全与权限风险：

命令行密码明文暴露（可用 mysql_config_editor 预存配置规避）
无法捕获错误详情，失败后难定位哪条语句出错
大文件易触发 PHP max_execution_time 或 memory_limit 限制（建议 CLI 模式运行，设 set_time_limit(0); ini_set('memory_limit', '-1');）
线上务必关闭 APP_DEBUG=true，避免 SQL 错误泄露敏感信息