php - 使用php批量插入数据到MySQL数据库

标签 php mysql load-data-infile

我使用 PHP 和 MySQL 从庞大的 XML 中解析出数千个数据,并将其插入到数据库表中。我的问题是将所有数据插入表中花费的时间太长。有没有办法将我的数据分成更小的组,以便按组进行插入过程?例如,如何设置一个脚本来处理 100 个数据?这是我的代码:

foreach($itemList as $key => $item){
     $download_records  = new DownloadRecords();
    //check first if the content exists
    if(!$download_records->selectRecordsFromCondition("WHERE Guid=".$guid."")){
         /* do an insert here */
    } else {
         /*do an update */
    }

*注意:$itemList 大约有 62,000 个并且还在增长。

最佳答案

使用 for 循环?

但是将数据加载到 MySQL 中的最快选择是使用 LOAD DATA INFILE命令,您可以创建要通过 PHP 加载的文件,然后通过不同的进程(或作为原始进程的最后一步)将其提供给 MySQL。

如果您不能使用文件,请使用以下语法:

insert into table(col1, col2) VALUES (val1,val2), (val3,val4), (val5, val6)

所以你减少了要运行的句子总数。

编辑:根据您的代码片段,您似乎可以从 INSERT ... ON DUPLICATE KEY UPDATE 中受益MySQL 的语法,让数据库完成工作并减少查询量。这假定您的表具有主键或唯一索引。

要每 100 行访问一次数据库,您可以执行以下操作(请检查它并将其修复到您的环境中)

$insertOrUpdateStatement1 = "INSERT INTO table (col1, col2) VALUES ";
$insertOrUpdateStatement2 = "ON DUPLICATE KEY UPDATE ";
$counter = 0;
$queries = array();

foreach($itemList as $key => $item){
    $val1 = escape($item->col1); //escape is a function that will make 
                                 //the input safe from SQL injection. 
                                 //Depends on how are you accessing the DB

    $val2 = escape($item->col2);

    $queries[] = $insertOrUpdateStatement1. 
    "('$val1','$val2')".$insertOrUpdateStatement2.
    "col1 = '$val1', col2 = '$val2'";

    $counter++;

    if ($counter % 100 == 0) {
        executeQueries($queries);
        $queries = array();
        $counter = 0;
    }
}

executeQueries 会抓取数组并发送一个单一的多重查询:

function executeQueries($queries) {
   $data = "";
     foreach ($queries as $query) {
        $data.=$query.";\n";
    }
    executeQuery($data);
}

关于php - 使用php批量插入数据到MySQL数据库,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/1042461/

相关文章:

javascript - 我这里有一个按钮,尝试在 jdfiddle 中执行它,它可以工作,但在 html 中则不行

php - 将多个结果的子查询合并为一个

javascript - 搜索结果中的动态链接

php - 需要使用 MySQL 查询插入封装的 XML 元素

javascript - 如何从数据库行创建有效的 JSON

python - 使用python和mssql插入特殊字符°

java - 创建动态 Web 项目时出现 "java.lang.ClassNotFoundException: com.mysql.jdbc.Driver"错误

mysql - 加载数据infile,注释字符

mysql - 如何在将数据从excel导入mysql时忽略指数通知并获取实际值

mysql - 批量导入数据到mysql,不指定文件扩展名