App\Component\Db\Factory

Complexity

Total Complexity

9

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	adapterParams()	0	11	2
A	connect()	0	15	3
A	getConnection()	0	8	2
A	__construct()	0	5	1
A	identity()	0	3	1

<?php

namespace App\Component\Db;

use \PDO;
use App\Component\Config;
use App\Component\Container;

class Factory
{
    const _ADAPTER = 'adapter';

    private $container;

    /**
     * factory config
     *
     * @var array
     */
    private $config;

    /**
     * connection pool
     *
     * @var array
     */
    private $connectionPool;

    /**
     * instanciate factory
     *
     * @param Container $container
     */
    public function __construct(Container $container)
    {
        $this->container = $container;
        $configService = $this->container->getService(\App\Config::class);
        $this->config = $configService->getSettings(Config::_DB);
    }

    /**
     * return Pdo connection instance from pool
     *
     * @param string $slot
     * @param string $dbname
     * @return PDO
     */
    public function getConnection(string $slot, string $dbname): PDO
    {
        $id = $this->identity($slot, $dbname);
        if (isset($this->connectionPool[$id])) {
            return $this->connectionPool[$id];
        }
        $this->connect($slot, $dbname);
        return $this->connectionPool[$id];
    }

    /**
     * connect
     *
     * @param string $slot
     * @param string $dbname
     * @return void
     */
    protected function connect(string $slot, string $dbname): Factory
    {
        $this->connectionPool = (false === is_array($this->connectionPool))

The condition false === is_array($this->connectionPool) is always false.

            ? []
            : $this->connectionPool;
        $params = $this->adapterParams($slot, $dbname);
        try {
            $adapter = new $params[self::_ADAPTER]($dbname, $params);
            $adapter->connect();
            $id = $this->identity($slot, $dbname);
            $this->connectionPool[$id] = $adapter->getConnection();
        } catch (\PDOException $e) {
            throw new \Exception('Connexion failed', $e->getCode());
        }
        return $this;
    }

    /**
     * adapter params
     *
     * @param string $slot
     * @param string $dbname
     * @return array
     */
    protected function adapterParams(string $slot, string $dbname): array
    {
        if (false === isset($this->config[$slot][$dbname])) {
            $exMsg = sprintf(
                'Missing or invalid config on slot %s for db %s',
                $slot,
                $dbname
            );
            throw new \Exception($exMsg);
        }
        return $this->config[$slot][$dbname];
    }

    /**
     * identify pool index
     *
     * @param string $slot
     * @param string $dbname
     * @return string
     */
    protected function identity(string $slot, string $dbname): string
    {
        return sprintf('%s-%s', $slot, $dbname);
    }
}