Как подменить используемый EntityManager?

Question

[HellWalk]

Есть ли способ через конфиг симфони подменить используемый по умолчанию Doctrine\ORM\EntityManager например на App\Proxy\EntityManagerProxy?

Т.е. указываю EntityManagerInterface в конструкторе, и контейнер понимал, что нужно создать App\Proxy\EntityManagerProxy (реализующий этот же интерфейс), а не стандартный Doctrine\ORM\EntityManager

Comments

[tukreb]

Согласно https://github.com/symfony/symfony/issues/48124#is...
Proxy используется через ServiceEntityRepository

[gaparchi]

Просто интересно, для чего тебе это?

Doctrine\ORM\EntityManagerInterface:
   class: App\Proxy\EntityManagerProxy

Так не работает?

[HellWalk]

gaparchi, не работает:

Symfony\Component\DependencyInjection\Exception\RuntimeException: Cannot autowire service "Doctrine\ORM\EntityManagerInterface": argument "$entityManager" of method "App\Proxy\EntityManagerProxy::__construct()" references class "Doctrine\ORM\EntityManager" but no such service exists. Try changing the type-hint to "Doctrine\ORM\EntityManagerInterface" instead.

А если сделать

Doctrine\ORM\EntityManagerInterface:
    public: true
    class: App\Proxy\EntityManagerProxy

То ошибка:

Symfony\Component\DependencyInjection\Exception\ServiceCircularReferenceException: Circular reference detected for service "Doctrine\ORM\EntityManagerInterface", path: "Doctrine\ORM\EntityManagerInterface -> Doctrine\ORM\EntityManagerInterface".

Если переделать Proxy, и зависимость на EntityManagerInterface заменить на EntityManager, то ошибка:

Symfony\Component\DependencyInjection\Exception\RuntimeException: Cannot autowire service "Doctrine\ORM\EntityManagerInterface": argument "$entityManager" of method "App\Proxy\EntityManagerProxy::__construct()" references class "Doctrine\ORM\EntityManager" but no such service exists. Try changing the type-hint to "Doctrine\ORM\EntityManagerInterface" instead.

Просто интересно, для чего тебе это?

Чтобы EntityManager переподключался в базе в случае ошибки SQL (по неведомой причине, разработчики доктрины посчитали, что если была SQL ошибка, то с базой можно дальше не работать).

Answer 1

[Денис Дерепко]

https://symfony.com/doc/current/service_container/...

Comments

[HellWalk]

Не работает:

class DemoComponent
{
    private EntityManagerInterface $em;

    /**
     * @param EntityManagerInterface $em
     */
    public function __construct(EntityManagerInterface $em)
    {
        $this->em = $em;
    }

    /**
     * @return EntityManagerInterface
     */
    public function getEm(): EntityManagerInterface
    {
        return $this->em;
    }
}

Doctrine\ORM\EntityManager:
  class: App\Proxy\EntityManagerProxy

App\Components\DemoComponent:
  public: true

public function testDoctrine(): void
    {
        $demo = self::$container->get(DemoComponent::class);

        var_dump(get_class($demo->getEm())); // Doctrine\ORM\EntityManager
    }

Что делаю не так?

[Денис Дерепко]

HellWalk, то что даже не читаете документацию по ссылке

[HellWalk]

Денис Дерепко, с чего сделан такой вывод?

[Денис Дерепко]

HellWalk, по конфигу. Сравните документацию и ваш конфиг

[HellWalk]

Денис Дерепко, с тем же успехом можно отправить в гугл со словами "там все есть, ищите"

[Денис Дерепко]

HellWalk, так и есть, я привёл ссылку где описано ровно то что вам нужно

[HellWalk]

Денис Дерепко, а оно, внезапно, не помогает.

Но вам, конечно, на это плевать. Вы же заходите сюда ЧСВ свое потешить.

[Денис Дерепко]

HellWalk, что не помогает то? Как говорил выше сравните конфиги и поймёте что не так. Перечитайте документацию и посмотрите на ваш код

[Денис Дерепко]

Цитаты из доки:

services:
    App\Mailer: ~

    App\DecoratingMailer:
        decorates: App\Mailer
        # pass the old service as an argument
        arguments: ['@.inner']

// src/Service/DecoratorService.php
namespace App\Service;

use Acme\OptionalBundle\Service\OptionalService;

class DecoratorService
{
    private $decorated;

    public function __construct(?OptionalService $decorated)
    {
        $this->decorated = $decorated;
    }

    public function tellInterestingStuff(): string
    {
        if (!$this->decorated) {
            return 'Just one interesting thing';
        }

        return $this->decorated->tellInterestingStuff().' + one more interesting thing';
    }
}

