Doctrine中使用预处理语句批量插入数据的异常问题求助

问题根源 #

你当前的代码存在以下问题：

• 第一种写法中，循环内反复绑定参数但仅执行一次execute()，最终只有最后一次绑定的邮箱会被插入。
• 将execute()放入循环但仅初始化一次语句对象时，重复使用同一个语句对象绑定参数可能存在覆盖或未正确刷新的问题，导致仅第一个邮箱被插入。

方案1：高效批量插入（推荐） #

构建包含多组值的INSERT语句，一次执行完成所有插入，性能更优：

$connection = $this->modelManager->getConnection();
$emails = array_keys($unsubscribedMembers);
$valuePlaceholders = [];
$params = [];

// 构建占位符和参数数组
foreach ($emails as $email) {
    $valuePlaceholders[] = '(?, ?)';
    $params[] = $email;
    $params[] = $listId;
}

// 拼接完整SQL
$sql = 'INSERT IGNORE INTO `unsubscriber` (email, listId) VALUES ' . implode(', ', $valuePlaceholders);
$stmt = $connection->prepare($sql);
$stmt->execute($params);

方案2：循环执行单条插入 #

如果需要保持单条插入的形式，直接在execute()中传入参数数组，避免手动绑定的问题：

$connection = $this->modelManager->getConnection();
$sql = 'INSERT IGNORE INTO `unsubscriber` (email, listId) VALUES (:email, :listId)';
$stmt = $connection->prepare($sql);

foreach (array_keys($unsubscribedMembers) as $email) {
    $stmt->execute([
        'email' => $email,
        'listId' => $listId
    ]);
}

两种方案都能实现批量插入所有邮箱地址，方案1因为减少了数据库交互次数，在数据量较大时性能更出色。

内容的提问来源于stack exchange，提问作者Torben