MySQLDriver::setColumns() - Code Metrics - Inspection of "Improve code quality" - rougin/describe - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#3)

by Rougin

created 2016-11-27 14:24 UTC

MySQLDriver::setColumns() B

↳ Parent: MySQLDriver

Complexity

Conditions	2
Paths	2

Size

Total Lines	37
Code Lines	25

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	26
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	37
c	0
b	0
f	0
ccs	26
cts	26
cp	1
rs	8.8571
cc	2
eloc	25
nc	2
nop	2
crap	2

<?php

namespace Rougin\Describe\Driver;

use Rougin\Describe\Column;

/**
 * MySQL Driver
 *
 * A database driver extension for MySQL.
 *
 * @package  Describe
 * @category Driver
 * @author   Rougin Royce Gutib <[email protected]>
 */
class MySQLDriver implements DriverInterface
{
    /**
     * @var array
     */
    protected $columns = [];

    /**
     * @var string
     */
    protected $database;

    /**
     * @var \PDO
     */
    protected $pdo;

    /**
     * @param PDO    $pdo
     * @param string $database
     */
    public function __construct(\PDO $pdo, $database)
    {
        $this->database = $database;
        $this->pdo = $pdo;
    }

    /**
     * Returns the result.
     *
     * @param  string $tableName
     * @return array
     */
    public function getTable($tableName)
    {
        $this->columns = [];

        try {
            $information = $this->pdo->prepare('DESCRIBE ' . $tableName);

            $information->execute();
            $information->setFetchMode(\PDO::FETCH_OBJ);
        } catch (\PDOException $e) {
            // Table not found
        }

        while ($row = $information->fetch()) {
            $this->setColumns($tableName, $row);
        }

        return $this->columns;
    }

    /**
     * Shows the list of tables.
     *
     * @return array
     */
    public function showTables()
    {
        $tables = [];

        $information = $this->pdo->prepare('SHOW TABLES');
        $information->execute();

        while ($row = $information->fetch()) {
            array_push($tables, $row[0]);
        }

        return $tables;
    }

    /**
     * Prepares the defined columns.
     *
     * @param  string $tableName
     * @param  mixed  $row
     * @return void
     */
    protected function setColumns($tableName, $row)
    {
        preg_match('/(.*?)\((.*?)\)/', $row->Type, $match);

        $column = new Column;

        $this->setProperties($row, $column);
        $this->setKey($row, $column);

        $column->setDataType($row->Type);
        $column->setDefaultValue($row->Default);
        $column->setField($row->Field);

        if (isset($match[1])) {
            $column->setDataType($match[1]);
            $column->setLength($match[2]);
        }

        $query = 'SELECT COLUMN_NAME as "column",' .
            'REFERENCED_COLUMN_NAME as "referenced_column",' .
            'CONCAT(' .
                'REFERENCED_TABLE_SCHEMA, ".",' .
                'REFERENCED_TABLE_NAME' .
            ') as "referenced_table"' .
            'FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE ' .
            'WHERE CONSTRAINT_SCHEMA = "' . $this->database . '" ' .
            'AND TABLE_NAME = "' . $tableName . '";';

        $foreignTable = $this->pdo->prepare($query);

        $foreignTable->execute();
        $foreignTable->setFetchMode(\PDO::FETCH_OBJ);

        $this->setForeignColumns($foreignTable, $row, $column);

        array_push($this->columns, $column);
    }

    /**
     * Sets the key of the specified column.
     *
     * @param  mixed                   $row
     * @param  \Rougin\Describe\Column &$column
     * @return void
     */
    protected function setKey($row, Column &$column)
    {
        switch ($row->Key) {
            case 'PRI':
                $column->setPrimary(true);

                break;
            
            case 'MUL':
                $column->setForeign(true);

                break;

            case 'UNI':
                $column->setUnique(true);

                break;
        }
    }

    /**
     * Sets the properties of the specified column.
     *
     * @param  \PDOStatement           $foreignTable
     * @param  mixed                   $row
     * @param  \Rougin\Describe\Column &$column
     * @return void
     */
    protected function setForeignColumns($foreignTable, $row, Column &$column)
    {
        while ($foreignRow = $foreignTable->fetch()) {
            if ($foreignRow->column == $row->Field) {
                $referencedTable = $this->stripTableSchema($foreignRow->referenced_table);

                $column->setReferencedField($foreignRow->referenced_column);
                $column->setReferencedTable($referencedTable);
            }
        }
    }

    /**
     * Sets the properties of the specified column.
     *
     * @param  mixed                   $row
     * @param  \Rougin\Describe\Column &$column
     * @return void
     */
    protected function setProperties($row, Column &$column)
    {
        $null = 'Null';

        if ($row->Extra == 'auto_increment') {
            $column->setAutoIncrement(true);
        }

        if ($row->$null == 'YES') {
            $column->setNull(true);
        }
    }

    /**
     * Strips the table schema from the table name.
     *
     * @param  string $table
     * @return string
     */
    protected function stripTableSchema($table)
    {
        return (strpos($table, '.') !== false) ? substr($table, strpos($table, '.') + 1) : $table;
    }
}


