Как описывать сущности для другой базы?

Question

[Максим Лагойский]

Всем привет, если в кратце то мне нужно создавать динамические подключения в бд, само подключение получилось сделать, а вот как быть с сущностями и репозиториями пока не очень понимаю.

Динамическое подключение к бд создаю

вот так(код упрощен)

$params['user'] = 'qwerty';
$params['host'] = 'localhost';
$params['port'] = 3306;
$params['dbname'] = 'test';
$params['password'] = 'test';
$params['url'] = 'mysql://qwerty:test@localhost:3306/test';

$connection = EntityManager::create(
    $params,
    $this->em->getConfiguration(),
    $this->em->getEventManager()
);

$this->em это дефолтное подключение

потом я создаю сущность в

src/Entity/Test/MyTable

и делаю выборку

$connection->getRepository(MyTable::class)->findAll();

и вроде бы работает все классно, но я вспоминаю что мне нужен репозиторий для этой сущности, я добавляю

/**
* @ORM\Entity(repositoryClass="App\Repository\Test\MyTableRepository")
* @ORM\Table(name="my_table")
*/

и сразу же ловлю ошибку что такой таблицы не существует в этой базе данных, но в ошибке видно что он ищет таблицу в дефолтной базе данных, как это исправить? может в создании нового подключения нужно еще что то добавить? или новое подключение создавать вообще как то по другому?

Comments

[Максим Федоров]

надо дебажить

Отладьте EntityManager -- посомтрите, какое подключение он юзает после создания?

[Максим Лагойский]

Максим Федоров, сам EntityManager использует нужные данные, но вот момент заметил если использовать getRepository(MyTable::class) и внутри конструктора продебажить $registry->getEntityManager() то у него уже оказывается дефолтное подключение получается как то так.

Пример

//Репозиторий
public function __construct(RegistryInterface $registry)
    {   
        $registry->getEntityManager(); //тут дефолтное подключение
        parent::__construct($registry, MyTable::class);
    }

//Контроллер к примеру
$connection = EntityManager::create(
    $params,
    $em->getConfiguration(),
    $em->getEventManager()
);
$connection->getRepository(MyTable::class)->findAll(); //тут я ловлю ошибку что такой таблицы не существует потому что в репозитории оказывается дефолтное подключение
$connection->createQueryBuilder()->from(MyTable::class, 'm')->select('m')->getQuery()->getResult(); //а тут все отрабатывает хорошо получаю данные из другой базы данных

поэтому вылазит вопрос почему в репозитории вместо моего подключения он решил потянуть дефолтное?

Answer 1

[Алексей Скобкин]

У Symfony есть документация на эту тему: https://symfony.com/doc/current/doctrine/multiple_...

А пример из реальной жизни можете посмотреть, например, у меня в этом мини-проекте. Там PostgreSQL и SQLite одновременно работают.
Внимание стоит обращать на config/packages/doctrine.yaml. Это, само собой, для заранее известных соединений.
Ну и для сущностей из каждой базы использовать свой EntityManager. Это в любом случае - не зависимо от того определены заранее или в рантайме подключения.

и сразу же ловлю ошибку что такой таблицы не существует в этой базе данных

Скорее всего, не тот EntityManager используете либо не с тем соединением его создаёте.

Comments

[Максим Лагойский]

Спасибо за пример проекта, обязательно его посмотрю, откройте пожалуйста комментарии под вопросом я там написал пример и указал что происходит если использовать queryBuilder и getRepository() как вы объясните что там происходит? Ну и вообще интересует мнение на сколько я правильно создаю новый EntityManager.

[Алексей Скобкин]

Максим Лагойский, Ну логично, да. Похоже, что у вас репозиторий инициализируется с другим EntityManager.
Попробуйте в репозитории вынимать нужный вам EntityManager. Например с помощью RegistryInterface::getEntityManager($name) или RegistryInterface::getEntityManagerForClass($class). Второе может быть проще и лучше потому что у вас уже ниже строчкой класс сущности используется - не нужно на название EM завязываться.