Pdo - Code Metrics - jaeger-app/db - Measure and Improve Code Quality continuously with Scrutinizer

Pdo C
last analyzed 2016-07-10 06:49 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	394
Duplicated Lines	2.28 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
wmc	59
c	2
b	0
f	0
lcom	1
cbo	3
dl	9
loc	394
rs	6.1904

16 Methods

Rating	Name	Duplication	Size	Complexity
B	update()	0	23	4
A	query()	0	8	3
A	escape()	0	4	1
A	select()	0	6	1
A	insert()	0	19	2
A	getAllTables()	0	5	1
A	getTableStatus()	0	5	1
A	getCreateTable()	0	18	4
A	clear()	0	6	1
A	totalRows()	0	12	3
A	getColumns()	9	9	2
B	get()	0	25	4
A	setCredentials()	0	5	1
A	getDb()	0	17	3
A	setDbName()	0	6	1
D	parseArrayPair()	0	109	27

How to fix Duplicated Code Complexity

Duplicated Code

Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.

Common duplication problems, and corresponding solutions are:

If you have the same expression in different places: Extract expression to a method
If you have the same method in different sub-classes: Extract method, and pull up field to the parent class
If you have the same code in unrelated classes: Consider extracting the code to a new class, and injecting that class

Complex Class

Tip: Before tackling complexity, make sure that you eliminate any duplication first. This often can reduce the size of classes significantly.

Complex classes like Pdo often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.

Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.

While breaking up the class, it is a good idea to analyze how other classes use Pdo, and based on these observations, apply Extract Interface, too.

<?php
/**
 * Jaeger
 *
 * @copyright	Copyright (c) 2015-2016, mithra62
 * @link		http://jaeger-app.com
 * @version		1.0
 * @filesource 	./Db/Pdo.php
 */
 
namespace JaegerApp\Db;

use Aura\Sql\ExtendedPdo; 
use Aura\SqlQuery\QueryFactory;

/**
 * Jaeger - PDO Database Object
 *
 * Wrapper for a simple PDO abstraction
 *
 * @package Database
 * @author Eric Lamb <[email protected]>
 */
class Pdo implements DbInterface
{
    /**
     * The primary table we're working with
     * @var string
     */
    protected $table = null;
    
    /**
     * Any filtering for a WHERE SQL clause
     * @var mixed
     */
    protected $where = false;
    
    /**
     * The database connection credentials
     * @var array
     */
    protected $credentials = array();
    
    /**
     * The database object we're piggybacking on
     * @var \Aura\Sql\ExtendedPdo
     */
    protected $db = null;
    
