From 05e38eadbeb3de19e5b26003c2b401e00bb71df4 Mon Sep 17 00:00:00 2001
From: polo <ordipolo@gmx.fr>
Date: Sun, 18 Oct 2026 00:08:23 +0200
Subject: =?UTF-8?q?sortie=20de=20vendor=20du=20d=C3=A9p=C3=B4t,=20oubli=20?=
 =?UTF-8?q?dans=20config-template.ini?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Connections/PrimaryReadReplicaConnection.php   | 327 ---------------------
 1 file changed, 327 deletions(-)
 delete mode 100644 vendor/doctrine/dbal/src/Connections/PrimaryReadReplicaConnection.php

(limited to 'vendor/doctrine/dbal/src/Connections')

diff --git a/vendor/doctrine/dbal/src/Connections/PrimaryReadReplicaConnection.php b/vendor/doctrine/dbal/src/Connections/PrimaryReadReplicaConnection.php
deleted file mode 100644
index 1d9c1a9..0000000
--- a/vendor/doctrine/dbal/src/Connections/PrimaryReadReplicaConnection.php
+++ /dev/null
@@ -1,327 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Doctrine\DBAL\Connections;
-
-use Doctrine\DBAL\Configuration;
-use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Driver;
-use Doctrine\DBAL\Driver\Connection as DriverConnection;
-use Doctrine\DBAL\Driver\Exception as DriverException;
-use Doctrine\DBAL\DriverManager;
-use Doctrine\DBAL\Exception;
-use Doctrine\DBAL\Statement;
-use InvalidArgumentException;
-use SensitiveParameter;
-
-use function array_rand;
-use function assert;
-use function count;
-
-/**
- * Primary-Replica Connection
- *
- * Connection can be used with primary-replica setups.
- *
- * Important for the understanding of this connection should be how and when
- * it picks the replica or primary.
- *
- * 1. Replica if primary was never picked before and ONLY if 'getWrappedConnection'
- *    or 'executeQuery' is used.
- * 2. Primary picked when 'executeStatement', 'insert', 'delete', 'update', 'createSavepoint',
- *    'releaseSavepoint', 'beginTransaction', 'rollback', 'commit' or 'prepare' is called.
- * 3. If Primary was picked once during the lifetime of the connection it will always get picked afterwards.
- * 4. One replica connection is randomly picked ONCE during a request.
- *
- * ATTENTION: You can write to the replica with this connection if you execute a write query without
- * opening up a transaction. For example:
- *
- *      $conn = DriverManager::getConnection(...);
- *      $conn->executeQuery("DELETE FROM table");
- *
- * Be aware that Connection#executeQuery is a method specifically for READ
- * operations only.
- *
- * Use Connection#executeStatement for any SQL statement that changes/updates
- * state in the database (UPDATE, INSERT, DELETE or DDL statements).
- *
- * This connection is limited to replica operations using the
- * Connection#executeQuery operation only, because it wouldn't be compatible
- * with the ORM or SchemaManager code otherwise. Both use all the other
- * operations in a context where writes could happen to a replica, which makes
- * this restricted approach necessary.
- *
- * You can manually connect to the primary at any time by calling:
- *
- *      $conn->ensureConnectedToPrimary();
- *
- * Instantiation through the DriverManager looks like:
- *
- * @psalm-import-type Params from DriverManager
- * @psalm-import-type OverrideParams from DriverManager
- * @example
- *
- * $conn = DriverManager::getConnection(array(
- *    'wrapperClass' => 'Doctrine\DBAL\Connections\PrimaryReadReplicaConnection',
- *    'driver' => 'pdo_mysql',
- *    'primary' => array('user' => '', 'password' => '', 'host' => '', 'dbname' => ''),
- *    'replica' => array(
- *        array('user' => 'replica1', 'password' => '', 'host' => '', 'dbname' => ''),
- *        array('user' => 'replica2', 'password' => '', 'host' => '', 'dbname' => ''),
- *    )
- * ));
- *
- * You can also pass 'driverOptions' and any other documented option to each of this drivers
- * to pass additional information.
- */
-class PrimaryReadReplicaConnection extends Connection
-{
-    /**
-     * Primary and Replica connection (one of the randomly picked replicas).
-     *
-     * @var array<string, DriverConnection|null>
-     */
-    protected array $connections = ['primary' => null, 'replica' => null];
-
-    /**
-     * You can keep the replica connection and then switch back to it
-     * during the request if you know what you are doing.
-     */
-    protected bool $keepReplica = false;
-
-    /**
-     * Creates Primary Replica Connection.
-     *
-     * @internal The connection can be only instantiated by the driver manager.
-     *
-     * @param array<string, mixed> $params
-     * @psalm-param Params $params
-     */
-    public function __construct(array $params, Driver $driver, ?Configuration $config = null)
-    {
-        if (! isset($params['replica'], $params['primary'])) {
-            throw new InvalidArgumentException('primary or replica configuration missing');
-        }
-
-        if (count($params['replica']) === 0) {
-            throw new InvalidArgumentException('You have to configure at least one replica.');
-        }
-
-        if (isset($params['driver'])) {
-            $params['primary']['driver'] = $params['driver'];
-
-            foreach ($params['replica'] as $replicaKey => $replica) {
-                $params['replica'][$replicaKey]['driver'] = $params['driver'];
-            }
-        }
-
-        $this->keepReplica = ! empty($params['keepReplica']);
-
-        parent::__construct($params, $driver, $config);
-    }
-
-    /**
-     * Checks if the connection is currently towards the primary or not.
-     */
-    public function isConnectedToPrimary(): bool
-    {
-        return $this->_conn !== null && $this->_conn === $this->connections['primary'];
-    }
-
-    public function connect(?string $connectionName = null): DriverConnection
-    {
-        if ($connectionName !== null) {
-            throw new InvalidArgumentException(
-                'Passing a connection name as first argument is not supported anymore.'
-                    . ' Use ensureConnectedToPrimary()/ensureConnectedToReplica() instead.',
-            );
-        }
-
-        return $this->performConnect();
-    }
-
-    protected function performConnect(?string $connectionName = null): DriverConnection
-    {
-        $requestedConnectionChange = ($connectionName !== null);
-        $connectionName          ??= 'replica';
-
-        if ($connectionName !== 'replica' && $connectionName !== 'primary') {
-            throw new InvalidArgumentException('Invalid option to connect(), only primary or replica allowed.');
-        }
-
-        // If we have a connection open, and this is not an explicit connection
-        // change request, then abort right here, because we are already done.
-        // This prevents writes to the replica in case of "keepReplica" option enabled.
-        if ($this->_conn !== null && ! $requestedConnectionChange) {
-            return $this->_conn;
-        }
-
-        $forcePrimaryAsReplica = false;
-
-        if ($this->getTransactionNestingLevel() > 0) {
-            $connectionName        = 'primary';
-            $forcePrimaryAsReplica = true;
-        }
-
-        if (isset($this->connections[$connectionName])) {
-            $this->_conn = $this->connections[$connectionName];
-
-            if ($forcePrimaryAsReplica && ! $this->keepReplica) {
-                $this->connections['replica'] = $this->_conn;
-            }
-
-            return $this->_conn;
-        }
-
-        if ($connectionName === 'primary') {
-            $this->connections['primary'] = $this->_conn = $this->connectTo($connectionName);
-
-            // Set replica connection to primary to avoid invalid reads
-            if (! $this->keepReplica) {
-                $this->connections['replica'] = $this->connections['primary'];
-            }
-        } else {
-            $this->connections['replica'] = $this->_conn = $this->connectTo($connectionName);
-        }
-
-        return $this->_conn;
-    }
-
-    /**
-     * Connects to the primary node of the database cluster.
-     *
-     * All following statements after this will be executed against the primary node.
-     */
-    public function ensureConnectedToPrimary(): void
-    {
-        $this->performConnect('primary');
-    }
-
-    /**
-     * Connects to a replica node of the database cluster.
-     *
-     * All following statements after this will be executed against the replica node,
-     * unless the keepReplica option is set to false and a primary connection
-     * was already opened.
-     */
-    public function ensureConnectedToReplica(): void
-    {
-        $this->performConnect('replica');
-    }
-
-    /**
-     * Connects to a specific connection.
-     *
-     * @throws Exception
-     */
-    protected function connectTo(string $connectionName): DriverConnection
-    {
-        $params = $this->getParams();
-        assert(isset($params['primary']));
-
-        if ($connectionName === 'primary') {
-            $connectionParams = $params['primary'];
-        } else {
-            assert(isset($params['replica']));
-            $connectionParams = $this->chooseReplicaConnectionParameters($params['primary'], $params['replica']);
-        }
-
-        try {
-            return $this->driver->connect($connectionParams);
-        } catch (DriverException $e) {
-            throw $this->convertException($e);
-        }
-    }
-
-    /**
-     * @param OverrideParams        $primary
-     * @param array<OverrideParams> $replicas
-     *
-     * @return array<string, mixed>
-     * @psalm-return OverrideParams
-     */
-    protected function chooseReplicaConnectionParameters(
-        #[SensitiveParameter]
-        array $primary,
-        #[SensitiveParameter]
-        array $replicas,
-    ): array {
-        $params = $replicas[array_rand($replicas)];
-
-        if (! isset($params['charset']) && isset($primary['charset'])) {
-            $params['charset'] = $primary['charset'];
-        }
-
-        return $params;
-    }
-
-    /**
-     * {@inheritDoc}
-     */
-    public function executeStatement(string $sql, array $params = [], array $types = []): int|string
-    {
-        $this->ensureConnectedToPrimary();
-
-        return parent::executeStatement($sql, $params, $types);
-    }
-
-    public function beginTransaction(): void
-    {
-        $this->ensureConnectedToPrimary();
-
-        parent::beginTransaction();
-    }
-
-    public function commit(): void
-    {
-        $this->ensureConnectedToPrimary();
-
-        parent::commit();
-    }
-
-    public function rollBack(): void
-    {
-        $this->ensureConnectedToPrimary();
-
-        parent::rollBack();
-    }
-
-    public function close(): void
-    {
-        unset($this->connections['primary'], $this->connections['replica']);
-
-        parent::close();
-
-        $this->_conn       = null;
-        $this->connections = ['primary' => null, 'replica' => null];
-    }
-
-    public function createSavepoint(string $savepoint): void
-    {
-        $this->ensureConnectedToPrimary();
-
-        parent::createSavepoint($savepoint);
-    }
-
-    public function releaseSavepoint(string $savepoint): void
-    {
-        $this->ensureConnectedToPrimary();
-
-        parent::releaseSavepoint($savepoint);
-    }
-
-    public function rollbackSavepoint(string $savepoint): void
-    {
-        $this->ensureConnectedToPrimary();
-
-        parent::rollbackSavepoint($savepoint);
-    }
-
-    public function prepare(string $sql): Statement
-    {
-        $this->ensureConnectedToPrimary();
-
-        return parent::prepare($sql);
-    }
-}
-- 
cgit v1.2.3