Symfony：动态更改数据库

Question

假设我有3个数据库：

• prefix_db1
• prefix_db2
• prefix_db3
  

而且我想像这样从url动态连接到它们，http://localhost/my-project/web/app_dev.php/db1/books所以我知道要从url连接到 哪个数据库（在这种情况下prefix_db1）
，基本上的想法是准备一个将随每个http请求触发的侦听器，获取数据库从URL名称，然后覆盖doctrin的参数，可以是这样的：
在services.yml：

dynamic_connection:
        class: AppBundle\service\DynamicDBConnector
        arguments:  ['@request_stack']
        calls:
            - [ setDoctrineConnection, ['@doctrine.dbal.default_connection'] ]
        tags:
            - { name: kernel.event_listener, event: kernel.request, method: onKernelRequest }

我的听众：

<?php    
namespace AppBundle\service;

use Doctrine\DBAL\Connection;
use Symfony\Component\HttpFoundation\RequestStack;
use Exception;

class DynamicDBConnector
{
    /**
     * @var Connection
     */
    private $connection;

    /*
     * @var Request
     */
    private $request;


    public function __construct(RequestStack $requestStack)
    {
        $this->request = $requestStack->getCurrentRequest();

    }

    /**
     * Sets the DB Name prefix to use when selecting the database to connect to
     *
     * @param  Connection       $connection
     * @return DynamicDBConnector $this
     */
    public function setDoctrineConnection(Connection $connection)
    {
        $this->connection = $connection;
        return $this;
    }

    public function onKernelRequest()
    {
        if ($this->request->attributes->has('_company')) {

            $connection = $this->connection;
            $params     = $this->connection->getParams();

            $companyName = $this->request->get('_company');
            // I did the concatenation here because in paramaters.yml I just put the prefix (database_name: prefix_) so after the concatenation I get the whole database name "prefix_db1"
            $params['dbname'] = $params['dbname'] . $companyName;

            // Set up the parameters for the parent
            $connection->__construct(
                $params,
                $connection->getDriver(),
                $connection->getConfiguration(),
                $connection->getEventManager()
            );

            try {
                $connection->connect();
            } catch (Exception $e) {
                // log and handle exception
            }
        }

        return $this;
    }
}

现在，这个方法非常有效，我已经使用一个简单的书籍列表对其进行了测试，并且每次更改url时，都会得到与每个数据库相关的列表：

http://localhost/my-project/web/app_dev.php/db1/books // I get books of database prefix_db1

http://localhost/my-project/web/app_dev.php/db2/books // I get books of database prefix_db2

现在让我们开始解决问题：)：
现在的问题是，当我使用身份验证系统保护我的项目并尝试user使用此URL 登录（当然每个数据库都有表）时，http://localhost/my-project/web/app_dev.php/db1/login 我会收到此异常：

An exception occured in driver: SQLSTATE[HY000] [1049] Base 'prefix_' unknown

如您所见，symfony尝试使用parameters.yml中database_name声明的名称登录用户，这意味着symfony的已经在我的侦听器之前以及在覆盖Doctrine的之前被激发了。我的问题： 有没有办法在其他任何HTTP请求侦听器之前触发我的侦听器？或者可能是另一种解决方案，以确保对数据库的任何请求都必须使用正确的数据库名称。 抱歉，很长的帖子。编辑： 从symfony的官方文档：https : //symfony.com/doc/2.3/cookbook/event_dispatcher/event_listener.htmlsecurity_checkerparams

另一个可选的标签属性称为优先级，它的默认值为0，它控制侦听器的执行顺序（优先级越高，侦听器执行的越早）。当您需要确保一个侦听器先于另一个侦听器执行时，这很有用。内部Symfony侦听器的优先级通常在-255到255之间，但是您自己的侦听器可以使用任何正整数或负整数。

我将侦听器的优先级设置为10000：

tags:
    - { name: kernel.event_listener, event: kernel.request, method: onKernelRequest, priority: 10000 }

但是问题仍然存在，在symfony之前仍然无法解雇我的听众！

Answer 1

我找到了一个解决方案，
其想法是更改Connectionsymfony用于创建数据库连接的默认类：

doctrine:
    dbal:
        connections:
            default:
                wrapper_class: AppBundle\Doctrine\DynamicConnection
                driver: pdo_mysql
                host: '%database_host%'
                port: '%database_port%'
                dbname: '%database_name%'
                user: '%database_user%'
                password: '%database_password%'
                charset: UTF8

之后，我们可以在构造函数中更改给定的参数：

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Driver;

class DynamicConnection extends Connection
{
    public function __construct(array $params, Driver $driver, $config, $eventManager)
    {
        $params['dbname'] = 'teqsdqsdqst';
        parent::__construct($params, $driver, $config, $eventManager);
    }
}

现在我们只需要从url中获取参数并在里面设置$params['dbname']。
这样，我们确保symfony将始终使用此类创建连接，并且不再需要使用http请求触发监听器

Answer 2

_company很好的解决方案，但如果你想从 URL获取参数，你可以通过EventManager传入参数的对象检索构造函数内的容器，并从中获取当前请求，实际上容器被注入到 的ContainerAwareEventManager子类中EventManager

class DynamicDBConnector extends Connection
{
    public function __construct($params, $driver, $config, $eventManager)
    {
        if(!$this->isConnected()){
            // Create default config and event manager if none given (case in command line)
            if (!$config) {
                $config = new Configuration();
            }
            if (!$eventManager) {
                $eventManager = new EventManager();
            }

            $refEventManager = new \ReflectionObject($eventManager);
            $refContainer = $refEventManager->getProperty('container');
            $refContainer->setAccessible('public'); //We have to change it for a moment

            /*
             * @var \Symfony\Component\DependencyInjection\ContainerInterface $container
             */
            $conrainer = $refContainer->getValue($eventManager);

            /*
             * @var Symfony\Component\HttpFoundation\Request
             */
            $request = $conrainer->get('request_stack')->getCurrentRequest();

            if ($request != null && $request->attributes->has('_company')) {
                $params['dbname'] .= $request->attributes->get('_company');
            }

            $refContainer->setAccessible('private'); //We put in private again
            parent::__construct($params, $driver, $config, $eventManager);
        }
    }
}