    /**
     * A matched array of "bad" characters our string manipulation hates
     * @var array
     */
    protected $escape_chars = array(
        'search' => array("\\", "\0", "\n", "\r", "\x1a", "'", '"'),
        'replace' => array("\\\\", "\\0", "\\n", "\\r", "\Z", "\'", '\"')
    );
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::select()
     */
    public function select($table, $where)
    {
        $this->table = $table;
        $this->where = $where;
        return $this;
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::insert()
     */
    public function insert($table, array $data = array())
    {
        $query_factory = new QueryFactory('mysql');
        $insert = $query_factory->newInsert();
        $insert->into($table);
        $cols = $bind = array();
        foreach($data AS $key => $value)
        {
            $cols[] = $key;
            $bind[$key] = $value;
        }
        
        $insert->cols($cols)->bindValues($bind);
        $sth = $this->getDb()->prepare($insert->getStatement());
        $sth->execute($insert->getBindValues());
        
        $name = $insert->getLastInsertIdName('id');
        return $this->getDb()->lastInsertId($name);
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::update()
     */
    public function update($table, $data, $where)
    {
        $query_factory = new QueryFactory('mysql');
        $update = $query_factory->newUpdate()->table($table);
abstract class User
{
    /** @return string */
    abstract public function getPassword();
}

class MyUser extends User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}
        $cols = $bind = array();
        foreach($data AS $key => $value)
        {
            $cols[] = $key;
            $bind[$key] = $value;
        }
        
        if (is_string($where)) {
            $where = $this->escape($where);
        } elseif (is_array($where)) {
            $where = $this->parseArrayPair($where, 'AND');
        } else {
            $where = '';
        }        
        
        $update->cols($cols)->where($where)->bindValues($bind);
        $sth = $this->getDb()->prepare($update->getStatement());
        return $sth->execute($update->getBindValues());
    }
    
    /**
     * (non-PHPdoc)
     * @see \Aura\Sql\ExtendedPdo::query()
     */
    public function query($sql = '', $return = false)
    {
        if( strtolower(substr($sql,0, 6)) == 'select' || strtolower(substr($sql,0, 4)) == 'show' ){
            return $this->getDb()->fetchAll($sql);
        } else {
            return $this->getDb()->exec($sql);
        }
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::escape()
     */
    public function escape($string)
    {
        return str_replace($this->escape_chars['search'], $this->escape_chars['replace'], $string);  
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::getAllTables()
     */
    public function getAllTables()
    {
        $sql = 'SHOW TABLES';
        return $this->getDb()->fetchAll($sql);
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::getTableStatus()
     */
    public function getTableStatus()
    {
        $sql = 'SHOW TABLE STATUS';
        return $this->getDb()->fetchAll($sql);  
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::getCreateTable()
     */
    public function getCreateTable($table, $if_not_exists = false)

    {
        $sql = sprintf('SHOW CREATE TABLE `%s` ;', $table);
        $statement = $this->query($sql, true);
        $string = false;
        if (! empty($statement['0']['Create Table'])) {
            $string = $statement['0']['Create Table'];
        }
        
        if ($if_not_exists) {
            $replace = substr($string, 0, 12);
            if ($replace == 'CREATE TABLE') {
                $string = str_replace('CREATE TABLE', 'CREATE TABLE IF NOT EXISTS ', $string);
            }
        }
        
        return $string;
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::clear()
     */
    public function clear()
    {
        $this->table = null;
        $this->where = null;
        return $this;
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::totalRows()
     */
    public function totalRows($table)

    {
        $sql = sprintf('SELECT COUNT(*) AS count FROM `%s`', $table);
        $statement = $this->query($sql, true);
        if ($statement) {
            if (isset($statement['0']['count'])) {
                return $statement['0']['count'];
            }
        }
        
        return '0';
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::getColumns()
     */
    public function getColumns($table)

    {
        $sql = sprintf('SHOW COLUMNS FROM `%s`', $table);
        $statement = $this->query($sql, true);

        if ($statement) {
            return $statement;
        }
        return array();
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::get()
     */
    public function get()
    {
        $query_factory = new QueryFactory('mysql');
        $select = $query_factory->newSelect();
        $select->cols(array('*'))->from($this->table);
        
        if (is_string($this->where)) {
            $where = $this->escape($this->where);
        } elseif (is_array($this->where)) {
            $where = $this->parseArrayPair($this->where, 'AND');
        } else {
            $where = '';
        }
        
        $select->where($where);
        
        $sql = $select->getStatement();
        
        $return = $this->getDb()->fetchAll($sql);
        if($return)

        {
            return $return;
        }
        return array();    
    }
    
    /**
     * 
     * @param array $credentials
     * @return \JaegerApp\Db\Mysqli
     */
    public function setCredentials(array $credentials)
    {
        $this->credentials = $credentials;
        return $this;
    }
    
    /**
     * (non-PHPdoc)
     * @see \JaegerApp\Db\DbInterface::getDb()
     */
    public function getDb($force = false)
    {
        if (is_null($this->db) || $force) {
        
            $this->db = new ExtendedPdo(
                'mysql:host='.$this->credentials['host'].';dbname='.$this->credentials['database'],
                $this->credentials['user'],
                $this->credentials['password'],
                array(), // driver options as key-value pairs
                array()  // attributes as key-value pairs
            );
            
            $this->db->setAttribute(ExtendedPdo::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
        }
        
        return $this->db;
    }
    
    /**
     * 
     * @param unknown $db_name
     */
    public function setDbName($db_name)
    {
        $this->credentials['database'] = $db_name;
        $this->getDb(true);
        return $this;
    }
    
    /**
     * Takes the WHERE array clause and prepairs it for use
     * @param array $arrayPair
     * @param string $glue
     */
    protected function parseArrayPair($arrayPair, $glue = ',')
    {
        // init
        $sql = '';
        $pairs = array();
    
        if (!empty($arrayPair)) {
    
            foreach ($arrayPair as $_key => $_value) {
                $_connector = '=';
                $_key_upper = strtoupper($_key);
    
                if (strpos($_key_upper, ' NOT') !== false) {
                    $_connector = 'NOT';
                }
    
                if (strpos($_key_upper, ' IS') !== false) {
                    $_connector = 'IS';
                }
    
                if (strpos($_key_upper, ' IS NOT') !== false) {
                    $_connector = 'IS NOT';
                }
    
                if (strpos($_key_upper, ' IN') !== false) {
                    $_connector = 'IN';
                }
    
                if (strpos($_key_upper, ' NOT IN') !== false) {
                    $_connector = 'NOT IN';
                }
    
                if (strpos($_key_upper, ' BETWEEN') !== false) {
                    $_connector = 'BETWEEN';
                }
    
                if (strpos($_key_upper, ' NOT BETWEEN') !== false) {
                    $_connector = 'NOT BETWEEN';
                }
    
                if (strpos($_key_upper, ' LIKE') !== false) {
                    $_connector = 'LIKE';
                }
    
                if (strpos($_key_upper, ' NOT LIKE') !== false) {
                    $_connector = 'NOT LIKE';
                }
    
                if (strpos($_key_upper, ' >') !== false && strpos($_key_upper, ' =') === false) {

                    $_connector = '>';
                }
    
                if (strpos($_key_upper, ' <') !== false && strpos($_key_upper, ' =') === false) {

                    $_connector = '<';
                }
    
                if (strpos($_key_upper, ' >=') !== false) {
                    $_connector = '>=';
                }
    
                if (strpos($_key_upper, ' <=') !== false) {
                    $_connector = '<=';
                }
    
                if (strpos($_key_upper, ' <>') !== false) {
                    $_connector = '<>';
                }
    
                if (
                    is_array($_value)
                    &&
                    (
                        $_connector == 'NOT IN'
                        ||
                        $_connector == 'IN'
                    )
                ) {
                    foreach ($_value as $oldKey => $oldValue) {
                        /** @noinspection AlterInForeachInspection */
                        $_value[$oldKey] = $this->escape($oldValue);
                    }
                    $_value = '(' . implode(',', $_value) . ')';
                } elseif (
                    is_array($_value)
                    &&
                    (
                        $_connector == 'NOT BETWEEN'
                        ||
                        $_connector == 'BETWEEN'
                    )
                ) {
                    foreach ($_value as $oldKey => $oldValue) {
                        /** @noinspection AlterInForeachInspection */
                        $_value[$oldKey] = $this->escape($oldValue);
                    }
                    $_value = '(' . implode(' AND ', $_value) . ')';
                } else {
                    $_value = $this->getDb()->quote($_value);
                }
    
                $quoteString = '`'.$_key.'`';
                $pairs[] = ' ' . $quoteString . ' ' . $_connector . ' ' . $_value . " \n";
            }
    
            $sql = implode($glue, $pairs);
        }
    
        return $sql;
    }    
}

1		<?php
2		/**
3		* Jaeger
4		*
5		* @copyright Copyright (c) 2015-2016, mithra62
6		* @link http://jaeger-app.com
7		* @version 1.0
8		* @filesource ./Db/Pdo.php
9		*/
10
11		namespace JaegerApp\Db;
12
13		use Aura\Sql\ExtendedPdo;
14		use Aura\SqlQuery\QueryFactory;
15
16		/**
17		* Jaeger - PDO Database Object
18		*
19		* Wrapper for a simple PDO abstraction
20		*
21		* @package Database
22		* @author Eric Lamb <[email protected]>
23		*/
24		class Pdo implements DbInterface
25		{
26		/**
27		* The primary table we're working with
28		* @var string
29		*/
30		protected $table = null;
31
32		/**
33		* Any filtering for a WHERE SQL clause
34		* @var mixed
35		*/
36		protected $where = false;
37
38		/**
39		* The database connection credentials
40		* @var array
41		*/
42		protected $credentials = array();
43
44		/**
45		* The database object we're piggybacking on
46		* @var \Aura\Sql\ExtendedPdo
47		*/
48		protected $db = null;
49
50		/**
51		* A matched array of "bad" characters our string manipulation hates
52		* @var array
53		*/
54		protected $escape_chars = array(
55		'search' => array("\\", "\0", "\n", "\r", "\x1a", "'", '"'),
56		'replace' => array("\\\\", "\\0", "\\n", "\\r", "\Z", "\'", '\"')
57		);
58
59		/**
60		* (non-PHPdoc)
61		* @see \JaegerApp\Db\DbInterface::select()
62		*/
63		public function select($table, $where)
64		{
65		$this->table = $table;
66		$this->where = $where;
67		return $this;
68		}
69
70		/**
71		* (non-PHPdoc)
72		* @see \JaegerApp\Db\DbInterface::insert()
73		*/
74		public function insert($table, array $data = array())
75		{
76		$query_factory = new QueryFactory('mysql');
77		$insert = $query_factory->newInsert();
78		$insert->into($table);
79		$cols = $bind = array();
80		foreach($data AS $key => $value)
81		{
82		$cols[] = $key;
83		$bind[$key] = $value;
84		}
85
86		$insert->cols($cols)->bindValues($bind);
87		$sth = $this->getDb()->prepare($insert->getStatement());
88		$sth->execute($insert->getBindValues());
89
90		$name = $insert->getLastInsertIdName('id');
91		return $this->getDb()->lastInsertId($name);
92		}
93
94		/**
95		* (non-PHPdoc)
96		* @see \JaegerApp\Db\DbInterface::update()
97		*/
98		public function update($table, $data, $where)
99		{
100		$query_factory = new QueryFactory('mysql');
101		$update = $query_factory->newUpdate()->table($table);
		0 ignored issues – show Bug introduced 2016-04-19 03:00 UTC by Report Bug Copy Issue Report It seems like you code against a specific sub-type and not the parent class `Aura\SqlQuery\AbstractQuery` as the method `table()` does only exist in the following sub-classes of `Aura\SqlQuery\AbstractQuery`: `Aura\SqlQuery\Common\Update`, `Aura\SqlQuery\Mysql\Update`, `Aura\SqlQuery\Pgsql\Update`, `Aura\SqlQuery\Sqlite\Update`, `Aura\SqlQuery\Sqlsrv\Update`. Maybe you want to `instanceof` check for one of these explicitly? Let’s take a look at an example: abstract class User { /** @return string / abstract public function getPassword(); } class MyUser extends User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different sub-classes of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the parent class: abstract class User { /** @return string / abstract public function getPassword(); /* @return string */ abstract public function getDisplayName(); } Loading history...
102		$cols = $bind = array();
103		foreach($data AS $key => $value)
104		{
105		$cols[] = $key;
106		$bind[$key] = $value;
107		}
108
109		if (is_string($where)) {
110		$where = $this->escape($where);
111		} elseif (is_array($where)) {
112		$where = $this->parseArrayPair($where, 'AND');
113		} else {
114		$where = '';
115		}
116
117		$update->cols($cols)->where($where)->bindValues($bind);
118		$sth = $this->getDb()->prepare($update->getStatement());
119		return $sth->execute($update->getBindValues());
120		}
121
122		/**
123		* (non-PHPdoc)
124		* @see \Aura\Sql\ExtendedPdo::query()
125		*/
126		public function query($sql = '', $return = false)
127		{
128		if( strtolower(substr($sql,0, 6)) == 'select' \|\| strtolower(substr($sql,0, 4)) == 'show' ){
129		return $this->getDb()->fetchAll($sql);
130		} else {
131		return $this->getDb()->exec($sql);
132		}
133		}
134
135		/**
136		* (non-PHPdoc)
137		* @see \JaegerApp\Db\DbInterface::escape()
138		*/
139		public function escape($string)
140		{
141		return str_replace($this->escape_chars['search'], $this->escape_chars['replace'], $string);
142		}
143
144		/**
145		* (non-PHPdoc)
146		* @see \JaegerApp\Db\DbInterface::getAllTables()
147		*/
148		public function getAllTables()
149		{
150		$sql = 'SHOW TABLES';
151		return $this->getDb()->fetchAll($sql);
152		}
153
154		/**
155		* (non-PHPdoc)
156		* @see \JaegerApp\Db\DbInterface::getTableStatus()
157		*/
158		public function getTableStatus()
159		{
160		$sql = 'SHOW TABLE STATUS';
161		return $this->getDb()->fetchAll($sql);
162		}
163
164		/**
165		* (non-PHPdoc)
166		* @see \JaegerApp\Db\DbInterface::getCreateTable()
167		*/
168		public function getCreateTable($table, $if_not_exists = false)
		0 ignored issues – show Duplication introduced 2016-04-19 03:00 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...
169		{
170		$sql = sprintf('SHOW CREATE TABLE `%s` ;', $table);
171		$statement = $this->query($sql, true);
172		$string = false;
173		if (! empty($statement['0']['Create Table'])) {
174		$string = $statement['0']['Create Table'];
175		}
176
177		if ($if_not_exists) {
178		$replace = substr($string, 0, 12);
179		if ($replace == 'CREATE TABLE') {
180		$string = str_replace('CREATE TABLE', 'CREATE TABLE IF NOT EXISTS ', $string);
181		}
182		}
183
184		return $string;
185		}
186
187		/**
188		* (non-PHPdoc)
189		* @see \JaegerApp\Db\DbInterface::clear()
190		*/
191		public function clear()
192		{
193		$this->table = null;
194		$this->where = null;
195		return $this;
196		}
197
198		/**
199		* (non-PHPdoc)
200		* @see \JaegerApp\Db\DbInterface::totalRows()
201		*/
202		public function totalRows($table)
		0 ignored issues – show Duplication introduced 2016-04-19 03:00 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...
203		{
204		$sql = sprintf('SELECT COUNT(*) AS count FROM `%s`', $table);
205		$statement = $this->query($sql, true);
206		if ($statement) {
207		if (isset($statement['0']['count'])) {
208		return $statement['0']['count'];
209		}
210		}
211
212		return '0';
213		}
214
215		/**
216		* (non-PHPdoc)
217		* @see \JaegerApp\Db\DbInterface::getColumns()
218		*/
219	View Code Duplication	public function getColumns($table)
		0 ignored issues – show Duplication introduced 2016-04-19 03:00 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...
220		{
221		$sql = sprintf('SHOW COLUMNS FROM `%s`', $table);
222		$statement = $this->query($sql, true);
		0 ignored issues – show Bug Compatibility introduced 2016-04-19 03:00 UTC by Report Bug Copy Issue Report The expression `$this->query($sql, true);` of type `array\|integer` adds the type `integer` to the return on line 224 which is incompatible with the return type declared by the interface `JaegerApp\Db\DbInterface::getColumns` of type `array`. Loading history...
223		if ($statement) {
224		return $statement;
225		}
226		return array();
227		}
228
229		/**
230		* (non-PHPdoc)
231		* @see \JaegerApp\Db\DbInterface::get()
232		*/
233		public function get()
234		{
235		$query_factory = new QueryFactory('mysql');
236		$select = $query_factory->newSelect();
237		$select->cols(array('*'))->from($this->table);
238
239		if (is_string($this->where)) {
240		$where = $this->escape($this->where);
241		} elseif (is_array($this->where)) {
242		$where = $this->parseArrayPair($this->where, 'AND');
243		} else {
244		$where = '';
245		}
246
247		$select->where($where);
248
249		$sql = $select->getStatement();
250
251		$return = $this->getDb()->fetchAll($sql);
252		if($return)
		0 ignored issues – show Bug Best Practice introduced 2016-04-19 03:00 UTC by Report Bug Copy Issue Report The expression `$return` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `! empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
253		{
254		return $return;
255		}
256		return array();
257		}
258
259		/**
260		*
261		* @param array $credentials
262		* @return \JaegerApp\Db\Mysqli
263		*/
264		public function setCredentials(array $credentials)
265		{
266		$this->credentials = $credentials;
267		return $this;
268		}
269
270		/**
271		* (non-PHPdoc)
272		* @see \JaegerApp\Db\DbInterface::getDb()
273		*/
274		public function getDb($force = false)
275		{
276		if (is_null($this->db) \|\| $force) {
277
278		$this->db = new ExtendedPdo(
279		'mysql:host='.$this->credentials['host'].';dbname='.$this->credentials['database'],
280		$this->credentials['user'],
281		$this->credentials['password'],
282		array(), // driver options as key-value pairs
283		array() // attributes as key-value pairs
284		);
285
286		$this->db->setAttribute(ExtendedPdo::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
287		}
288
289		return $this->db;
290		}
291
292		/**
293		*
294		* @param unknown $db_name
295		*/
296		public function setDbName($db_name)
297		{
298		$this->credentials['database'] = $db_name;
299		$this->getDb(true);
300		return $this;
301		}
302
303		/**
304		* Takes the WHERE array clause and prepairs it for use
305		* @param array $arrayPair
306		* @param string $glue
307		*/
308		protected function parseArrayPair($arrayPair, $glue = ',')
309		{
310		// init
311		$sql = '';
312		$pairs = array();
313
314		if (!empty($arrayPair)) {
315
316		foreach ($arrayPair as $_key => $_value) {
317		$_connector = '=';
318		$_key_upper = strtoupper($_key);
319
320		if (strpos($_key_upper, ' NOT') !== false) {
321		$_connector = 'NOT';
322		}
323
324		if (strpos($_key_upper, ' IS') !== false) {
325		$_connector = 'IS';
326		}
327
328		if (strpos($_key_upper, ' IS NOT') !== false) {
329		$_connector = 'IS NOT';
330		}
331
332		if (strpos($_key_upper, ' IN') !== false) {
333		$_connector = 'IN';
334		}
335
336		if (strpos($_key_upper, ' NOT IN') !== false) {
337		$_connector = 'NOT IN';
338		}
339
340		if (strpos($_key_upper, ' BETWEEN') !== false) {
341		$_connector = 'BETWEEN';
342		}
343
344		if (strpos($_key_upper, ' NOT BETWEEN') !== false) {
345		$_connector = 'NOT BETWEEN';
346		}
347
348		if (strpos($_key_upper, ' LIKE') !== false) {
349		$_connector = 'LIKE';
350		}
351
352		if (strpos($_key_upper, ' NOT LIKE') !== false) {
353		$_connector = 'NOT LIKE';
354		}
355
356		if (strpos($_key_upper, ' >') !== false && strpos($_key_upper, ' =') === false) {
		0 ignored issues – show Duplication introduced 2016-04-19 03:00 UTC by Report Bug Copy Issue Report This code seems to be duplicated across 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...
357		$_connector = '>';
358		}
359
360		if (strpos($_key_upper, ' <') !== false && strpos($_key_upper, ' =') === false) {
		0 ignored issues – show Duplication introduced 2016-04-19 03:00 UTC by Report Bug Copy Issue Report This code seems to be duplicated across 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...
361		$_connector = '<';
362		}
363
364		if (strpos($_key_upper, ' >=') !== false) {
365		$_connector = '>=';
366		}
367
368		if (strpos($_key_upper, ' <=') !== false) {
369		$_connector = '<=';
370		}
371
372		if (strpos($_key_upper, ' <>') !== false) {
373		$_connector = '<>';
374		}
375
376		if (
377		is_array($_value)
378		&&
379		(
380		$_connector == 'NOT IN'
381		\|\|
382		$_connector == 'IN'
383		)
384		) {
385		foreach ($_value as $oldKey => $oldValue) {
386		/** @noinspection AlterInForeachInspection */
387		$_value[$oldKey] = $this->escape($oldValue);
388		}
389		$_value = '(' . implode(',', $_value) . ')';
390		} elseif (
391		is_array($_value)
392		&&
393		(
394		$_connector == 'NOT BETWEEN'
395		\|\|
396		$_connector == 'BETWEEN'
397		)
398		) {
399		foreach ($_value as $oldKey => $oldValue) {
400		/** @noinspection AlterInForeachInspection */
401		$_value[$oldKey] = $this->escape($oldValue);
402		}
403		$_value = '(' . implode(' AND ', $_value) . ')';
404		} else {
405		$_value = $this->getDb()->quote($_value);
406		}
407
408		$quoteString = '`'.$_key.'`';
409		$pairs[] = ' ' . $quoteString . ' ' . $_connector . ' ' . $_value . " \n";
410		}
411
412		$sql = implode($glue, $pairs);
413		}
414
415		return $sql;
416		}
417		}

jaeger-app / db

Pdo C last analyzed 2016-07-10 06:49 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

16 Methods

How to fix Duplicated Code Complexity

Duplicated Code

Complex Class

Available Fixes

Duplication Side-by-Side

Filter issues like

Pdo C
last analyzed 2016-07-10 06:49 UTC