使用Doctrine 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;

    // ... getters and setters
}

/**
 * @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;

    // ... getters and setters
}

// 在 CityRepository 中
public function findCitiesBySlugs(array $slugs): array
{
    return $this->createQueryBuilder('c')
        ->where('c.slug IN (:slugs)')
        ->setParameter('slugs', $slugs, Connection::PARAM_STR_ARRAY)
        ->getQuery()
        ->getResult();
}

// 在 ListingRepository 中
public function findAllByCities(array $cities): array
{
    $citiesIds = array_map(static fn(City $city): int => $city->getId(), $cities);

    if (empty($citiesIds)) {
        return []; // 避免空数组导致SQL错误
    }

    $qb = $this->createQueryBuilder('l');
    return $qb
        ->select('l')
        ->where($qb->expr()->in('l.city', ':cities'))
        ->setParameter('cities', $citiesIds, Connection::PARAM_INT_ARRAY) // 使用PARAM_INT_ARRAY
        ->getQuery()
        ->getResult();
}

// 使用示例
$citySlugs = ['new_york', 'rome'];
$cities = $cityRepository->findCitiesBySlugs($citySlugs);
$listings = $listingRepository->findAllByCities($cities);

use Doctrine\ORM\QueryBuilder;
use Doctrine\DBAL\Connection; // 引入Connection类，用于参数类型

class ListingRepository extends ServiceEntityRepository
{
    // ... 其他方法

    /**
     * 根据城市slug数组查询所有相关的Listing实体。
     *
     * @param array $citySlugs 城市slug的数组，例如 ['new_york', 'rome']
     * @return Listing[]
     */
    public function findAllByCitySlugs(array $citySlugs): array
    {
        if (empty($citySlugs)) {
            return []; // 如果城市slug数组为空，则直接返回空结果
        }

        $qb = $this->createQueryBuilder('l'); // 'l' 是 Listing 实体的主别名

        return $qb
            ->select('l') // 选择 Listing 实体
            ->join('l.city', 'c') // 将 Listing 实体与关联的 City 实体连接，'c' 是 City 的别名
            ->where($qb->expr()->in('c.slug', ':cities')) // 在 City 实体的 slug 字段上使用 IN 条件
            ->setParameter('cities', $citySlugs, Connection::PARAM_STR_ARRAY) // 设置参数，指定为字符串数组类型
            ->getQuery() // 获取查询对象
            ->getResult(); // 执行查询并返回结果
    }
}