WebStream\Database\ConnectionManager

Complexity

Total Complexity

12

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Test Coverage

Coverage

82.05%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	__destruct()	0	3	1
A	getConnection()	0	5	2
B	initialize()	0	45	8

<?php

namespace WebStream\Database;

use WebStream\Container\Container;

The type WebStream\Container\Container was not found. Maybe you did not declare it correctly or list all dependencies?

use WebStream\IO\File;

The type WebStream\IO\File was not found. Maybe you did not declare it correctly or list all dependencies?

use WebStream\Exception\Extend\ClassNotFoundException;

The type WebStream\Exception\Extend\ClassNotFoundException was not found. Maybe you did not declare it correctly or list all dependencies?

use WebStream\Exception\Extend\DatabaseException;

The type WebStream\Exception\Extend\DatabaseException was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * ConnectionManager
 * @author Ryuichi TANAKA.
 * @since 2014/06/13
 * @version 0.4
 */
class ConnectionManager
{
    /**
     * @var array<string> クラスパス-DSNハッシュマップ
     */
    private $classpathMap;

    /**
     * @var AnnotationContainer データベース接続項目コンテナ

The type WebStream\Database\AnnotationContainer was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    private $connectionContainer;

    /**
     * constructor
     * @param Container 依存コンテナ

The doc comment 依存コンテナ at position 0 could not be parsed: Unknown type name '依存コンテナ' at position 0 in 依存コンテナ.

     */
    public function __construct(Container $container)
    {
        $this->initialize($container);
    }

    /**
     * destructor
     */
    public function __destruct()
    {
        $this->connectionContainer = null;
    }

    /**
     * DBコネクションを返却する
     * @param string Modelクラスファイルパス

The doc comment Modelクラスファイルパス at position 0 could not be parsed: Unknown type name 'Modelクラスファイルパス' at position 0 in Modelクラスファイルパス.

     * @return DatabaseDriver データベースドライバインスタンス
     */
    public function getConnection($filepath)
    {
        $dsnHash = $this->classpathMap[$filepath];

        return $dsnHash !== null ? $this->connectionContainer->{$dsnHash} : null;

The condition $dsnHash !== null is always true.

    }

    /**
     * 初期処理
     * @param Container 依存コンテナ

The doc comment 依存コンテナ at position 0 could not be parsed: Unknown type name '依存コンテナ' at position 0 in 依存コンテナ.

     */
    private function initialize(Container $container)
    {
        $this->classpathMap = [];
        $this->connectionContainer = new Container();
        $logger = $container->logger;
        $innerException = null;

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

        foreach ($container->connectionContainerList as $connectionContainer) {
            $config = null;
            $configFile = new File($connectionContainer->configPath);

            if (!$configFile->exists()) {
                throw new DatabaseException("Database configuration file is not found: " . $configFile->getFilePath());
            }

            $ext = $configFile->getFileExtension();
            if ($ext === 'ini') {
                $config = parse_ini_file($configFile->getFilePath());
            } elseif ($ext === 'yml' || $ext === 'yaml') {
                $config = \Spyc::YAMLLoad($configFile->getFilePath());
            } else {
                throw new DatabaseException("Yaml or ini file only available database configuration file.");
            }

            $driverClassPath = $connectionContainer->driverClassPath;

            if (!class_exists($driverClassPath)) {
                throw new ClassNotFoundException("$driverClassPath is not defined.");
            }

            $dsnHash = "";
            $databaseConfigContainer = new Container(false);
            foreach ($config as $key => $value) {
                $dsnHash .= $key . $value;
                $databaseConfigContainer->set($key, $value);
            }
            $dsnHash = md5($dsnHash);

            $this->classpathMap[$connectionContainer->filepath] = $dsnHash;

            $this->connectionContainer->{$dsnHash} = function () use ($driverClassPath, $databaseConfigContainer, $logger) {
                $driver = new $driverClassPath($databaseConfigContainer);
                $driver->inject('logger', $logger);

                return $driver;
            };
        }
    }
}