Driver::realCommit() - Code Metrics - phossa2/libs - Measure and Improve Code Quality continuously with Scrutinizer

Driver::realCommit() A
last analyzed 2016-10-12 00:59 UTC

↳ Parent: Driver

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	6
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	4
nc	1
nop	0

<?php
/**
 * Phossa Project
 *
 * PHP version 5.4
 *
 * @category  Library
 * @package   Phossa2\Db
 * @copyright Copyright (c) 2016 phossa.com
 * @license   http://mit-license.org/ MIT License
 * @link      http://www.phossa.com/
 */
/*# declare(strict_types=1); */

namespace Phossa2\Db\Driver\Mysqli;

use Phossa2\Db\Message\Message;
use Phossa2\Db\Driver\DriverAbstract;
use Phossa2\Db\Exception\LogicException;
use Phossa2\Db\Interfaces\StatementInterface;

/**
 * Driver
 *
 * Mysqli driver
 *
 * @package Phossa2\Db
 * @author  Hong Zhang <[email protected]>
 * @see     DriverAbstract
 * @version 2.0.0
 * @since   2.0.0 added
 */
class Driver extends DriverAbstract
{
    /**
     * the connection link
     *
     * @var    \mysqli
     * @access protected
     */
    protected $link;

    /**
     * Default mysqli attributes
     *
     * @var    array
     * @access protected
     */
    protected $attributes = [
        'MYSQLI_OPT_CONNECT_TIMEOUT' => 300,
        'MYSQLI_OPT_LOCAL_INFILE' => true,
        'MYSQLI_INIT_COMMAND' => '',
    ];

    /**
     * Driver constructor
     *
     * @param  array $connectInfo
     * @param  StatementInterface $statementPrototype
     * @throws InvalidArgumentException if link type not right
     * @throws LogicException driver specific extension not loaded
     * @access public
     */
    public function __construct(
        $connectInfo,
        StatementInterface $statementPrototype = null
    ) {
        parent::__construct($connectInfo);

        // set prototypes
        $this->statement_prototype = $statementPrototype ?: new Statement();
    }

    /**
     * {@inheritDoc}
     */
    protected function extensionLoaded()/*# : bool */
    {
        return extension_loaded('mysqli');
    }

    /**
     * {@inheritDoc}
     */
    protected function realLastId($name)
    {
        return $this->link->insert_id;
    }

    /**
     * {@inheritDoc}
     */
    protected function realQuote(
        $string,
        /*# int */ $type
    )/*# : string */ {
        return '\'' . $this->link->real_escape_string($string) . '\'';
    }

    /**
     * {@inheritDoc}
     */
    protected function realConnect(array $parameters)
    {
        // init
        $link = new \mysqli();
        $link->init();

        // params with defaults
        $p = $this->fixParams($parameters);

        // real connect
        $link->real_connect(
            $p['host'],
            $p['username'],
            $p['password'],
            $p['db'],
            $p['port'],
            $p['socket']
        );

        $this->isConenctFailed($link);
        $this->setCharset($link, $parameters);
        return $link;
    }

    /**
     * Disconnect the \PDO link
     *
     * {@inheritDoc}
     */
    protected function realDisconnect()
    {
        $this->link->close();
    }

    /**
     * {@inheritDoc}
     */
    protected function realPing()/*# : bool */
    {
        return $this->link->ping();
    }

    /**
     * {@inheritDoc}
     */
    protected function realSetAttribute(/*# string */ $attribute, $value)

