Symfony2组织:在哪里放置与数据库和其他实体交互的实体函数


Symfony2 organization: where to put entity functions that interact with database and other entities

我已经将一个PHP应用程序转换为Symfony2,并且还有另一个结构问题...

在我的旧应用程序中,我将具有可能作用于其他实体类的实体类......例如,我有一个搜索类和一个结果类。像search->updateSearch()这样的函数将对搜索类及其子结果类($this->result->setFoo('bar'))进行操作。这只是不属于Symfony2实体类的实体相关函数的一个例子。

据我所知,似乎最symfonyesque的方法是创建一个服务,类似于searchHelper类,我可以将实体管理器,$search和$result类传递给该服务,并在那里对它们进行操作。

这听起来像是最好的行动方案吗?

谢谢!

对于此场景,我使用模型管理器,它旨在成为用于操作实体的业务层ORM不可知的接口。像这样:

<?php
/**
 * Group entity manager
 */
class GroupManager
{
    /**
     * Holds the Doctrine entity manager for database interaction
     * @var EntityManager
     */
    protected $em;
    /**
     * Holds the Symfony2 event dispatcher service
     * @var EventDispatcherInterface
     */
    protected $dispatcher;
    /**
     * Entity specific repository, useful for finding entities, for example
     * @var EntityRepository
     */
    protected $repository;
    /**
     * Constructor
     *
     * @param EventDispatcherInterface $dispatcher
     * @param EntityManager $em
     * @param string $class
     */
    public function __construct(EventDispatcherInterface $dispatcher, EntityManager $em)
    {
        $this->dispatcher = $dispatcher;
        $this->em = $em;
        $this->repository = $em->getRepository($class);
    }
    /**
     * @return Group
     */
    public function findGroupBy(array $criteria)
    {
        return $this->repository->findOneBy($criteria);
    }
    /**
     * @return Group
     */
    public function createGroup()
    {
        $group = new Group();
        // Some initialization or creation logic
        return $group;
    }
    /**
     * Update a group object
     *
     * @param Group $group
     * @param boolean $andFlush
     */
    public function updateGroup(Group $group, $andFlush = true)
    {
        $this->em->persist($group);
        if ($andFlush) {
            $this->em->flush();
        }
    }
    /**
     * Add a user to a group
     *
     * @param User $user
     * @param Group $group
     * @return Membership
     */
    public function addUserToGroup(User $user, Group $group)
    {
        $membership= $this->em->getRepository('GroupBundle:Membership')
        ->findOneBy(array(
            'user'  => $user->getId(),
            'group' => $group->getId(),
        ));
        if ($membership && $membership->isActive()) {
            return null;
        } elseif ($membership && !$membership->isActive()) {
            $membership->setActive(true);
            $this->em->persist($membership);
            $this->em->flush();
        } else {
            $membership = new Membership();
            $membership->setUser($user);
            $membership->setGroup($group);
            $this->em->persist($membership);
            $this->em->flush();
        }
        $this->dispatcher->dispatch(
            GroupEvents::USER_JOINED_GROUP, new MembershipEvent($user, $group)
        );
        return $membership;
    }

然后是服务定义:

<service id="app.model_manager.group" class="App'GroupBundle'Entity'GroupManager">
    <argument type="service" id="event_dispatcher" />
    <argument type="service" id="doctrine.orm.entity_manager" />
</service>

您可以注入记录器、邮件程序、路由器或您可能需要的任何其他服务。

查看 FOSUserBundle 管理器,以获取有关如何使用它们的示例和想法。

听起来你应该使用教义自定义存储库类。你可以在这里查看它们: http://symfony.com/doc/current/book/doctrine.html#custom-repository-classes

基本上,它们允许您在基本实体之上和之外添加自定义逻辑。另外,因为它们基本上是实体的扩展,所以加载它们并使用它们的函数变得非常容易:

//Basic Entity File
/**
 * @ORM'Entity(repositoryClass="Namespace'Bundle'Repository'ProductRepo")
 */
class Product
{
    //...
}

然后,该实体的存储库文件:

//Basic Repo File
use Doctrine'ORM'EntityRepository;
class ProductRepo extends EntityRepository
{
    public function updateSearch($passedParam)
    {
       // Custom query goes here
    }
}

然后,从控制器中,您可以加载存储库并使用以下函数:

//Controller file
class ProductController extends Controller
{
    public function updateSearchAction()
    {
         $productRepo = $this->getDoctrine()->getManager()->getRepository('Namespace'Bundle'Entity'Product');
         // Set $passedParam to what ever it needs to be
         $productRepo->updateSearch($passedParam);
    }
}