动态数据库连接 symfony2
我的symfony2项目有一个主数据库和许多子数据库。每个子数据库都是为每个用户创建的，数据库凭据存储在主数据库中。当用户登录时，将从主数据库获取特定于用户的数据库凭据，理想情况下应建立子数据库连接。我在谷歌上搜索了相同的内容，我遇到了许多解决方案，最后做了以下操作：
#config.yml
doctrine:
dbal:
default_connection: default
connections:
default:
dbname: maindb
user: root
password: null
host: localhost
dynamic_conn:
dbname: ~
user: ~
password: ~
host: localhost
orm:
default_entity_manager: default
entity_managers:
default:
connection: default
auto_mapping: true
dynamic_em:
connection: dynamic_conn
auto_mapping: true
我创建了一个默认连接来连接到主数据库，并为子数据库创建了一个空连接，同样，我创建了实体管理器。然后，我创建了默认事件侦听器，并将以下代码添加到“onKernelRequest”中：
public function onKernelRequest(GetResponseEvent $event) //works like preDispatch in Zend
{
//code to get db credentials from master database and stored in varaiables
....
$connection = $this->container->get(sprintf('doctrine.dbal.%s_connection', 'dynamic_conn'));
$connection->close();
$refConn = new \ReflectionObject($connection);
$refParams = $refConn->getProperty('_params');
$refParams->setAccessible('public'); //we have to change it for a moment
$params = $refParams->getValue($connection);
$params['dbname'] = $dbName;
$params['user'] = $dbUser;
$params['password'] = $dbPass;
$refParams->setAccessible('private');
$refParams->setValue($connection, $params);
$this->container->get('doctrine')->resetEntityManager('dynamic_em');
....
}
上面的代码设置子数据库参数并重置实体管理器dynamic_em。
当我在某个控制器中执行以下操作时，它可以正常工作，并且如果从子数据库中提取数据， 则数据。
$getblog= $em->getRepository('BloggerBlogBundle:Blog')->findById($id); //uses doctrine
但是，当我使用安全上下文（如以下代码所示）时，我收到错误“未选择数据库”。
$securityContext = $this->container->get('security.context');
$loggedinUserid = $securityContext->getToken()->getUser()->getId();
如何动态设置数据库连接并使用安全上下文？
更新：-
经过长时间的反复试验，以及谷歌搜索，我意识到这是在执行之前设置的。现在的问题是如何将数据库连接详细信息注入 security.context，以及在哪里注入？security.contextonKernelRequest
我们需要达到设置 DBAL 和安全上下文并创建安全令牌的点，并且我们可以操作数据库连接详细信息。
因此，正如以下链接中的人所说，我对代码进行了更改，因为这正是我想要做的。http://forum.symfony-project.org/viewtopic.php?t=37398&p=124413
这使我把以下代码添加到我的项目中：
#config.yml //remains unchanged, similar to above code
编译器传递的创建方式如下：
// src/Blogger/BlogBundle/BloggerBlogBundle.php
namespace Blogger\BlogBundle;
use Symfony\Component\HttpKernel\Bundle\Bundle;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Blogger\BlogBundle\DependencyInjection\Compiler\CustomCompilerPass;
class BloggerBlogBundle extends Bundle
{
public function build(ContainerBuilder $container)
{
parent::build($container);
$container->addCompilerPass(new CustomCompilerPass());
}
}
编译器通道如下所示：
# src/Blogger/BlogBundle/DependencyInjection/Compiler/CustomCompilerPass.php
class CustomCompilerPassimplements CompilerPassInterface
{
public function process(ContainerBuilder $container)
{
$connection_service = 'doctrine.dbal.dynamic_conn_connection';
if ($container->hasDefinition($connection_service))
{
$def = $container->getDefinition($connection_service);
$args = $def->getArguments();
$args[0]['driverClass'] = 'Blogger\BlogBundle\UserDependentMySqlDriver';
$args[0]['driverOptions'][] = array(new Reference('security.context'));
$def->replaceArgument(0, $args[0]);
}
}
}
驱动程序类代码如下所示：
# src/Blogger/BlogBundle/UserDependentMySqlDriver.php
use Doctrine\DBAL\Driver\PDOMySql\Driver;
class UserDependentMySqlDriver extends Driver
{
public function connect(array $params, $username = null, $password = null, array $driverOptions = array())
{
$dbname = ..... //store database name in variable
$params['dbname'] = $dbname;
return parent::connect($params, $username, $password, array());
}
}
上面的代码已添加到我的项目中，我假设这是解决我的问题的实际方法。
但现在我得到以下错误：
ServiceCircularReferenceException：为服务“security.context”检测到循环引用，路径：“profiler_listener -> profiler -> security.context -> security.authentication.manager -> fos_user.user_provider.username_email -> fos_user.user_manager -> doctrine.orm.dynamic_manager_entity_manager -> doctrine.dbal.dynamic_conn_connection”。
如何使我的代码正常工作？我敢打赌我在这里做错了什么，我将不胜感激任何提示和帮助。
