ConnectionManager::open() - Code Metrics - Inspection of "Merge branch 'Results'" - maikees/moc-orm - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( d50d64...3e68ba )

by Maike

created 2017-10-25 13:47 UTC

ConnectionManager::open() B

↳ Parent: ConnectionManager

Complexity

Conditions	6
Paths	2

Size

Total Lines	24
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	19.1203

Importance

Changes

Metric	Value
cc	6
eloc	13
nc	2
nop	1
dl	0
loc	24
ccs	4
cts	14
cp	0.2857
crap	19.1203
rs	8.5125
c	0
b	0
f	0

<?php

namespace MocOrm\Connection;

class ConnectionManager
{
    /**
     * @Connection object is a of Connection
     */
    private $Connection;


    /**
     * @Connection array is all connections opened
     */
    private $connections = [];

    /**
     * @currentConnection object is the current connection
     */
    private $currentConnection;

    /**
     * @_instance object this instance
     */
    private static $_instance;

    /**
     * @currentConnectionName string of the current connection name
     */
    private $_currentConnectionName;


    /**
     * @Config This is a singleton object for save all configs
     */
    private $Config;

    /**
     * Initialize the object or return this object if have value set in attribute $_instance
     * @param \Closure $config
     * @return ConnectionManager
     */
    public static function initialize($config = null)
    {
        if (!self::$_instance) self::$_instance = new ConnectionManager();

        if (is_callable($config)) {

            $config($_config = new Config());

            self::$_instance->Config = $_config;
        }

        return self::$_instance;
    }

    /**
     * @param $connectionName String
     * @return $this
     * @throws \Exception if isn't an string
     * @throws \Exception if isn't set
     */
    public static function open($connectionName)
    {
        $instance = self::$_instance;

        if (!is_string($connectionName) || empty($connectionName)) throw new \Exception("Invalid connection name.");
        if (!$instance->hasConnection($connectionName)) throw new \Exception("The connection name $connectionName is not set.");
        if ($instance->hasOpen($connectionName)) throw new \Exception('This connection is actived.');

        $instance->_currentConnectionName = $connectionName;

        $configs = $instance->Config->getConnection($connectionName);

        $instance->Connection = new Connection($configs);
        $instance->Connection->setAppLogger($instance->Config->getAppLogger());

        $instance->connections[$connectionName] = $instance->Connection->setConnection();

        $instance->currentConnection = $instance->connections[$connectionName];

        if ($instance->currentConnection->getDriver() == 'pgsql') {
            $instance->currentConnection->changeSchema($instance->currentConnection->getSchema());
        }

        return $instance;
    }

    /**
     * This get the current connection
     * If not exists the current connection this use last setting
     * @return  Connection
     * @throws \Exception if not exists connections set
     */
    public function current()
    {
        if (empty($this->currentConnection)) {
            $configs = ($this->Config) ? $this->Config->getConfigs() : null;

            if (count($configs) == 0) throw new \Exception('No connections are available.');

            $default = $this->Config->getDefault();

            $name = is_null($default) ?
                @end(array_keys($configs ?: [])) :
                $default;

            $this->open($name);
        }

        return $this->currentConnection;
    }

    /**
     * Change current connection but this needed is set
     * @param $connectionName
     * @return mixed
     * @throws \Exception if connection name isn't string
     * @throws \Exception if connection name isn't set
     * @throws \Exception if connection not actived
     */
    public static function change($connectionName, $open = false)
    {
        $instance = self::initialize();

        if (!is_string($connectionName)) throw new \Exception("Invalid connection name.");

        if (!$instance->hasConnection($connectionName)) throw new \Exception("The connection name $connectionName is not set.");

        if (!$instance->hasOpen($connectionName)) {
            if ($open) {
                try {
                    self::open($connectionName);
                } catch (\Exception $e) {
                    throw $e;
                }
            } else {

                throw new \Exception("This connection isn't actived.");
            }
        }

        $instance->_currentConnectionName = $connectionName;

        $instance->currentConnection = $instance->connections[$connectionName];

        $instance->Connection = $instance->connections[$connectionName];

        return $instance;
    }

    /**
     * All connections opened
     * @return array All connections
     * @throws \Exception This instance isnt't initialized
     */
    public function getAllActive()
    {
        if (!$this->hasInstance()) throw new \Exception('This instance isnt\'t initialized');

        return $this->connections;
    }


    /**
     * Get all connection string
     * @return array if have connection but not have this method return null
     */
    final public function getConfigs()
    {
        return $this->Config->getConfigs();
    }

    /**
     * Verify if connection has open
     * @param $connectionName
     * @return bool
     */
    private function hasOpen($connectionName)
    {
        return array_key_exists($connectionName, $this->connections);
    }

    /**
     * Verify if this is initialized
     * @return bool
     */
    private function hasInstance()
    {
        return !self::$_instance ? false : true;
    }

    /**
     * Verify if has connection defined
     * @param $connectionName
     * @return bool
     */
    private function hasConnection($connectionName)
    {
        return array_key_exists(
            $connectionName,
            $this->Config->getConfigs()
        );
    }
}