Где у вас декоратор, который будет передаваться в нужный сервис?

[HellWalk]

Денис Дерепко, неужели, пошла какая-то конкретика.

Вы написали:

services:
    App\Mailer: ~

    App\DecoratingMailer:
        decorates: App\Mailer
        # pass the old service as an argument
        arguments: ['@.inner']

Делаю по аналогии:

services:
  Doctrine\ORM\EntityManagerInterface: ~

  App\Proxy\EntityManagerProxy:
    decorates: Doctrine\ORM\EntityManagerInterface
    arguments: ['@.inner']

Получаю ошибку:

Error: Cannot instantiate interface Doctrine\ORM\EntityManagerInterface

Где у вас декоратор, который будет передаваться в нужный сервис?

Где, или что в нем? Где он понятно из конфига: App\Proxy\EntityManagerProxy

[Денис Дерепко]

неужели, пошла какая-то конкретика

Так посмотрите на своей первый коммент, там ничего такого нет

Error: Cannot instantiate interface Doctrine\ORM\EntityManagerInterface

Нельзя создать экземпляр интерфейса да и вообще кажется можно убрать
Doctrine\ORM\EntityManagerInterface: ~
и вместо

decorates: Doctrine\ORM\EntityManagerInterface написать:

decorates: '@doctrine.orm.entity_manager'

[HellWalk]

Денис Дерепко, неужели, правда нужно без @:

App\Proxy\EntityManagerProxy:
    decorates: 'doctrine.orm.entity_manager'

И больше ничего не нужно (строка "Doctrine\ORM\EntityManagerInterface: ~" вызывает ошибку)

Большое спасибо.

Но будем честны - в документации не сказано о том, что в некоторых ситуациях чтобы подменить класс нужно указывать именно имя службы в таком формате. А не сам класс/интерфейс.

Потому что пока вы писали про "посмотри документацию" - я её перечитал 3 раза и перепробовал штук 5 разных способов - ничего не работало. Ну а приводить кучу нерабочих вариантов - это была бы просто стена текста. По этому я ждал какой-то конкретики от вас, и уже от неё двигаться.

[Денис Дерепко]

HellWalk, Из-за первого коммента казалось что вы не читали документацию и просто предоставили старый код

[HellWalk]

Сейчас напишу свой развернутый ответ по решению вопроса, и отмечу решением его и ваш ответ.

Потому что отмечать решением просто ссылку на документацию, которая никак не помогает решить задачу с подменой EntityManager - такое себе.

Answer 2

[HellWalk]

Не смотря на наличие документации на которую сослался Денис Дерепко, она мало помогает в задаче подменить именно EntityManager, и именно когда к нему идет обращение в зависимостях через EntityManagerInterface.

По этому отдельным ответом пишу решение:

config/services.yaml:

App\Proxy\EntityManagerProxy:
    decorates: 'doctrine.orm.entity_manager'

Proxy-обертка (здесь оставив за скобками почему в документации декоратор, а в моем случае proxy) с нужным функционалом - чтобы EntityManager переподключался в базе в случае потери соединения с базой (а доктрина закрывает соединение в случае любой SQL-ошибки):

class EntityManagerProxy implements EntityManagerInterface
{
    private ObjectManager $entityManager;
    private ManagerRegistry $doctrine;

    public function __construct(ObjectManager $entityManager, ManagerRegistry $doctrine)
    {
        $this->entityManager = $entityManager;
        $this->doctrine = $doctrine;
    }

    /**
     * @param $object
     * @return void
     * @throws Exception
     */
    public function persist($object): void
    {
        $this->correctionConnect();
        $this->entityManager->persist($object);
    }

    /**
     * @return void
     * @throws Exception
     */
    public function flush(): void
    {
        $this->correctionConnect();
        $this->entityManager->flush();
    }


    private function correctionConnect(): void
    {
        // Для ошибок когда падает сама база или соединение с ней, например:
        // SQLSTATE[57P01]: Admin shutdown: 7 FATAL:  terminating connection due to administrator command
        // SQLSTATE[08006] [7] could not translate host name "postgres" to address: Temporary failure in name resolution
        // (например, когда на время падает контейнер с postgres)
        if ($this->entityManager->getConnection()->ping() === false) {
            $this->entityManager->getConnection()->close();
            $this->entityManager->getConnection()->connect();
        }

        // Для ошибки "The EntityManager is closed" (например, при ошибки SQL-запроса)
        if (!$this->entityManager->isOpen()) {
            $this->doctrine->resetManager();
            $this->entityManager = $this->doctrine->getManager();
        }
    }
    
    // Все другие методы для EntityManagerInterface перебрасываются напрямую на базовый EntityManager