Почему не берет данные из другой бд?

Question

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

Решил попробовать использовать несколько бд, посмотрел доки, взял конфиг от туда, но что то не получается.

Вот конфиг

doctrine:
    dbal:
        default_connection: default
        connections:
            default:
                # configure these for your database server
                url: '%env(DATABASE_URL)%'
                driver: 'pdo_mysql'
                server_version: '5.7'
                charset: utf8mb4
            customer:
                # configure these for your database server
                url: '%env(DATABASE_CUSTOMER_URL)%'
                driver: 'pdo_mysql'
                server_version: '5.7'
                charset: utf8mb4

    orm:
        default_entity_manager: default
        entity_managers:
            default:
                connection: default
                mappings:
                    Main:
                        is_bundle: false
                        type: annotation
                        dir: '%kernel.project_dir%/src/Entity'
                        prefix: 'App\Entity'
                        alias: Main
            customer:
                connection: customer
                mappings:
                    Customer:
                        is_bundle: false
                        type: annotation
                        dir: '%kernel.project_dir%/src/Entity'
                        prefix: 'App\Entity'
                        alias: Customer

В каждой из бд создал таблицу User и залил разные данные.
Но при такой выборке я все равно получаю данные из дефолтного подключения. Что я сделал не так?

$this->getDoctrine()->getRepository(User::class, 'customer')->findAll();

Comments

[BoShurik]

Создал проект с нуля с вашими конфигами. Все работает

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

BoShurik, хммм, попробовал из под консоли создать бд, миграции использовав 2-е подключение все нормально отработало, а в контроллере все равно не хочет, мб кэш какой?

[BoShurik]

Максим Лагойский, может быть. Мой код, на всякий случай:

/**
 * @Route(path="/")
 */
public function indexAction(\Symfony\Bridge\Doctrine\RegistryInterface $registry)
{
    $repository = $registry->getRepository(Post::class, 'default');
    dump($repository->findAll());

    return new Response();
}

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

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

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

BoShurik, если делаю вот так то падает с ошибкой

$customerEntityManager = $this->get('doctrine.orm.customer_entity_manager');

может в конфиге с сервисами что то нужно?

[BoShurik]

Максим Лагойский, Как создать сервис для класса и передать туда аргументы Symfony 4?

services:
    _defaults:
        autowire: true
        autoconfigure: true
        bind:
            \Doctrine\ORM\EntityManagerInterface $customerEntityManager: '@doctrine.orm.customer_entity_manager'

А в коде уже использовать инъекцию зависимостей через конструктор:

public function __construct(EntityManagerInterface $customerEntityManager)

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

BoShurik, но я так полагаю это все равно не обязательно для работы такого кода?

$customers = $this->getDoctrine()
            ->getRepository(Customer::class, 'customer')
            ->findAll()
        ;

[BoShurik]

Максим Лагойский, да, конечно. Это к тому. что код

$this->get('doctrine.orm.customer_entity_manager');

попахивает

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

BoShurik, короче попробовал писать sql запросы в консоли, все отлично работает, я даже не знаю что думать, как найду решение обязательно отпишу)

Answer 1

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

Короче ошибка в namespace-ах, у меня они одинаковые были, сделал разные namespace сразу все нормально стало.

Answer 2

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

Читаем документацию: https://symfony.com/doc/current/doctrine/multiple_...

$entityManager = $this->getDoctrine()->getManager('default');
$customerEntityManager = $this->getDoctrine()->getManager('customer');

Comments

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

Иии? если там же написано

// Retrieves a repository managed by the "customer" em
        $customers = $this->getDoctrine()
            ->getRepository(Customer::class, 'customer')
            ->findAll()
        ;