带子查询的 Doctrine Update 查询

Question

我正在尝试使用 Doctrine dql 执行类似于以下查询的查询：

Doctrine_Query::create()
              ->update('Table a')
              ->set('a.amount',
                    '(SELECT sum(b.amount) FROM Table b WHERE b.client_id = a.id AND b.regular = ? AND b.finished = ?)',
                    array(false, false))
              ->execute();

但它会引发 Doctrine_Query_Exception 并显示消息：“未知组件别名 b”

是关于在“set”子句中使用子查询的限制，您可以吗给我一些帮助吗？

提前致谢。

Answer 1

几年后但可能会有所帮助。

是]

如果您需要/想要/必须，您可以使用Querybuilder来执行具有子选择语句的更新查询，而不是直接使用底层连接层。
这里的想法是使用 QueryBuilder 两次。

• 构建一个 select 语句来计算新值。
• 构建实际的更新查询以提交到数据库，您将在其中注入前一个选择 DQL，如您所期望的那样，以便发出单个数据库请求。

示例]

给定一个用户可以出售物品的应用程序。每笔交易都涉及买方和卖方。交易结束后，卖家和买家可以留下评论，了解对方的交易进展情况。
您可能需要一个用户表、一个审核表和一个交易表。
用户表包含一个名为评级的字段，它将保存用户的平均评级。 Review 表存储事务 ID、作者 ID（提交评论的人）、值（从 0 到 5）。最后，交易包含对卖方和买方的参考。

现在假设您想在对方提交评论后更新用户的平均评分。更新查询将计算用户的平均评分，并将结果作为 User. rating 属性的值。
我将以下代码片段与 Doctrine 2.5 和 Symfony3 结合使用。由于这项工作是关于用户的，因此我在 AppBundle\Entity\UserRepository.php 存储库中创建一个名为 updateRating( User $user) 的新公共函数是有意义的。

/**
 * Update the average rating for a user
 * @param User $user The user entity object target
 */
public function updateRating( User $user )
{
    // Compute Subrequest. The reference table being Transaction, we get its repository first.
    $transactionRepo = $this->_em->getRepository('AppBundle:Transaction');
    $tqb = $postRepo->createQueryBuilder('t');
    #1 Computing select
    $select = $tqb->select('SUM(r.value)/count(r.value)')
        // My Review table as no association declared inside annotation (because I do not need it elsewhere)
        // So I need to specify the glue part in order join the two tables
        ->leftJoin('AppBundle:Review','r', Expr\Join::WITH, 'r.post = p.id AND r.author <> :author')
        // In case you have an association declared inside the Transaction entity schema, simply replace the above leftJoin with something like
        // ->leftJoin(t.reviews, 'r')
        // Specify index first (Transaction has been declared as terminated)
        ->where( $tqb->expr()->eq('t.ended', ':ended') )
        // The user can be seller or buyer
        ->andWhere( $tqb->expr()->orX(
            $tqb->expr()->eq('t.seller', ':author'),
            $tqb->expr()->eq('t.buyer', ':author')
        ));
    #2 The actual update query, containing the above sub-request
    $update = $this->createQueryBuilder('u')
        // We want to update a row
        ->update()
        // Setting the new value using the above sub-request
        ->set('u.rating', '('. $select->getQuery()->getDQL() .')')
        // should apply to the user we want
        ->where('u.id = :author')
        // Set parameters for both the main & sub queries
        ->setParameters([ 'ended' => 1, 'author' => $user->getId() ]);
    // Get the update success status
    return $update->getQuery()->getSingleScalarResult();
}

现在从控制器

            // … Update User's rating
            $em->getRepository('AppBundle:User')->updateRating($member);
            // …

Answer 2

我不确定这是否有限制，但我记得不久前曾与此进行过斗争。我最终让它工作起来：

$q = Doctrine_Manager::getInstance()->getCurrentConnection();
$q->execute("UPDATE table a SET a.amount = (SELECT SUM(b.amount) FROM table b WHERE b.client_id = a.id AND b.regular = 0 AND b.finished = 0)");

看看这是否有效。请注意，此查询不会执行自动变量转义，因为它不是 DQL。