    {
        if (is_string($attribute)) {
            $this->checkAttribute($attribute);
            $this->link->options(constant($attribute), $value);
        } else {
            $this->link->options($attribute, $value);
        }
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    protected function realGetAttribute(/*# string */ $attribute)
    {
        if (is_string($attribute)) {
            $this->checkAttribute($attribute);
        }
        return null;
    }

    /**
     * {@inheritDoc}
     */
    protected function realBegin()
    {
        $this->link->autocommit(false);
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    protected function realCommit()
    {
        $this->link->commit();
        $this->link->autocommit(true);
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    protected function realRollback()
    {
        $this->link->rollback();
        $this->link->autocommit(true);
        return $this;
    }

    /**
     * Fill connect params with defaults
     *
     * @param  array $params
     * @return array
     * @access protected
     */
    protected function fixParams(array $params)/*# : array */
    {
        return array_replace([
            'host' => 'localhost',
            'username' => 'root',
            'password' => null,
            'db' => null,
            'port' => null,
            'socket' => null
        ], $params);
    }

    /**
     *
     * @param  \mysqli $link
     * @throws LogicException if failed
     * @access protected
     */
    protected function isConenctFailed(\mysqli $link)
    {
        if ($link->connect_error) {
            throw new LogicException(
                Message::get(
                    Message::DB_CONNECT_FAIL,
                    $link->connect_errno,
                    $link->connect_error
                ),
                Message::DB_CONNECT_FAIL
            );
        }
    }

    /**
     * Set charset
     *
     * @param  \mysqli $link
     * @param  array $params
     * @access protected
     */
    protected function setCharset(\mysqli $link, array $params)
    {
        if (!empty($params['charset'])) {
            $link->set_charset($params['charset']);
        }
    }

    /**
     * Is attribute defined ?
     *
     * @param  string $attribute
     * @throws LogicException
     * @access protected
     */
    protected function checkAttribute(/*# string */ $attribute)
    {
        if (!defined($attribute)) {
            throw new LogicException(
                Message::get(Message::DB_ATTRIBUTE_UNKNOWN, $attribute),
                Message::DB_ATTRIBUTE_UNKNOWN
            );
        }
    }
}


1		<?php
2		/**
3		* Phossa Project
4		*
5		* PHP version 5.4
6		*
7		* @category Library
8		* @package Phossa2\Db
9		* @copyright Copyright (c) 2016 phossa.com
10		* @license http://mit-license.org/ MIT License
11		* @link http://www.phossa.com/
12		*/
13		/# declare(strict_types=1); /
14
15		namespace Phossa2\Db\Driver\Mysqli;
16
17		use Phossa2\Db\Message\Message;
18		use Phossa2\Db\Driver\DriverAbstract;
19		use Phossa2\Db\Exception\LogicException;
20		use Phossa2\Db\Interfaces\StatementInterface;
21
22		/**
23		* Driver
24		*
25		* Mysqli driver
26		*
27		* @package Phossa2\Db
28		* @author Hong Zhang <[email protected]>
29		* @see DriverAbstract
30		* @version 2.0.0
31		* @since 2.0.0 added
32		*/
33		class Driver extends DriverAbstract
34		{
35		/**
36		* the connection link
37		*
38		* @var \mysqli
39		* @access protected
40		*/
41		protected $link;
42
43		/**
44		* Default mysqli attributes
45		*
46		* @var array
47		* @access protected
48		*/
49		protected $attributes = [
50		'MYSQLI_OPT_CONNECT_TIMEOUT' => 300,
51		'MYSQLI_OPT_LOCAL_INFILE' => true,
52		'MYSQLI_INIT_COMMAND' => '',
53		];
54
55		/**
56		* Driver constructor
57		*
58		* @param array $connectInfo
59		* @param StatementInterface $statementPrototype
60		* @throws InvalidArgumentException if link type not right
61		* @throws LogicException driver specific extension not loaded
62		* @access public
63		*/
64		public function __construct(
65		$connectInfo,
66		StatementInterface $statementPrototype = null
67		) {
68		parent::__construct($connectInfo);
69
70		// set prototypes
71		$this->statement_prototype = $statementPrototype ?: new Statement();
72		}
73
74		/**
75		* {@inheritDoc}
76		*/
77		protected function extensionLoaded()/# : bool /
78		{
79		return extension_loaded('mysqli');
80		}
81
82		/**
83		* {@inheritDoc}
84		*/
85		protected function realLastId($name)
86		{
87		return $this->link->insert_id;
88		}
89
90		/**
91		* {@inheritDoc}
92		*/
93		protected function realQuote(
94		$string,
95		/# int / $type
96		)/# : string / {
97		return '\'' . $this->link->real_escape_string($string) . '\'';
98		}
99
100		/**
101		* {@inheritDoc}
102		*/
103		protected function realConnect(array $parameters)
104		{
105		// init
106		$link = new \mysqli();
107		$link->init();
108
109		// params with defaults
110		$p = $this->fixParams($parameters);
111
112		// real connect
113		$link->real_connect(
114		$p['host'],
115		$p['username'],
116		$p['password'],
117		$p['db'],
118		$p['port'],
119		$p['socket']
120		);
121
122		$this->isConenctFailed($link);
123		$this->setCharset($link, $parameters);
124		return $link;
125		}
126
127		/**
128		* Disconnect the \PDO link
129		*
130		* {@inheritDoc}
131		*/
132		protected function realDisconnect()
133		{
134		$this->link->close();
135		}
136
137		/**
138		* {@inheritDoc}
139		*/
140		protected function realPing()/# : bool /
141		{
142		return $this->link->ping();
143		}
144
145		/**
146		* {@inheritDoc}
147		*/
148	View Code Duplication	protected function realSetAttribute(/# string / $attribute, $value)
		0 ignored issues – show Duplication introduced 2016-09-27 11:59 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
149		{
150		if (is_string($attribute)) {
151		$this->checkAttribute($attribute);
152		$this->link->options(constant($attribute), $value);
153		} else {
154		$this->link->options($attribute, $value);
155		}
156		return $this;
157		}
158
159		/**
160		* {@inheritDoc}
161		*/
162		protected function realGetAttribute(/# string / $attribute)
163		{
164		if (is_string($attribute)) {
165		$this->checkAttribute($attribute);
166		}
167		return null;
168		}
169
170		/**
171		* {@inheritDoc}
172		*/
173		protected function realBegin()
174		{
175		$this->link->autocommit(false);
176		return $this;
177		}
178
179		/**
180		* {@inheritDoc}
181		*/
182		protected function realCommit()
183		{
184		$this->link->commit();
185		$this->link->autocommit(true);
186		return $this;
187		}
188
189		/**
190		* {@inheritDoc}
191		*/
192		protected function realRollback()
193		{
194		$this->link->rollback();
195		$this->link->autocommit(true);
196		return $this;
197		}
198
199		/**
200		* Fill connect params with defaults
201		*
202		* @param array $params
203		* @return array
204		* @access protected
205		*/
206		protected function fixParams(array $params)/# : array /
207		{
208		return array_replace([
209		'host' => 'localhost',
210		'username' => 'root',
211		'password' => null,
212		'db' => null,
213		'port' => null,
214		'socket' => null
215		], $params);
216		}
217
218		/**
219		*
220		* @param \mysqli $link
221		* @throws LogicException if failed
222		* @access protected
223		*/
224		protected function isConenctFailed(\mysqli $link)
225		{
226		if ($link->connect_error) {
227		throw new LogicException(
228		Message::get(
229		Message::DB_CONNECT_FAIL,
230		$link->connect_errno,
231		$link->connect_error
232		),
233		Message::DB_CONNECT_FAIL
234		);
235		}
236		}
237
238		/**
239		* Set charset
240		*
241		* @param \mysqli $link
242		* @param array $params
243		* @access protected
244		*/
245		protected function setCharset(\mysqli $link, array $params)
246		{
247		if (!empty($params['charset'])) {
248		$link->set_charset($params['charset']);
249		}
250		}
251
252		/**
253		* Is attribute defined ?
254		*
255		* @param string $attribute
256		* @throws LogicException
257		* @access protected
258		*/
259		protected function checkAttribute(/# string / $attribute)
260		{
261		if (!defined($attribute)) {
262		throw new LogicException(
263		Message::get(Message::DB_ATTRIBUTE_UNKNOWN, $attribute),
264		Message::DB_ATTRIBUTE_UNKNOWN
265		);
266		}
267		}
268		}
269

phossa2 / libs

Driver::realCommit() A last analyzed 2016-10-12 00:59 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Driver::realCommit() A
last analyzed 2016-10-12 00:59 UTC