有没有办法在 Doctrine ORM 中为 UPDATE 查询添加限制？

Question

我正在使用 Doctrine 2.5.x，但在让 LIMIT 子句用于 UPDATE 查询时遇到问题。它总是更新所有匹配的记录（即它似乎忽略了 LIMIT 子句）。

setMaxResults() 与 UPDATE 查询一起使用时似乎没有效果。

作为一种快速解决方法，我使用的是原生 MySQL 查询，但这不是最佳解决方案。

我尝试了这些示例，但没有一个有效：

Doctrine update query with LIMIT

https://recalll.co/app/?q=doctrine2%20-%20Doctrine%20update%20query%20with%20LIMIT

带有setMaxResults() 的QueryBuilder（不起作用）：

$qb = $em->createQueryBuilder();

$query = $qb->update('\Task\Entity', 't')
    ->set('t.ClaimedBy', 1)
    ->where('t.Claimed IS NULL')
    ->getQuery();
$query->setMaxResults(20);

$this->log($query->getSQL());

希望有人可以帮助找到比原生查询更好的解决方案。它带走了 ORM 的全部好处。

是否可以在 UPDATE 语句中使用 LIMIT 子句？

Answer 1

简而言之，不，因为 SQL 规范不支持UPDATE ... LIMIT ...，所以任何试图实现可移植性的 ORM 都不应该允许您这样做。

---

还请查看MySQL Reference Manual 本身说明UPDATE ... LIMIT ... 不是标准SQL 构造：

MySQL Server 支持一些您可能在其他 SQL DBMS 中找不到的扩展。请注意，如果您使用它们，您的代码将无法移植到其他 SQL 服务器。在某些情况下，您可以使用以下形式的 cmets 编写包含 MySQL 扩展但仍可移植的代码：

• SQL 语句语法
  • UPDATE 和 DELETE 语句的 ORDER BY 和 LIMIT 子句。

所以本质上，因为您要实现的不是标准 SQL，所以 ORM 将没有可移植的方式来实现它，并且可能根本不会实现它。

---

抱歉，您试图通过 DQL 实现的目标是不可能的，因为：

Ocramius 于 2014 年 9 月 2 日发表评论
DQL 不允许限制 UPDATE 查询，因为它不可移植。

正如 DoctrineBundle 存储库的 this issue 所建议的，它的所有者 Marco Pivetta（他也恰好是 ORM 存储库的所有者）。

更多信息，虽然它可能需要一个很好的链接到正确的 ISO 规范文档，遗憾的是不能免费获得：

UPDATE 指令的 ISO 标准不允许在 UPDATE 中允许 LIMIT，其中 SELECT 当然是允许它的指令。

正如您自己提出的那样，ORM 的目的是不编写纯 SQL 以使其与 DBMS 兼容。如果不可能做到这一点，那么 ORM 没有实现它是有道理的。

另请注意，在 MYSQL 以外的其他 SQL 变体上，限制实际上是 SELECT 子句的一部分：

select * from demo limit 10

将在 SQL Server 中转换为

select top 10 from demo

或者在 Orcale 中

select * from demo WHERE rownum = 1

另见：https://stackoverflow.com/a/1063937/2123530

Answer 2

正如 b.enoit.be 在他的回答中已经说明的那样，this is not possible 在 Doctrine 中，因为在 UPDATE 语句中使用 LIMIT 是不可移植的（仅在 MySQL 中有效）。

希望有人可以帮助找到比原生查询更好的解决方案。它带走了 ORM 的全部好处。

我认为您是在将业务规则与持久性混合在一起（幸运的是，ORM 不能很好地处理这一点）。

让我解释一下： 更新实体的状态不一定是业务规则。更新最大值20 个实体是（这 20 个是从哪里来的？）。

为了解决这个问题，您应该通过将业务规则和持久性分离到服务中来正确分离它。

class TaskService
{

    private $taskRepository;

    public function __construct(TaskRepository $taskRepository)
    {
        $this->taskRepository = $taskRepository;
    }

    public function updateClaimedBy()
    {
        $criteria = ['Claimed' => null];
        $orderBy = null;

        // Only update the first 20 because XYZ
        $limit = 20;

        $tasks = $taskRepository->findBy($criteria, $orderBy, $limit);

        foreach($tasks as $task) {
            $task->setClaimedBy(1)
        }
    }

}