PrimaryReplicaConnection for TYPO3 Doctrine DBAL

README.md

PrimaryReplicaConnection for TYPO3 Doctrine DBAL

Useful if you need to extend the Connection to have a separate connection.

See https://forge.typo3.org/issues/82619 and https://www.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#wrapper-class

AdditionalConfiguration.php

<?php

// Runs through a pool of connections and see which one can connect to
$GLOBALS['TYPO3_CONF_VARS']['DB']['Connections']['Default']['wrapperClass'] = \PrimaryReplicaConnection::class;

PrimaryReplicaConnection.php

class PrimaryReplicaConnection extends \TYPO3\CMS\Core\Database\Connection
{
    public function connect(): bool
    {
        $allParams = $this->getParams();
        try {
            return parent::connect();
        } catch(\Doctrine\DBAL\Exception\ConnectionException $e) {
            if (!isset($allParams['replica'])) {
                throw $e;
            }
        }
        while ($nextReplica = array_shift($allParams['replica'])) {
            $allParams = array_replace_recursive($allParams, $nextReplica);
            $driverOptions = $allParams['driverOptions'] ?? [];
            $user          = $allParams['user'] ?? null;
            $password      = $allParams['password'] ?? null;
            try {
                $this->_conn = $this->_driver->connect($allParams, $user, $password, $driverOptions);
                if ($this->_eventManager->hasListeners(\Doctrine\DBAL\Events::postConnect)) {
                    $eventArgs = new \Doctrine\DBAL\Event\ConnectionEventArgs($this);
                    $this->_eventManager->dispatchEvent(\Doctrine\DBAL\Events::postConnect, $eventArgs);
                }
                return true;
            } catch(\Doctrine\DBAL\Exception\ConnectionException $e) {
                continue;
            }
        }
        // No connection available
        if ($e) {
            throw $e;
        }
    }
}