StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

PO
text
Body
copied!<p>If you use <code>ConnectionFactory</code>, your event subscribers attached to the connection will stop working, for example stofDoctrineExtensions. </p> <p>Here is my method. I have as with <code>ConnectionFactory</code> have empty connection and EntityManager. While working I just replace connection configuration by Reflections. Works on SF 2.0.10 ;)</p> <pre class="lang-php prettyprint-override"><code>class YourService extends ContainerAware { public function switchDatabase($dbName, $dbUser, $dbPass) { $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_manager'); // for sure (unless you like broken transactions) } } </code></pre> <p><strong>UPDATE</strong>:</p> <p>More elegant solution for doctrine 2.2 / sf 2.3 (without relection), created for php5.4 (I love new array initializer :D) We can use doctrine feature called connection wrapper, see <a href="http://docs.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/portability.html" rel="noreferrer">http://docs.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/portability.html</a></p> <p>This example use session service for temporary storing connection details.</p> <p>At first we have to create special connection wrapper:</p> <pre class="lang-php prettyprint-override"><code>namespace w3des\DoctrineBundle\Connection; use Doctrine\DBAL\Connection; use Symfony\Component\HttpFoundation\Session\Session; use Doctrine\Common\EventManager; use Doctrine\DBAL\Events; use Doctrine\DBAL\Event\ConnectionEventArgs; /* * @author Dawid zulus Pakula [zulus@w3des.net] */ class ConnectionWrapper extends Connection { const SESSION_ACTIVE_DYNAMIC_CONN = 'active_dynamic_conn'; /** * @var Session */ private $session; /** * @var bool */ private $_isConnected = false; /** * @param Session $sess */ public function setSession(Session $sess) { $this->session = $sess; } public function forceSwitch($dbName, $dbUser, $dbPassword) { if ($this->session->has(self::SESSION_ACTIVE_DYNAMIC_CONN)) { $current = $this->session->get(self::SESSION_ACTIVE_DYNAMIC_CONN); if ($current[0] === $dbName) { return; } } $this->session->set(self::SESSION_ACTIVE_DYNAMIC_CONN, [ $dbName, $dbUser, $dbPass ]); if ($this->isConnected()) { $this->close(); } } /** * {@inheritDoc} */ public function connect() { if (! $this->session->has(self::SESSION_ACTIVE_DYNAMIC_CONN)) { throw new \InvalidArgumentException('You have to inject into valid context first'); } if ($this->isConnected()) { return true; } $driverOptions = isset($params['driverOptions']) ? $params['driverOptions'] : array(); $params = $this->getParams(); $realParams = $this->session->get(self::SESSION_ACTIVE_DYNAMIC_CONN); $params['dbname'] = $realParams[0]; $params['user'] = $realParams[1]; $params['password'] = $realParams[2]; $this->_conn = $this->_driver->connect($params, $params['user'], $params['password'], $driverOptions); if ($this->_eventManager->hasListeners(Events::postConnect)) { $eventArgs = new ConnectionEventArgs($this); $this->_eventManager->dispatchEvent(Events::postConnect, $eventArgs); } $this->_isConnected = true; return true; } /** * {@inheritDoc} */ public function isConnected() { return $this->_isConnected; } /** * {@inheritDoc} */ public function close() { if ($this->isConnected()) { parent::close(); $this->_isConnected = false; } } } </code></pre> <p>Next register it in your doctrine configuration:</p> <pre class="lang-yaml prettyprint-override"><code>… connections: dynamic: driver: %database_driver% host: %database_host% port: %database_port% dbname: 'empty_database' charset: UTF8 wrapper_class: 'w3des\DoctrineBundle\Connection\ConnectionWrapper' </code></pre> <p>And our ConnectionWrapper is properly registered. Now session injection.</p> <p>First create special CompilerPass class:</p> <pre class="lang-php prettyprint-override"><code>namespace w3des\DoctrineBundle\DependencyInjection\CompilerPass; use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface; use Symfony\Component\DependencyInjection\ContainerBuilder; use Symfony\Component\DependencyInjection\Definition; use Symfony\Component\DependencyInjection\Reference; class ConnectionCompilerPass implements CompilerPassInterface { /** * {@inheritDoc} */ public function process(ContainerBuilder $container) { $connection = $container ->getDefinition('doctrine.dbal.dynamic_connection') ->addMethodCall('setSession', [ new Reference('session') ]); } } </code></pre> <p>And we record our new compiler class in *Bundle class:</p> <pre class="lang-php prettyprint-override"><code>public function build(ContainerBuilder $container) { parent::build($container); $container->addCompilerPass(new ConnectionCompilerPass()); } </code></pre> <p>And that its all!</p> <p>Connection will be created on demand, based on session properties.</p> <p>To switch database, just use:</p> <pre class="lang-php prettyprint-override"><code>$this->get('doctrine.dbal.dynamic_connection')->forceSwitch($dbname, $dbuser, $dbpass); </code></pre> <p><strong>Advantages</strong></p> <ol> <li>No more reflection</li> <li>Creation on demand</li> <li>Elegant and powerfull</li> </ol> <p><strong>Disadvantages</strong></p> <ol> <li>You have to manualy cleanup your entity manager, or create special doctrine event for this</li> <li>Much more code</li> </ol>

Querying!

Guidance

An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload