Janisbiz\LightOrm\ConnectionPool

Complexity

Total Complexity

7

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	createConnection()	0	8	1
A	getConnection()	0	24	4
A	addConnectionConfig()	0	5	1
A	getConnectionStatic()	0	3	1

<?php declare(strict_types=1);

namespace Janisbiz\LightOrm;

use Janisbiz\LightOrm\Connection\ConnectionConfigInterface;
use Janisbiz\LightOrm\Connection\ConnectionInterface;
use Janisbiz\LightOrm\Connection\ConnectionInvalidArgumentException;

class ConnectionPool
{
    /**
     * @var ConnectionConfigInterface[]
     */
    protected static $connectionConfig = [];

    /**
     * @var ConnectionInterface[]
     */
    protected static $connections = [];

    /**
     * @param ConnectionConfigInterface $connectionConfig
     *
     * @return $this
     */
    public function addConnectionConfig(ConnectionConfigInterface $connectionConfig): ConnectionPool
    {
        static::$connectionConfig[$connectionConfig->getDbname()] = $connectionConfig;

        return $this;
    }

    /**
     * @param string $dbName
     *
     * @return ConnectionInterface
     * @throws ConnectionInvalidArgumentException
     */
    public function getConnection($dbName): ConnectionInterface
    {
        if (!\array_key_exists($dbName, static::$connectionConfig)) {
            if (empty(static::$connectionConfig)) {
                throw new ConnectionInvalidArgumentException(\sprintf(
                    'Could not find connection by name "%s"!',
                    $dbName
                ));
            } else {
                throw new ConnectionInvalidArgumentException(\sprintf(
                    'Could not find connection by name "%s"! Available connections: "%s".',
                    $dbName,
                    \implode('", "', \array_keys(static::$connectionConfig))
                ));
            }
        }

        $connectionConfig = static::$connectionConfig[$dbName];

        if (!isset(static::$connections[$dbName])) {
            static::$connections[$dbName] = $this->createConnection($connectionConfig);
        }

        return static::$connections[$dbName];
    }

    /**
     * @param string $dbName
     *
     * @return ConnectionInterface
     */
    public static function getConnectionStatic($dbName): ConnectionInterface
    {
        return (new static())->getConnection($dbName);
    }

    /**
     * Ignoring for code coverage, as this requires to have a real connection to be tested.
     * @codeCoverageIgnore
     *
     * @param ConnectionConfigInterface $connectionConfig
     *
     * @return ConnectionInterface
     */
    protected function createConnection(ConnectionConfigInterface $connectionConfig): ConnectionInterface
    {
        $adapterConnectionClass = $connectionConfig->getAdapterConnectionClass();

        return new $adapterConnectionClass(
            $connectionConfig->generateDsn(),
            $connectionConfig->getUsername(),
            $connectionConfig->getPassword()
        );
    }
}