Symfony 5：如何让用户登录前选择要连接的数据库？

问题根源 #

你当前的代码仅在控制器中临时创建了新的EntityManager实例，但该实例仅在当前请求有效，跳转至登录页面后便会丢失。同时，手动创建EntityManager绕过了Symfony服务容器的管理机制，后续请求仍会调用默认的EntityManager服务，因此实际连接的还是默认数据库。

修正方案 #

1. 复用已配置的多EntityManager实例

你的doctrine.yaml已配置了default和SITE70两个EntityManager，直接复用这些预配置实例即可，无需通过Setup手动创建。

2. 用会话存储用户选择的数据库标识

用户选择站点后，将对应的EntityManager名称（如default或SITE70）存入会话，后续请求从会话中读取并切换实例。

3. 修改控制器，存储选择到会话

class DataBaseConnectionController extends AbstractController
{    
    /**
     * @Route("/Site", name="app_login_database_connection")
     */
    public function index(Request $request): Response {
        
        $form = $this->createFormBuilder()
            ->add('database', ChoiceType::class, [
                'choices'  => [
                    'Site1' => 'default', // 对应doctrine配置中的EntityManager名称
                    'Site2' => 'SITE70',
                ]
            ])
            ->getForm();
        $form->handleRequest($request);
        
        if ($form->isSubmitted() && $form->isValid()) {
            $selectedManager = $form->get('database')->getData();
            // 将选择存入会话
            $request->getSession()->set('selected_entity_manager', $selectedManager);
            
            return $this->redirectToRoute('app_login', [], Response::HTTP_SEE_OTHER);
        }       
        
        return $this->render('security/database.html.twig',['form' => $form->createView()]);
    }
}

4. 创建动态EntityManager服务

编写服务类，根据会话中的选择返回对应的EntityManager实例：

首先修改services.yaml：

App\Service\DynamicEntityManagerProvider:
    arguments:
        - '@doctrine'
        - '@session'

然后创建DynamicEntityManagerProvider.php：

namespace App\Service;

use Doctrine\Persistence\ManagerRegistry;
use Symfony\Component\HttpFoundation\Session\SessionInterface;

class DynamicEntityManagerProvider
{
    private $doctrine;
    private $session;

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

    public function getEntityManager()
    {
        $managerName = $this->session->get('selected_entity_manager', 'default');
        // 验证EntityManager是否存在，防止非法值
        if (!$this->doctrine->hasManager($managerName)) {
            $managerName = 'default';
        }
        return $this->doctrine->getManager($managerName);
    }
}

5. 在业务代码中使用动态EntityManager

例如在登录控制器中，注入DynamicEntityManagerProvider来获取对应实例：

class LoginController extends AbstractController
{
    public function login(
        Request $request,
        AuthenticationUtils $authenticationUtils,
        DynamicEntityManagerProvider $entityManagerProvider
    ): Response {
        $em = $entityManagerProvider->getEntityManager();
        // 使用$em执行数据库操作，如查询用户
        // $user = $em->getRepository(User::class)->findOneBy(['email' => $email]);
        
        // 剩余登录逻辑
    }
}

（可选）单连接动态切换数据库

若不想使用多EntityManager，可完善DynamicConnection类，在请求开始时从会话读取数据库URL并切换：

namespace App\Doctrine;

use Doctrine\DBAL\Connection;
use Symfony\Component\HttpFoundation\Session\SessionInterface;

class DynamicConnection extends Connection
{
    private $session;

    public function setSession(SessionInterface $session)
    {
        $this->session = $session;
    }

    public function connect()
    {
        // 从会话读取选择的数据库URL，覆盖默认配置
        if ($dbUrl = $this->session->get('selected_database_url')) {
            $params = $this->getParams();
            $params['url'] = $dbUrl;
            $this->__construct(
                $params,
                $this->_driver,
                $this->_config,
                $this->_eventManager
            );
        }
        parent::connect();
    }
}

在services.yaml中注入Session：

App\Doctrine\DynamicConnection:
    calls:
        - [setSession, ['@session']]

此时控制器中需存储数据库URL：

// 控制器内修改存储逻辑
$selectedUrl = $form->get('database')->getData() === '1' 
    ? $_ENV['DATABASE_URL'] 
    : $_ENV['SITE70_DATABASE_URL'];
$request->getSession()->set('selected_database_url', $selectedUrl);

关键注意事项 #

• 确保会话配置正常，用户选择的标识能在后续请求中稳定读取。
• 使用多EntityManager方式时，所有业务代码需通过DynamicEntityManagerProvider获取实例，避免直接注入默认的EntityManagerInterface。
• 测试时可通过dd($request->getSession()->all())验证会话存储值，或执行查询确认连接的数据库是否正确。

内容的提问来源于stack exchange，提问作者Otmane