Итерация запроса Doctrine не работает на MS SQL Server - новая транзакция не разрешена
Я пытаюсь перебрать результаты и удалить их с помощью диспетчера сущностей, как описано в https://www.doctrine-project.org/projects/doctrine-orm/en/2.6/reference/batch-processing.html#iterating-results.
Однако при вызове flush() я получаю следующую ошибку:
PHP Fatal error: Uncaught Doctrine\DBAL\Driver\SQLSrv\SQLSrvException: SQLSTATE [42000, 3988]: [Microsoft][ODBC Driver 13 for SQL Server][SQL Server]New transaction is not allowed because there are other threads running in the session. in D:\inetpub\wwwroot\vendor\doctrine\dbal\lib\Doctrine\DBAL\Driver\SQLSrv\SQLSrvException.php:54
<?php
$batchSize = 20;
$i = 0;
$q = $em->createQuery('select u from MyProject\Model\User u WHERE credit < :minCredit');
$q->setParameter('minCredit', 20);
$iterableResult = $q->iterate();
while (($row = $iterableResult->next()) !== false) {
$em->remove($row[0]);
if (($i % $batchSize) === 0) {
$em->flush();
$em->clear();
}
++$i;
}
$em->flush();
Ответы 1
Проблема в том, что SQL Server не может начать новую транзакцию во время повторения подготовленного оператора.
Решение состоит в том, чтобы начать транзакцию, включающую подготовленный оператор, а затем зафиксировать ее после изменения всех объектов.
<?php
$conn = $em->getConnection();
$batchSize = 20;
$i = 0;
$q = $em->createQuery('select u from MyProject\Model\User u WHERE credit < :minCredit');
$q->setParameter('minCredit', 20);
$conn->beginTransaction();
try {
$iterableResult = $q->iterate();
while (($row = $iterableResult->next()) !== false) {
$em->remove($row[0]);
if (($i % $batchSize) === 0) {
$em->flush();
$em->clear();
}
++$i;
}
$em->flush();
$conn->commit();
} catch (\Exception $e) {
$conn->rollBack();
throw $e;
}