1		<?php
2
3		namespace Rougin\Describe\Driver;
4
5		use Rougin\Describe\Column;
6
7		/**
8		* MySQL Driver
9		*
10		* A database driver extension for MySQL.
11		*
12		* @package Describe
13		* @category Driver
14		* @author Rougin Royce Gutib <[email protected]>
15		*/
16		class MySQLDriver implements DriverInterface
17		{
18		/**
19		* @var array
20		*/
21		protected $columns = [];
22
23		/**
24		* @var string
25		*/
26		protected $database;
27
28		/**
29		* @var \PDO
30		*/
31		protected $pdo;
32
33		/**
34		* @param PDO $pdo
35		* @param string $database
36		*/
37	60	public function __construct(\PDO $pdo, $database)
38		{
39	60	$this->database = $database;
40	60	$this->pdo = $pdo;
41	60	}
42
43		/**
44		* Returns the result.
45		*
46		* @param string $tableName
47		* @return array
48		*/
49	51	public function getTable($tableName)
50		{
51	51	$this->columns = [];
52
53		try {
54	51	$information = $this->pdo->prepare('DESCRIBE ' . $tableName);
55
56	51	$information->execute();
57	51	$information->setFetchMode(\PDO::FETCH_OBJ);
58	51	} catch (\PDOException $e) {
59		// Table not found
60		}
61
62	51	while ($row = $information->fetch()) {
63	48	$this->setColumns($tableName, $row);
64	48	}
65
66	51	return $this->columns;
67		}
68
69		/**
70		* Shows the list of tables.
71		*
72		* @return array
73		*/
74	9	public function showTables()
75		{
76	9	$tables = [];
77
78	9	$information = $this->pdo->prepare('SHOW TABLES');
79	9	$information->execute();
80
81	9	while ($row = $information->fetch()) {
82	9	array_push($tables, $row[0]);
83	9	}
84
85	9	return $tables;
86		}
87
88		/**
89		* Prepares the defined columns.
90		*
91		* @param string $tableName
92		* @param mixed $row
93		* @return void
94		*/
95	48	protected function setColumns($tableName, $row)
96		{
97	48	preg_match('/(.?)\((.?)\)/', $row->Type, $match);
98
99	48	$column = new Column;
100
101	48	$this->setProperties($row, $column);
102	48	$this->setKey($row, $column);
103
104	48	$column->setDataType($row->Type);
105	48	$column->setDefaultValue($row->Default);
106	48	$column->setField($row->Field);
107
108	48	if (isset($match[1])) {
109	48	$column->setDataType($match[1]);
110	48	$column->setLength($match[2]);
111	48	}
112
113		$query = 'SELECT COLUMN_NAME as "column",' .
114	48	'REFERENCED_COLUMN_NAME as "referenced_column",' .
115	48	'CONCAT(' .
116	48	'REFERENCED_TABLE_SCHEMA, ".",' .
117	48	'REFERENCED_TABLE_NAME' .
118	48	') as "referenced_table"' .
119	48	'FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE ' .
120	48	'WHERE CONSTRAINT_SCHEMA = "' . $this->database . '" ' .
121	48	'AND TABLE_NAME = "' . $tableName . '";';
122
123	48	$foreignTable = $this->pdo->prepare($query);
124
125	48	$foreignTable->execute();
126	48	$foreignTable->setFetchMode(\PDO::FETCH_OBJ);
127
128	48	$this->setForeignColumns($foreignTable, $row, $column);
129
130	48	array_push($this->columns, $column);
131	48	}
132
133		/**
134		* Sets the key of the specified column.
135		*
136		* @param mixed $row
137		* @param \Rougin\Describe\Column &$column
138		* @return void
139		*/
140	48	protected function setKey($row, Column &$column)
141		{
142	48	switch ($row->Key) {
143	48	case 'PRI':
144	48	$column->setPrimary(true);
145
146	48	break;
147
148	48	case 'MUL':
149	48	$column->setForeign(true);
150
151	48	break;
152
153	48	case 'UNI':
154	48	$column->setUnique(true);
155
156	48	break;
157	48	}
158	48	}
159
160		/**
161		* Sets the properties of the specified column.
162		*
163		* @param \PDOStatement $foreignTable
164		* @param mixed $row
165		* @param \Rougin\Describe\Column &$column
166		* @return void
167		*/
168	48	protected function setForeignColumns($foreignTable, $row, Column &$column)
169		{
170	48	while ($foreignRow = $foreignTable->fetch()) {
171	45	if ($foreignRow->column == $row->Field) {
172	45	$referencedTable = $this->stripTableSchema($foreignRow->referenced_table);
173
174	45	$column->setReferencedField($foreignRow->referenced_column);
175	45	$column->setReferencedTable($referencedTable);
176	45	}
177	45	}
178	48	}
179
180		/**
181		* Sets the properties of the specified column.
182		*
183		* @param mixed $row
184		* @param \Rougin\Describe\Column &$column
185		* @return void
186		*/
187	48	protected function setProperties($row, Column &$column)
188		{
189	48	$null = 'Null';
190
191	48	if ($row->Extra == 'auto_increment') {
192	48	$column->setAutoIncrement(true);
193	48	}
194
195	48	if ($row->$null == 'YES') {
196	48	$column->setNull(true);
197	48	}
198	48	}
199
200		/**
201		* Strips the table schema from the table name.
202		*
203		* @param string $table
204		* @return string
205		*/
206	45	protected function stripTableSchema($table)
207		{
208	45	return (strpos($table, '.') !== false) ? substr($table, strpos($table, '.') + 1) : $table;
209		}
210		}
211

rougin / describe

Pull Request — master (#3)

MySQLDriver::setColumns() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like