1		<?php
2
3		namespace MocOrm\Connection;
4
5		class ConnectionManager
6		{
7		/**
8		* @Connection object is a of Connection
9		*/
10		private $Connection;
		0 ignored issues – show Unused Code introduced 2017-10-20 16:43 UTC by Report Bug Copy Issue Report The property `$Connection` is not used and could be removed. This check marks private properties in classes that are never used. Those properties can be removed. Loading history...
11
12		/**
13		* @Connection array is all connections opened
14		*/
15		private $connections = [];
16
17		/**
18		* @currentConnection object is the current connection
19		*/
20		private $currentConnection;
21
22		/**
23		* @_instance object this instance
24		*/
25		private static $_instance;
26
27		/**
28		* @currentConnectionName string of the current connection name
29		*/
30		private $_currentConnectionName;
		0 ignored issues – show Unused Code introduced 2017-10-20 16:43 UTC by Report Bug Copy Issue Report The property `$_currentConnectionName` is not used and could be removed. This check marks private properties in classes that are never used. Those properties can be removed. Loading history...
31
32		/**
33		* @Config This is a singleton object for save all configs
34		*/
35		private $Config;
36
37		/**
38		* Initialize the object or return this object if have value set in attribute $_instance
39		* @param \Closure $config
40		* @return ConnectionManager
41		*/
42	6	public static function initialize($config = null)
43		{
44	6	if (!self::$_instance) self::$_instance = new ConnectionManager();
45
46	6	if (is_callable($config)) {
47
48	1	$config($_config = new Config());
49
50	1	self::$_instance->Config = $_config;
51		}
52
53	6	return self::$_instance;
54		}
55
56		/**
57		* @param $connectionName String
58		* @return $this
59		* @throws \Exception if isn't an string
60		* @throws \Exception if isn't set
61		*/
62	2	public static function open($connectionName)
63		{
64	2	$instance = self::$_instance;
65
66	2	if (!is_string($connectionName) \|\| empty($connectionName)) throw new \Exception("Invalid connection name.");
67	1	if (!$instance->hasConnection($connectionName)) throw new \Exception("The connection name $connectionName is not set.");
68		if ($instance->hasOpen($connectionName)) throw new \Exception('This connection is actived.');
69
70		$instance->_currentConnectionName = $connectionName;
71
72		$configs = $instance->Config->getConnection($connectionName);
73
74		$instance->Connection = new Connection($configs);
75		$instance->Connection->setAppLogger($instance->Config->getAppLogger());
76
77		$instance->connections[$connectionName] = $instance->Connection->setConnection();
78
79		$instance->currentConnection = $instance->connections[$connectionName];
80
81		if ($instance->currentConnection->getDriver() == 'pgsql') {
82		$instance->currentConnection->changeSchema($instance->currentConnection->getSchema());
83		}
84
85		return $instance;
86		}
87
88		/**
89		* This get the current connection
90		* If not exists the current connection this use last setting
91		* @return Connection
92		* @throws \Exception if not exists connections set
93		*/
94	1	public function current()
95		{
96	1	if (empty($this->currentConnection)) {
97	1	$configs = ($this->Config) ? $this->Config->getConfigs() : null;
98
99	1	if (count($configs) == 0) throw new \Exception('No connections are available.');
100
101		$default = $this->Config->getDefault();
102
103		$name = is_null($default) ?
104		@end(array_keys($configs ?: [])) :
105		$default;
106
107		$this->open($name);
108		}
109
110		return $this->currentConnection;
111		}
112
113		/**
114		* Change current connection but this needed is set
115		* @param $connectionName
116		* @return mixed
117		* @throws \Exception if connection name isn't string
118		* @throws \Exception if connection name isn't set
119		* @throws \Exception if connection not actived
120		*/
121		public static function change($connectionName, $open = false)
122		{
123		$instance = self::initialize();
124
125		if (!is_string($connectionName)) throw new \Exception("Invalid connection name.");
126
127		if (!$instance->hasConnection($connectionName)) throw new \Exception("The connection name $connectionName is not set.");
128
129		if (!$instance->hasOpen($connectionName)) {
130		if ($open) {
131		try {
132		self::open($connectionName);
133		} catch (\Exception $e) {
134		throw $e;
135		}
136		} else {
137
138		throw new \Exception("This connection isn't actived.");
139		}
140		}
141
142		$instance->_currentConnectionName = $connectionName;
143
144		$instance->currentConnection = $instance->connections[$connectionName];
145
146		$instance->Connection = $instance->connections[$connectionName];
147
148		return $instance;
149		}
150
151		/**
152		* All connections opened
153		* @return array All connections
154		* @throws \Exception This instance isnt't initialized
155		*/
156	1	public function getAllActive()
157		{
158	1	if (!$this->hasInstance()) throw new \Exception('This instance isnt\'t initialized');
159
160	1	return $this->connections;
161		}
162
163
164		/**
165		* Get all connection string
166		* @return array if have connection but not have this method return null
167		*/
168	1	final public function getConfigs()
169		{
170	1	return $this->Config->getConfigs();
171		}
172
173		/**
174		* Verify if connection has open
175		* @param $connectionName
176		* @return bool
177		*/
178		private function hasOpen($connectionName)
179		{
180		return array_key_exists($connectionName, $this->connections);
181		}
182
183		/**
184		* Verify if this is initialized
185		* @return bool
186		*/
187	1	private function hasInstance()
188		{
189	1	return !self::$_instance ? false : true;
190		}
191
192		/**
193		* Verify if has connection defined
194		* @param $connectionName
195		* @return bool
196		*/
197	1	private function hasConnection($connectionName)
198		{
199	1	return array_key_exists(
200	1	$connectionName,
201	1	$this->Config->getConfigs()
202		);
203		}
204		}
205

maikees / moc-orm

Push — master ( d50d64...3e68ba )

ConnectionManager::open() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like