Silviooosilva\CacheerPhp\Core\ConnectionFactory

Complexity

Total Complexity

6

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	createConnection()	0	22	6

<?php

namespace Silviooosilva\CacheerPhp\Core;

use PDO;
use PDOException;
use Silviooosilva\CacheerPhp\Exceptions\ConnectionException;

/**
 * Class ConnectionFactory
 * @author Sílvio Silva <https://github.com/silviooosilva>
 * @package Silviooosilva\CacheerPhp
 */
class ConnectionFactory
{

    /**
     * Creates a new PDO instance based on the specified database configuration.
     *
     * @param array|null $database
     * @return PDO|null
     * @throws ConnectionException
     */
    public static function createConnection(?array $database = null): ?PDO
    {
        $dbConf = $database ?? CACHEER_DATABASE_CONFIG[Connect::getConnection()];

        if ($dbConf['driver'] === 'sqlite') {
            $dbName = $dbConf['dbname'];
            $dbDsn = $dbConf['driver'] . ':' . $dbName;
        } else {
            $dbName = "{$dbConf['driver']}-{$dbConf['dbname']}@{$dbConf['host']}";

The assignment to $dbName is dead and can be removed.

            $dbDsn = "{$dbConf['driver']}:host={$dbConf['host']};dbname={$dbConf['dbname']};port={$dbConf['port']}";
        }

        try {
            $options = $dbConf['options'] ?? [];
            foreach ($options as $key => $value) {
                if (is_string($value) && defined($value)) {
                    $options[$key] = constant($value);
                }
            }
            return new PDO($dbDsn, $dbConf['username'] ?? null, $dbConf['passwd'] ?? null, $options);
        } catch (PDOException $exception) {
            throw ConnectionException::create($exception->getMessage(), $exception->getCode(), $exception->getPrevious());
        }
    }
}