MysqlDriver::clearTable() - Code Metrics - Inspection of "remove abstract from Connection, remove IDriver fr..." - linpax/microphp-framework - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( aaac57...e2ab3e )

by Oleg

created 2016-07-06 17:37 UTC

MysqlDriver::clearTable() A

↳ Parent: MysqlDriver::listFields()

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
c	2
b	0
f	0
dl	0
loc	4
rs	10
cc	1
eloc	2
nc	1
nop	1

<?php /** MysqlDriverMicro */

namespace Micro\Db\Drivers;

/**
 * MySQL Driver class file.
 *
 * @author Oleg Lunegov <[email protected]>
 * @link https://github.com/linpax/microphp-framework
 * @copyright Copyright (c) 2013 Oleg Lunegov
 * @license https://github.com/linpax/microphp-framework/blob/master/LICENSE
 * @package Micro
 * @subpackage Db\Drivers
 * @version 1.0
 * @since 1.0
 */
class MysqlDriver extends Driver
{
    /**
     * Set current database
     *
     * @access public
     *
     * @param string $dbName Database name
     *
     * @return boolean
     */
    public function switchDatabase($dbName)
    {
        return $this->conn->exec("USE {$dbName};") !== false;
    }

    /**
     * Info of database
     *
     * @access public
     * @param string $dbName Database name
     * @return array
     */
    public function infoDatabase($dbName)
    {
        $sth = $this->conn->query("SHOW TABLE STATUS FROM {$dbName};");

        $result = [];
        foreach ($sth->fetchAll() AS $row) {
            $result[] = [
                'name' => $row['Name'],
                'engine' => $row['Engine'],
                'rows' => $row['Rows'],
                'length' => $row['Avg_row_length'],
                'increment' => $row['Auto_increment'],
                'collation' => $row['Collation']
            ];
        }

        return $result;
    }

    /**
     * List database names on this connection
     *
     * @access public
     * @return array
     */
    public function listDatabases()
    {
        $sql = 'SHOW DATABASES;';

        if ($this->getDriverType() === 'pgsql') {
            $sql = 'SELECT datname FROM pg_database;';
        }

        $sth = $this->conn->query($sql);
        $result = [];

        foreach ($sth->fetchAll() AS $row) {
            $result[] = $row[0];
        }

        return $result;
    }

    /**
     * List tables in db
     *
     * @access public
     * @return array
     */
    public function listTables()
    {
        return $this->conn->query('SHOW TABLES;')->fetchAll(\PDO::FETCH_COLUMN, 0);
    }

    /**
     * Create a new table
     *
     * @param string $name Table name
     * @param array $elements Table elements
     * @param string $params Table params
     *
     * @return int
     */
    public function createTable($name, array $elements = [], $params = '')
    {
        return $this->conn->exec(
            sprintf('SELECT TABLE IF NOT EXISTS `%s` (%s) %s;', $name, implode(', ', $elements), $params)
        );
    }

    /**
     * Remove table from database
     *
     * @access public
     *
     * @param string $name Table name
     *
     * @return mixed
     */
    public function removeTable($name)
    {
        return $this->conn->exec("DROP TABLE {$name};");
    }

    /**
     * Get array fields into table
     *
     * @access public
     *
     * @param string $table Table name
     *
     * @return array
     */
    public function listFields($table)
    {
        $sth = $this->conn->query("SHOW COLUMNS FROM {$table};");

        $result = [];
        foreach ($sth->fetchAll(\PDO::FETCH_ASSOC) as $row) {
            $result[] = [
                'field' => $row['Field'],
                'type' => $row['Type'],
                'null' => $row['Null'],
                'key' => $row['Key'],
                'default' => $row['Default'],
                'extra' => $row['Extra']
            ];
        }

        return $result;
    }

