Symfony+Doctrine分组取最大N条数据的分页查询问题

场景与错误描述 #

需要获取所有用户的最高得分记录并实现分页，使用Doctrine Paginator时触发错误：

An exception occurred while executing a query: SQLSTATE[42S22]: Column not found: 1054 Unknown column 's1_.id' in 'field list'

实体结构 #

Score实体代码：

#[ORM\Entity(repositoryClass: ScoreRepository::class)]
#[ORM\HasLifecycleCallbacks]
class Score extends BaseEntity implements JsonSerializable
{
    #[ORM\Id]
    #[ORM\GeneratedValue]
    #[ORM\Column]
    private ?int $id = null;

    #[ORM\Column]
    private ?int $value = null;

    #[ORM\ManyToOne(inversedBy: 'scores')]
    #[ORM\JoinColumn(nullable: false)]
    private ?User $user = null;

    /** other methods */
}

原查询与SQL对比 #

原查询构建器：

$qb = $this->createQueryBuilder('s');
$subquery = $this->createQueryBuilder('b')
    ->select('MAX(b.id)')
    ->where(
        'b.value = (
            SELECT MAX(a.value)
            FROM App\Entity\Score a
            WHERE a.user = b.user
        )'
    )
    ->groupBy('b.user')
    ->getDQL();

$qb
    ->select('s')
    ->orderBy('s.value', 'DESC')
    ->where($qb->expr()->in('s.id', $subquery))
    ->setMaxResults($perPage)
    ->setFirstResult(($page - 1) * $perPage);

• 直接执行查询生成的SQL是正确的，但Paginator自动生成的SQL错误引入了子查询的表字段（如s1_.id），导致字段不存在。

修复方案 #

方案一：改用JOIN方式重构查询（推荐） #

通过子查询预获取每个用户的最高得分及对应记录ID，再与主查询JOIN，避免Paginator解析子查询时混淆表别名：

// 在ScoreRepository中实现分页查询方法
public function getTopUserScoresPaginated(int $page, int $perPage): Paginator
{
    // 子查询：获取每个用户的最高分值、对应最大记录ID（处理同用户同得分多条记录）
    $userMaxScoreQb = $this->createQueryBuilder('s_sub')
        ->select('s_sub.user, MAX(s_sub.value) AS max_value, MAX(s_sub.id) AS max_id')
        ->groupBy('s_sub.user');

    // 主查询：关联子查询，匹配用户、最高分值、对应记录ID
    $mainQb = $this->createQueryBuilder('s')
        ->join(
            sprintf('(%s)', $userMaxScoreQb->getDQL()),
            'user_max',
            \Doctrine\ORM\Query\Expr\Join::WITH,
            's.user = user_max.user AND s.value = user_max.max_value AND s.id = user_max.max_id'
        )
        ->orderBy('s.value', 'DESC')
        ->setMaxResults($perPage)
        ->setFirstResult(($page - 1) * $perPage);

    return new Paginator($mainQb);
}

方案二：关闭Paginator的关联集合抓取 #

如果希望保留原IN子查询写法，初始化Paginator时传入$fetchJoinCollection = false，让Paginator仅查询主实体ID，避免错误引入子查询字段：

// 原查询构建器代码保持不变
$qb = $this->createQueryBuilder('s');
// ... 子查询与条件设置 ...

// 初始化Paginator时传入第二个参数为false
$paginator = new \Doctrine\ORM\Tools\Pagination\Paginator($qb, false);
$results = $paginator->getIterator();

方案对比 #

• 方案一：SQL执行效率更高，逻辑清晰，完全避免Paginator的解析问题，适合生产环境使用。
• 方案二：修改量小，适合快速临时修复，但如果查询涉及关联实体（如需要同时获取User信息），可能需要额外处理关联查询。

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