在 PHP 中执行大型 SQL 查询字符串时出现“内存不足”错误


"Out of memory" error when executing large SQL query string in PHP

我想将我的MS Access数据导入MySQL数据库。我正在使用xampp.我编写了获取 Access 表并创建查询字符串的 PHP 代码。当我执行程序时,它给我以下错误:

内存不足(需要 2465528 字节)

我的代码是:

<?php
$conn=odbc_connect('my','','');/* connected */
$sql="SELECT * FROM mytable";
$rs=odbc_exec($conn,$sql);
$sqlstr="";
$tablefields=array("Name","City","State");
$sqlstr="INSERT INTO `mytable`(";
$temp=0;
for($i=0;$i<count($tablefields)-1;$i++)
{
    $sqlstr.="`".$tablefields[$i]."`";
    if($temp==count($tablefields)-2)
    {
    }
    else
    {
        $sqlstr.=",";
        $temp++;
    }
}
$sqlstr.=") VALUES";
//echo $sqlstr;
//return;
$sqlstr.="(";
while($row = odbc_fetch_array($rs)) 
{ 
    $temp=0;
    foreach ($row as $key => $value)
    {
        $sqlstr.="'".$value."'";
        if($temp==count($row)-1)
        {
            $sqlstr.="),(";
        }else
        {
            $sqlstr.=",";
            $temp++;
        }
        //echo $sqlstr;
    }

}    
$sqlstr.=")";
     connection();


$res=mysql_query($sqlstr)or die (mysql_error());


function connection()
{
$host="localhost";
$user="root";
$pass="";
$database="mydatabase";
$cnx=mysql_connect($host, $user, $pass);
mysql_connect($host, $user, $pass);
echo (mysql_error($cnx));
mysql_select_db($database, $cnx);
echo (mysql_error($cnx));
return $cnx;
}
?>

我确实改变了max_execution_time = 3600memory_limit = -1 php.ini并在my.ini

    key_buffer = 200M
    sort_buffer_size = 200M
    read_buffer = 200M
    write_buffer = 200M

谁能告诉我问题出在哪里?

对于任何处于类似情况的未来读者,更好的方法是使用预准备语句来执行 INSERT 操作。优点包括:

  • 您不必猜测一批插入件的"正确"尺寸应该是多少。
  • 代码更具可维护和可扩展性。
  • 如果文本字段包含单引号,它不会爆炸。
  • 它不容易受到SQL注入问题的影响。
  • 它能够正确处理空值。
<?php
$tablefields=array("Name","City","State");
$myDb = new PDO('mysql:host=localhost:3307;dbname=myDb', 'root', 'whatever');
$myDb->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$mySt = $myDb->prepare("TRUNCATE TABLE mytable");
$mySt->execute();
$params = array_fill(0, count($tablefields), '?');
$sqlstr = "INSERT INTO mytable (`" . implode("`,`", $tablefields) .
        "`) VALUES (" . implode(",", $params) . ")";
// i.e., INSERT INTO mytable (`Name`,`City`,`State`) VALUES (?,?,?)
$mySt = $myDb->prepare($sqlstr);
$accDb = new PDO('odbc:' .
        'Driver={Microsoft Access Driver (*.mdb, *.accdb)};' .
        'Dbq=C:''Users''Public''Database1.accdb;');
$accDb->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$sqlstr = "SELECT [" . implode("],[", $tablefields) . "] FROM myTable";
// i.e., SELECT [Name],[City],[State] FROM myTable
$accSt = $accDb->prepare($sqlstr);
$accSt->execute();
$rowCount = 0;
while ($row = $accSt->fetch()) {
    for ($i = 0; $i < count($tablefields); $i++) {
        $params[$i] = $row[$tablefields[$i]];
    }
    $mySt->execute($params);
    $rowCount++;
}
echo $rowCount . " row(s) copied.<br />";

每几百条记录插入一次。像这样的东西:-

<?php
$conn=odbc_connect('my','','');/* connected */
$sql="SELECT * FROM mytable";
$rs=odbc_exec($conn,$sql);
$sqlstr="";
$tablefields=array("Name","City","State");
$sqlhead="INSERT INTO `mytable`(`".implode("`,`", $tablefields)."`) VALUES ";
connection();
$sqlitem = array();
while($row = odbc_fetch_array($rs)) 
{ 
    $temp=0;
    if (count($sqlitem) > 255)
    {
        $res=mysql_query($sqlhead.implode(',', $sqlitem))or die (mysql_error());
        $sqlitem = array();
    }
    $sqlitem[] = "('".implode("','",$row)."')";
}    
if (count($sqlitem) > 0)
{
    $res=mysql_query($sqlhead."(".implode('),(', $sqlitem).")")or die (mysql_error());
}
function connection()
{
    $host="localhost";
    $user="root";
    $pass="";
    $database="mydatabase";
    $cnx=mysql_connect($host, $user, $pass);
    mysql_connect($host, $user, $pass);
    echo (mysql_error($cnx));
    mysql_select_db($database, $cnx);
    echo (mysql_error($cnx));
    return $cnx;
}
?>

您可以通过将插入移动到类中(而不仅仅是使用数组)来更干净地执行此操作。传递每一行以插入类,如果当前总数高于 X,则执行插入,并从类中的析构函数执行插入。省去了在循环结束时决定是否需要执行更多插入操作的麻烦。

请注意,mysql_* 函数已弃用,您可能应该改用 mysqli_* 函数。