    /**
     * Get info of a field
     *
     * @access public
     *
     * @param string $field Field name
     * @param string $table Table name
     *
     * @return array|boolean
     */
    public function fieldInfo($field, $table)
    {
        if ($this->fieldExists($field, $table)) {
            return $this->conn->query("SELECT {$field} FROM {$table} LIMIT 1;")->getColumnMeta(0);
        }

        return false;
    }

    /**
     * Insert row into table
     *
     * @access public
     *
     * @param string $table Table name
     * @param array $line Line or lines to added
     * @param bool $multi Is multi rows
     *
     * @return bool
     */
    public function insert($table, array $line = [], $multi = false)

    {
        $fields = '`' . implode('`, `', array_keys($multi ? $line[0] : $line)) . '`';

        $values = ':'.implode(', :', array_keys($multi ? $line[0] : $line));
        $rows = $multi ? $line : [$line];
        $id = null;

        if ($rows) {

            $this->conn->beginTransaction();

            $dbh = null;
            foreach ($rows AS $row) {
                $dbh = $this->conn->prepare("INSERT INTO {$table} ({$fields}) VALUES ({$values});")->execute($row);
            }

            $id = $dbh ? $this->conn->lastInsertId() : false;
            $this->conn->commit();
        }

        return $id ?: false;
    }

    /**
     * Update row in table
     *
     * @access public
     *
     * @param string $table Table name
     * @param array $elements Elements to update
     * @param string $conditions Conditions for search
     *
     * @return bool
     */
    public function update($table, array $elements = [], $conditions = '')
    {
        $keys = array_keys($elements);
        if (0 === count($keys)) {
            return false;
        }

        $valStr = [];
        foreach ($keys as $key) {
            $valStr[] = '`'.$key.'` = :'.$key;
        }
        $valStr = implode(',', $valStr);

        if ($conditions) {
            $conditions = 'WHERE '.$conditions;
        }

        return $this->conn->prepare("UPDATE {$table} SET {$valStr} {$conditions};")->execute($elements);
    }

    /**
     * Delete row from table
     *
     * @access public
     *
     * @param string $table Table name
     * @param string $conditions Conditions to search
     * @param array $params Params array
     *
     * @return bool
     */
    public function delete($table, $conditions, array $params = [])
    {
        return $this->conn->prepare("DELETE FROM {$table} WHERE {$conditions};")->execute($params);
    }

    /**
     * Count element in sub-query
     *
     * @access public
     *
     * @param string $query Query
     * @param string $table Table name
     *
     * @return integer|boolean
     */
    public function count($query = '', $table = '')
    {
        if ($query) {
            $sth = $this->conn->prepare("SELECT COUNT(*) FROM ({$query}) AS m;");
        } elseif ($table) {
            $sth = $this->conn->prepare("SELECT COUNT(*) FROM {$table} AS m;");
        } else {
            return false;
        }
        if ($sth->execute()) {
            return $sth->fetchColumn();
        }

        return false;
    }

    /**
     * Exists element in the table by params
     *
     * @access public
     *
     * @param string $table Table name
     * @param array $params Params array
     *
     * @return bool
     */
    public function exists($table, array $params = [])
    {
        $keys = [];

        foreach ($params AS $key => $val) {
            $keys[] = $table . '.' . $key . '=\'' . $val . '\'';
        }

        $sth = $this->conn->prepare('SELECT * FROM ' . $table . ' WHERE ' . implode(' AND ', $keys) . ' LIMIT 1;');
        /** @noinspection PdoApiUsageInspection */
        $sth->execute();

        return (bool)$sth->rowCount();
    }
}


