Doctrine ORM教程：通过关联实体字段数组高效筛选数据

admin 百科 2025-12-13 11

本教程旨在解决如何使用doctrine orm，通过一个包含关联实体字段值（如城市slug）的数组，高效地筛选出主实体（如列表项）的问题。文章将详细阐述如何利用dql的`join`语句结合`in`表达式，在单次数据库查询中完成这一复杂筛选，从而避免多余的查询和内存处理，优化数据检索性能。

场景描述与问题背景

在开发实践中，我们经常需要根据关联实体（例如一个城市的属性）来筛选主实体（例如该城市下的所有列表项）。一个常见的需求是，给定一个城市标识符（如slug）的数组，筛选出所有属于这些城市的列表项。

考虑以下两个实体：City（城市）和Listing（列表项）。 City实体包含id、name和slug字段。 Listing实体包含id、name，并通过city字段与City实体建立多对一（ManyToOne）关系，即一个Listing属于一个City。

Doctrine ORM教程：通过关联实体字段数组高效筛选数据-第2张图片-佛山资讯网

// app/src/Entity/Listing.php
namespace App\Entity;

use Doctrine\ORM\Mapping as ORM;

/**
 * @ORM\Entity(repositoryClass=ListingRepository::class)
 * @ORM\Table(name="listings", schema="app")
 */
class Listing
{
    /**
     * @ORM\Id
     * @ORM\GeneratedValue()
     * @ORM\Column(type="integer")
     */
    private int $id;

    /** @ORM\Column(type="string", length=255, nullable=false) */
    private string $name;

    /** @ORM\ManyToOne(targetEntity=City::class, inversedBy="listings") */
    private City $city;

    // ... 其他字段和方法
}

登录后复制

// app/src/Entity/City.php
namespace App\Entity;

use Doctrine\Common\Collections\Collection;
use Doctrine\ORM\Mapping as ORM;

/**
 * @ORM\Entity(repositoryClass=CityRepository::class)
 * @ORM\Table(name="cities", schema="app")
 */
class City
{
    /**
     * @ORM\Id
     * @ORM\GeneratedValue()
     * @ORM\Column(type="integer")
     */
    private int $id;

    /** @ORM\Column(type="string", length=255, nullable=false) */
    private string $name;

    /** @ORM\Column(type="string", length=255, nullable=false) */
    private string $slug;

    /** @ORM\OneToMany(targetEntity=Listing::class, mappedBy="city") */
    private Collection $listings;

    // ... 其他字段和方法
}

登录后复制

我们的目标是，给定一个城市slug数组，例如 ['new_york', 'rome', 'hong_kong']，如何高效地查询出所有属于这些城市的Listing实体。

传统（低效）解决方案及其局限性

一种直观但效率较低的方法是分两步进行：

首先，根据给定的slug数组查询所有对应的City实体。
然后，从这些City实体中提取出它们的ID。
最后，使用这些ID作为条件，通过IN表达式查询Listing实体。

代码示例（非最佳实践）：

// 在ListingRepository中
use Doctrine\DBAL\Connection;

class ListingRepository extends ServiceEntityRepository
{
    // ... 构造函数等

    /**
     * @param City[] $cities
     * @return Listing[]
     */
    public function findAllByCitiesInefficiently(array $cities): array
    {
        // 步骤2: 提取城市ID
        $citiesIds = array_map(static fn(City $city): int => $city->getId(), $cities);

        // 步骤3: 使用城市ID查询Listing
        $qb = $this->createQueryBuilder('l');
        return $qb
            ->select('l')
            ->where($qb->expr()->in('l.city', ':cities'))
            ->setParameter('cities', $citiesIds, Connection::PARAM_STR_ARRAY)
            ->getQuery()
            ->getResult();
    }

    // 假设在某个服务或控制器中先获取城市实体
    // public function someServiceMethod(array $citySlugs) {
    //     $cities = $this->cityRepository->findBy(['slug' => $citySlugs]); // 步骤1
    //     return $this->listingRepository->findAllByCitiesInefficiently($cities);
    // }
}

登录后复制

这种方法的缺点在于：