Symfony6+MySQL分页关联查询异常及QueryBuilder转换求助

问题背景 #

• 技术栈：MySQL + Symfony 6
• 表关系：Article 一对多关联 Comment，Article 多对一关联 User
• 已实现功能：按用户角色筛选文章、展示文章及关联评论、分页功能
• 核心问题：当文章存在多条评论时，关联查询会返回重复的文章记录（每条评论对应一条文章），导致分页器的LIMIT把重复记录算入总数——比如一篇有2条评论的文章会占分页的2个位置，第一页本该显示2篇文章却只显示1篇。

核心原因 #

关联查询（JOIN）会生成文章和评论的笛卡尔积，同一篇文章会随着每条评论重复输出，而分页器默认基于查询结果的行数计算，而非去重后的文章实体数量。

解决方案 #

方案1：分步查询（先拿分页ID，再查完整数据） #

先通过分组查询拿到分页后的文章ID（确保每个ID唯一），再用这些ID查询包含评论的完整文章数据，从根源避免重复记录干扰分页。

// 第一步：获取分页后的文章ID列表（去重）
$articleIdsQuery = $entityManager->createQueryBuilder()
    ->select('a.id')
    ->from(Article::class, 'a')
    ->join('a.user', 'u')
    ->where('u.roles LIKE :role') // 按角色筛选，根据实际需求调整条件
    ->setParameter('role', '%ROLE_AUTHOR%')
    ->groupBy('a.id')
    ->setMaxResults($limit) // 每页条数
    ->setFirstResult($offset); // 偏移量

$articleIds = $articleIdsQuery->getQuery()->getSingleColumnResult();

// 第二步：根据ID获取文章及关联评论
$articlesQuery = $entityManager->createQueryBuilder()
    ->select('a, c')
    ->from(Article::class, 'a')
    ->leftJoin('a.comments', 'c')
    ->where('a.id IN (:ids)')
    ->setParameter('ids', $articleIds)
    ->orderBy('a.createdAt', 'DESC');

$articles = $articlesQuery->getQuery()->getResult();

方案2：用ROW_NUMBER()窗口函数（MySQL 8.0+） #

利用MySQL的窗口函数给每个文章的评论标记行号，只保留每个文章的第一条记录用于分页计算，后续再关联所有评论。

// 子查询：给每个文章的评论标记行号
$subQuery = $entityManager->createQueryBuilder()
    ->select('a.id, ROW_NUMBER() OVER (PARTITION BY a.id ORDER BY c.createdAt DESC) as rn')
    ->from(Article::class, 'a')
    ->join('a.user', 'u')
    ->leftJoin('a.comments', 'c')
    ->where('u.roles LIKE :role')
    ->setParameter('role', '%ROLE_AUTHOR%');

// 获取分页后的文章ID
$pagedIdsQuery = $entityManager->createQueryBuilder()
    ->select('s.id')
    ->from('(' . $subQuery->getQuery()->getSQL() . ')', 's')
    ->where('s.rn = 1')
    ->groupBy('s.id')
    ->setMaxResults($limit)
    ->setFirstResult($offset);

$articleIds = $pagedIdsQuery->getQuery()->getSingleColumnResult();

// 查询完整文章及评论
$articlesQuery = $entityManager->createQueryBuilder()
    ->select('a, c')
    ->from(Article::class, 'a')
    ->leftJoin('a.comments', 'c')
    ->where('a.id IN (:ids)')
    ->setParameter('ids', $articleIds)
    ->orderBy('a.createdAt', 'DESC');

$articles = $articlesQuery->getQuery()->getResult();

方案3：Symfony分页器+DISTINCT提示（最简洁） #

利用Doctrine的分页器提示HINT_PAGINATE_DISTINCT，配合DISTINCT让分页计算基于去重后的文章实体数量，无需分步查询。

use Doctrine\ORM\Query;

// 构建查询
$queryBuilder = $entityManager->createQueryBuilder()
    ->select('DISTINCT a')
    ->from(Article::class, 'a')
    ->join('a.user', 'u')
    ->leftJoin('a.comments', 'c')
    ->where('u.roles LIKE :role')
    ->setParameter('role', '%ROLE_AUTHOR%')
    ->orderBy('a.createdAt', 'DESC');

// 初始化分页器并配置提示
$paginator = new \Doctrine\ORM\Tools\Pagination\Paginator($queryBuilder->getQuery());
$paginator->setUseOutputWalkers(false); // 关闭输出 walker，提升性能
$queryBuilder->getQuery()->setHint(Query::HINT_PAGINATE_DISTINCT, true);

// 设置分页参数
$paginator->getQuery()
    ->setMaxResults($limit)
    ->setFirstResult($offset);

// 获取结果
$articles = $paginator->getIterator()->getArrayCopy();

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