1		<?php /** MysqlDriverMicro */
2
3		namespace Micro\Db\Drivers;
4
5		/**
6		* MySQL Driver class file.
7		*
8		* @author Oleg Lunegov <[email protected]>
9		* @link https://github.com/linpax/microphp-framework
10		* @copyright Copyright (c) 2013 Oleg Lunegov
11		* @license https://github.com/linpax/microphp-framework/blob/master/LICENSE
12		* @package Micro
13		* @subpackage Db\Drivers
14		* @version 1.0
15		* @since 1.0
16		*/
17		class MysqlDriver extends Driver
18		{
19		/**
20		* Set current database
21		*
22		* @access public
23		*
24		* @param string $dbName Database name
25		*
26		* @return boolean
27		*/
28		public function switchDatabase($dbName)
29		{
30		return $this->conn->exec("USE {$dbName};") !== false;
31		}
32
33		/**
34		* Info of database
35		*
36		* @access public
37		* @param string $dbName Database name
38		* @return array
39		*/
40		public function infoDatabase($dbName)
41		{
42		$sth = $this->conn->query("SHOW TABLE STATUS FROM {$dbName};");
43
44		$result = [];
45		foreach ($sth->fetchAll() AS $row) {
46		$result[] = [
47		'name' => $row['Name'],
48		'engine' => $row['Engine'],
49		'rows' => $row['Rows'],
50		'length' => $row['Avg_row_length'],
51		'increment' => $row['Auto_increment'],
52		'collation' => $row['Collation']
53		];
54		}
55
56		return $result;
57		}
58
59		/**
60		* List database names on this connection
61		*
62		* @access public
63		* @return array
64		*/
65		public function listDatabases()
66		{
67		$sql = 'SHOW DATABASES;';
68
69		if ($this->getDriverType() === 'pgsql') {
70		$sql = 'SELECT datname FROM pg_database;';
71		}
72
73		$sth = $this->conn->query($sql);
74		$result = [];
75
76		foreach ($sth->fetchAll() AS $row) {
77		$result[] = $row[0];
78		}
79
80		return $result;
81		}
82
83		/**
84		* List tables in db
85		*
86		* @access public
87		* @return array
88		*/
89		public function listTables()
90		{
91		return $this->conn->query('SHOW TABLES;')->fetchAll(\PDO::FETCH_COLUMN, 0);
92		}
93
94		/**
95		* Create a new table
96		*
97		* @param string $name Table name
98		* @param array $elements Table elements
99		* @param string $params Table params
100		*
101		* @return int
102		*/
103		public function createTable($name, array $elements = [], $params = '')
104		{
105		return $this->conn->exec(
106		sprintf('SELECT TABLE IF NOT EXISTS `%s` (%s) %s;', $name, implode(', ', $elements), $params)
107		);
108		}
109
110		/**
111		* Remove table from database
112		*
113		* @access public
114		*
115		* @param string $name Table name
116		*
117		* @return mixed
118		*/
119		public function removeTable($name)
120		{
121		return $this->conn->exec("DROP TABLE {$name};");
122		}
123
124		/**
125		* Get array fields into table
126		*
127		* @access public
128		*
129		* @param string $table Table name
130		*
131		* @return array
132		*/
133		public function listFields($table)
134		{
135		$sth = $this->conn->query("SHOW COLUMNS FROM {$table};");
136
137		$result = [];
138		foreach ($sth->fetchAll(\PDO::FETCH_ASSOC) as $row) {
139		$result[] = [
140		'field' => $row['Field'],
141		'type' => $row['Type'],
142		'null' => $row['Null'],
143		'key' => $row['Key'],
144		'default' => $row['Default'],
145		'extra' => $row['Extra']
146		];
147		}
148
149		return $result;
150		}
151
152		/**
153		* Get info of a field
154		*
155		* @access public
156		*
157		* @param string $field Field name
158		* @param string $table Table name
159		*
160		* @return array\|boolean
161		*/
162		public function fieldInfo($field, $table)
163		{
164		if ($this->fieldExists($field, $table)) {
165		return $this->conn->query("SELECT {$field} FROM {$table} LIMIT 1;")->getColumnMeta(0);
166		}
167
168		return false;
169		}
170
171		/**
172		* Insert row into table
173		*
174		* @access public
175		*
176		* @param string $table Table name
177		* @param array $line Line or lines to added
178		* @param bool $multi Is multi rows
179		*
180		* @return bool
181		*/
182	View Code Duplication	public function insert($table, array $line = [], $multi = false)
		0 ignored issues – show Duplication introduced 2016-07-04 21:40 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...
183		{
184		$fields = '`' . implode('`, `', array_keys($multi ? $line[0] : $line)) . '`';
185
186		$values = ':'.implode(', :', array_keys($multi ? $line[0] : $line));
187		$rows = $multi ? $line : [$line];
188		$id = null;
189
190		if ($rows) {
		0 ignored issues – show Bug Best Practice introduced 2016-06-06 16:38 UTC by Report Bug Copy Issue Report The expression `$rows` 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...
191		$this->conn->beginTransaction();
192
193		$dbh = null;
194		foreach ($rows AS $row) {
195		$dbh = $this->conn->prepare("INSERT INTO {$table} ({$fields}) VALUES ({$values});")->execute($row);
196		}
197
198		$id = $dbh ? $this->conn->lastInsertId() : false;
199		$this->conn->commit();
200		}
201
202		return $id ?: false;
203		}
204
205		/**
206		* Update row in table
207		*
208		* @access public
209		*
210		* @param string $table Table name
211		* @param array $elements Elements to update
212		* @param string $conditions Conditions for search
213		*
214		* @return bool
215		*/
216		public function update($table, array $elements = [], $conditions = '')
217		{
218		$keys = array_keys($elements);
219		if (0 === count($keys)) {
220		return false;
221		}
222
223		$valStr = [];
224		foreach ($keys as $key) {
225		$valStr[] = '`'.$key.'` = :'.$key;
226		}
227		$valStr = implode(',', $valStr);
228
229		if ($conditions) {
230		$conditions = 'WHERE '.$conditions;
231		}
232
233		return $this->conn->prepare("UPDATE {$table} SET {$valStr} {$conditions};")->execute($elements);
234		}
235
236		/**
237		* Delete row from table
238		*
239		* @access public
240		*
241		* @param string $table Table name
242		* @param string $conditions Conditions to search
243		* @param array $params Params array
244		*
245		* @return bool
246		*/
247		public function delete($table, $conditions, array $params = [])
248		{
249		return $this->conn->prepare("DELETE FROM {$table} WHERE {$conditions};")->execute($params);
250		}
251
252		/**
253		* Count element in sub-query
254		*
255		* @access public
256		*
257		* @param string $query Query
258		* @param string $table Table name
259		*
260		* @return integer\|boolean
261		*/
262		public function count($query = '', $table = '')
263		{
264		if ($query) {
265		$sth = $this->conn->prepare("SELECT COUNT(*) FROM ({$query}) AS m;");
266		} elseif ($table) {
267		$sth = $this->conn->prepare("SELECT COUNT(*) FROM {$table} AS m;");
268		} else {
269		return false;
270		}
271		if ($sth->execute()) {
272		return $sth->fetchColumn();
273		}
274
275		return false;
276		}
277
278		/**
279		* Exists element in the table by params
280		*
281		* @access public
282		*
283		* @param string $table Table name
284		* @param array $params Params array
285		*
286		* @return bool
287		*/
288		public function exists($table, array $params = [])
289		{
290		$keys = [];
291
292		foreach ($params AS $key => $val) {
293		$keys[] = $table . '.' . $key . '=\'' . $val . '\'';
294		}
295
296		$sth = $this->conn->prepare('SELECT * FROM ' . $table . ' WHERE ' . implode(' AND ', $keys) . ' LIMIT 1;');
297		/** @noinspection PdoApiUsageInspection */
298		$sth->execute();
299
300		return (bool)$sth->rowCount();
301		}
302		}
303

linpax / microphp-framework

Push — master ( aaac57...e2ab3e )

MysqlDriver::clearTable() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like