如何在 Symfony 2.4 中使用缓存 ID 和缓存生命周期选项缓存学说“findOneBy()”查询？

Question

我正在使用学说 2.4 进行 symfony 2.5 项目。

我想用缓存 id 和缓存时间来缓存查询结果，所以我可以在需要时通过管理员删除缓存结果。

我可以使用“createQueryBuilder()”选项缓存查询结果。

例子：

$this->createQueryBuilder('some_table')
                    ->select('some_table')
                    ->where('some_table.deleted_date IS NULL')
                    ->getQuery()
                    ->useResultCache(true)
                    ->setResultCacheLifetime(120) //Query Cache lifetime
                    ->setResultCacheId($queryCacheId) //Query Cache Id
                    ->getResult();

但我找不到类似的方法来查找“findOneBy()”选项的查询结果。

例子：

$this->findOneBy(array('some_field'=>$some_value));

我正在寻找一些合适的解决方案，非常感谢任何帮助。

Answer 1

您需要将每个 findBy* 或 findOneBy* 函数重新定义到自定义存储库中：这是唯一的方法，因为教义 2 默认行为不考虑这种情况。 很遗憾，这取决于你。

Ocramius（Doctrine2 开发者）也在这里说 https://groups.google.com/d/msg/doctrine-user/RIeH8ZkKyEY/HnR7h2p0lCQJ

Answer 2

为此创建一个通用函数。

 $repo->findOneByYourSufff($yourStuff, $yourRepoClass);

接下来是你的常用功能：

 public function findOneByYourSufff($yourStuff, $yourRepoClass) {


         $q = $this->createQueryBuilder()
                ->select('x.*')
                ->from($yourRepoClass, 'x');

                foreach($yourStuff as $fieldKey => $wh) {
                    $q->andWhere("b.$fieldKey = :fieldName");
                    $q->setParameter("fieldName", $wh);
                }

          $q->useResultCache(true)
                ->setResultCacheLifetime(120) //Query Cache lifetime
                ->setResultCacheId($queryCacheId) //Query Cache Id
                ->getSingleResult();

    return $q

 }

Answer 3

这是一个示例，说明如何从单个存储库中为函数缓存结果：

• findOneBy(['foo' => 'bar'])
• findOneByFoo('bar')
• findOneBy(['bar' => 'foo', 'foo' => 'bar')
• 等等...

它会覆盖EntityRepository::FindOneBy 函数。它遵循相同的签名，因此无需更新调用代码。所有FindOneBy% 类型的调用都将通过我们对findOneBy 的实现。

<?php
/**
* MyObject Repo    
*/

namespace MyLib\Entity\Repository;
use Doctrine\ORM\EntityRepository;

class MyObjectRepository extends EntityRepository
{

    const CACHE_KEY = 'my_object';
    const ALIAS = 'my_object';

    /**
     * Override - use cache.
     *
     * @param array $criteria
     * @param array|null $orderBy
     * @return mixed
     */
    public function findOneBy(array $criteria, array $orderBy = null)
    {
        $queryBuilder = $this->createQueryBuilder(self::ALIAS);
        foreach($criteria as $field => $value) {
            $queryBuilder->andWhere(self::ALIAS . ".{$field} = :{$field}")->setParameter($field, $value);
        }
        if (is_array($orderBy)) {
            foreach ($orderBy as $field => $dir) {
                $queryBuilder->addOrderBy($field, $dir);
            }
        }
        $queryBuilder->setMaxResults(1);

        $query = $queryBuilder->getQuery();

        $query->useResultCache(true, 3600, self::CACHE_KEY);

        $result = $query->getResult();

        if ($result) return reset($result);

        return $result;
    }

    /**
     * Depending how you hydrate the entities may make more 
     * sense to use cache layer at findAll
     *
     * @param void
     * @return array The entities.
     */
    public function findAll()
    {
        $query = $this->getEntityManager()->createQuery('select v from \OAS\Entity\MyObject v');

        $query->useResultCache(true, 3600, self::CACHE_KEY);

        $result = $query->getResult();

        return $result;
    }

    /**
     *
     */
    public function invalidateCache()
    {
        //this would depend on your cache implementation...
        $container = \Zend_Registry::get('doctrine');

        $cache = $container->getCacheInstance();

        $cache->delete(self::CACHE_KEY);
    }
}

如果您想说在存储库上有一个简单地打开或关闭缓存的属性，这当然可以以更 OOP 的方式完成，扩展一个中间类。您可以为其他存储库操作功能扩展类似的方法。