如何在Symfony QueryBuilder中为左连接表的每条Answer限制返回50条Vote记录

嘿，这个需求我碰到过好多次了——Doctrine的QueryBuilder确实没法直接在左连接时给关联表设置行限制，但咱们可以通过窗口函数来实现这个效果，不管是用QueryBuilder还是原生SQL都能搞定，下面给你具体的实现方式：

方法一：用Symfony QueryBuilder实现 #

核心思路是借助ROW_NUMBER()窗口函数，给每个Answer对应的Vote记录按时间排序并编号，然后只保留编号≤50的记录。假设你的实体是App\Entity\Answer和App\Entity\Vote，且Answer实体里的关联字段是votes（对应Vote里关联Answer的外键），代码如下：

$qb = $this->getDoctrine()->createQueryBuilder();

// 子查询：给每个Answer的Vote按postedTime升序编号
$voteSubQuery = $qb->createQueryBuilder()
    ->select('v, ROW_NUMBER() OVER (PARTITION BY v.answer ORDER BY v.postedTime ASC) as rn')
    ->from('App\Entity\Vote', 'v')
    ->getDQL();

// 主查询：左连接过滤后的Vote记录
$results = $qb->select('a, filteredVotes.v')
    ->from('App\Entity\Answer', 'a')
    ->leftJoin(
        sprintf('(%s)', $voteSubQuery),
        'filteredVotes',
        'WITH',
        'filteredVotes.v.answer = a.id AND filteredVotes.rn <= 50'
    )
    ->orderBy('a.id')
    ->getQuery()
    ->getArrayResult();

这段代码里，PARTITION BY v.answer会把Vote按所属的Answer分组，ROW_NUMBER()给每组内的Vote按postedTime排序后编号，最后主查询通过filteredVotes.rn <= 50过滤出每个Answer的前50条Vote。

方法二：用原生SQL实现 #

如果觉得QueryBuilder的子查询写法有点绕，直接用原生SQL会更直观，同样依赖窗口函数：

$sql = <<<SQL
SELECT a.*, v.*
FROM answer a
LEFT JOIN (
    SELECT *, ROW_NUMBER() OVER (PARTITION BY answer_id ORDER BY posted_time ASC) as rn
    FROM votes
) v ON a.id = v.answer_id AND v.rn <= 50
ORDER BY a.id, v.posted_time ASC;
SQL;

$connection = $this->getDoctrine()->getConnection();
$results = $connection->executeQuery($sql)->fetchAllAssociative();

这里子查询先给votes表按answer_id分组编号，左连接时只保留编号≤50的记录，就能得到每个Answer对应的前50条Vote了。

注意事项 #

• 窗口函数需要MySQL 8.0+、PostgreSQL 9.4+或其他支持SQL:2003标准的数据库，如果你用的是旧版数据库，可能需要用关联子查询的方式（但效率会低一些）。
• 如果你之前的QueryBuilder里直接写leftJoin('votes', 'v')是不对的，应该用实体关联的方式（比如a.votes），不过上面的方案已经规避了这个问题。

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