23

我希望使用 PHP PDO 进行多次插入。

我找到的最接近的答案是这个

如何将数组插入单个 mysql 准备语句

但是给出的示例使用？而不是真正的占位符。

我查看了 PHP 文档站点上的示例以获取占位符

php.net pdo.prepared-statements

$stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)");
$stmt->bindParam(':name', $name);
$stmt->bindParam(':value', $value);

现在假设我想实现上述目标，但使用数组

$valuesToInsert = array(
  0 => array('name' => 'Robert', 'value' => 'some value'),
  1 => array('name' -> 'Louise', 'value' => 'another value')
);

我将如何处理 PDO 和每个事务的多个插入？

我想它会从一个循环开始？

$stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)");

foreach($valuesToInsert as $insertRow){

    // now loop through each inner array to match binded values
    foreach($insertRow as $column => value){
        $stmt->bindParam(":{$column}", value);
    }
}
$stmt->execute();

然而，上述方法不起作用，但希望能证明我试图实现的目标

4

5 回答 5

30

首先，?符号是真正的占位符（大多数驱动程序允许同时使用语法、位置和命名占位符）。其次，预准备语句只不过是一种将原始输入注入 SQL 语句的工具——SQL 语句本身的语法不受影响。您已经拥有所需的所有元素：

  • 如何使用单个查询插入多行
  • 如何动态生成 SQL
  • 如何使用带有命名占位符的准备好的语句。

将它们全部结合起来相当简单：

$sql = 'INSERT INTO table (memberID, programID) VALUES ';
$insertQuery = [];
$insertData = [];
$n = 0;
foreach ($data as $row) {
    $insertQuery[] = '(:memberID' . $n . ', :programID' . $n . ')';
    $insertData['memberID' . $n] = $memberid;
    $insertData['programID' . $n] = $row;
    $n++;
}

if (!empty($insertQuery)) {
    $sql .= implode(', ', $insertQuery);
    $stmt = $db->prepare($sql);
    $stmt->execute($insertData);
}
于 2013-02-25T15:17:28.360 回答
8

我假设您使用的是 InnoDB，因此此答案仅对该引擎有效（或任何其他支持事务的引擎，这意味着不包括 MyISAM）。

默认情况下 InnoDB 在自动提交模式下运行。这意味着每个查询都被视为自己包含的事务。

要将其翻译成我们凡人可以理解的东西，这意味着您发出的每个 INSERT 查询都会通过确认它写下查询信息来强制硬盘提交它。考虑到机械硬盘的速度非常慢，因为它们每秒的输入输出操作很低（如果我没记错的话，平均为 300 次 IO），这意味着您的 50 000 个查询将非常慢。

所以你会怎么做？您在单个事务中提交所有 50k 查询。它可能不是用于各种目的的最佳解决方案，但它会很快。

你这样做：

$dbh->beginTransaction();

$stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)");

foreach($valuesToInsert as $insertRow)
{    
    // now loop through each inner array to match bound values
    foreach($insertRow as $column => value)
    {
        $stmt->bindParam(":$column", value);
        $stmt->execute();
    }
}


$dbh->commit();
于 2013-02-25T15:26:52.827 回答
1

NB
$stmt->execute() 提供的解决方案中的一些修改应该在内部循环之外，因为您可能有一个或多个列需要在调用 $stmt->execute() 之前绑定，否则您将得到异常“无效参数号：绑定变量的数量与令牌的数量不匹配”。
第二个“价值”变量缺少美元符号。

function batchinsert($sql,$params){
    try { 
                db->beginTransaction(); 

                $stmt = db->prepare($sql);

                foreach($params as $row)
                {    
                    // now loop through each inner array to match bound values
                    foreach($row as $column => $value)
                    {                           
                        $stmt->bindParam(":$column", $value);                           
                    }
                    $stmt->execute();
                }                                       
                db->commit();                   

        } catch(PDOExecption $e) {
            $db->rollback();                
        }
}

测试：

$sql = "INSERT INTO `test`(`name`, `value`) VALUES (:name, :value)" ;

$data = array();    

array_push($data, array('name'=>'Name1','value'=>'Value1')); 

array_push($data, array('name'=>'Name2','value'=>'Value2')); 

array_push($data, array('name'=>'Name3','value'=>'Value3')); 

array_push($data, array('name'=>'Name4','value'=>'Value4')); 

array_push($data, array('name'=>'Name5','value'=>'Value5')); 

batchinsert($sql,$data);
于 2015-06-01T15:44:00.620 回答
-1

您的代码实际上没问题，但$stmt->bindParam(":$column", value);它应该是有问题的，$stmt->bindValue(":{$column}", $value);它会完美运行。这将在未来帮助其他人。

完整代码：

foreach($params as $row)
{ 
    // now loop through each inner array to match bound values
    foreach($row as $column => $value)
    { 
        $stmt->bindValue(":{$column}", $value); //EDIT
    }
    // Execute statement to add to transaction
    $stmt->execute();
}
于 2016-03-24T13:36:08.793 回答
-4

将执行移动到循环内部。

$stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)");
foreach($valuesToInsert as $insertRow)
{
    $stmt->execute($insertRow);    
}

如果您在使用这种推荐的方式时遇到任何问题，您必须提出一个问题，描述这些特定问题。

于 2013-02-25T15:17:23.337 回答