TMysqlMetaData::getIsView() - Code Metrics - Inspection of "Fix #727 - Php compatibility bug in TMysqlMetaData..." - pradosoft/prado - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( a8469e...0f6b23 )

by Fabio

created 2020-11-26 16:20 UTC

TMysqlMetaData::getIsView() B

↳ Parent: TMysqlMetaData

Complexity

Conditions	7
Paths	19

Size

Total Lines	18
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	11.6004

Importance

Changes	3
Bugs	0	Features	0

Metric	Value
cc	7
eloc	13
nc	19
nop	2
dl	0
loc	18
ccs	6
cts	11
cp	0.5455
crap	11.6004
rs	8.8333
c	3
b	0
f	0

<?php
/**
 * TMysqlMetaData class file.
 *
 * @author Wei Zhuo <weizhuo[at]gmail[dot]com>
 * @link https://github.com/pradosoft/prado
 * @license https://github.com/pradosoft/prado/blob/master/LICENSE
 * @package Prado\Data\Common\Mysql
 */

namespace Prado\Data\Common\Mysql;

/**
 * Load the base TDbMetaData class.
 */
use PDO;
use Prado\Data\Common\TDbMetaData;
use Prado\Data\TDbColumnCaseMode;
use Prado\Exceptions\TDbException;
use Prado\Prado;

/**
 * TMysqlMetaData loads Mysql version 4.1.x and 5.x database table and column information.
 *
 * For Mysql version 4.1.x, PHP 5.1.3 or later is required.
 * See http://netevil.org/node.php?nid=795&SC=1
 *
 * @author Wei Zhuo <weizho[at]gmail[dot]com>
 * @package Prado\Data\Common\Mysql
 * @since 3.1
 */
class TMysqlMetaData extends TDbMetaData
{
	private $_serverVersion = 0;

	/**
	 * @return string TDbTableInfo class name.
	 */
	protected function getTableInfoClass()
	{
		return '\Prado\Data\Common\Mysql\TMysqlTableInfo';
	}

	/**
	 * @return string TDbTableColumn class name.
	 */
	protected function getTableColumnClass()
	{
		return '\Prado\Data\Common\Mysql\TMysqlTableColumn';
	}

	/**
	 * Quotes a table name for use in a query.
	 * @param string $name $name table name
	 * @return string the properly quoted table name
	 */
	public function quoteTableName($name)
	{
		return parent::quoteTableName($name, '`', '`');
	}

	/**
	 * Quotes a column name for use in a query.
	 * @param string $name $name column name
	 * @return string the properly quoted column name
	 */
	public function quoteColumnName($name)
	{
		return parent::quoteColumnName($name, '`', '`');
	}

	/**
	 * Quotes a column alias for use in a query.
	 * @param string $name $name column alias
	 * @return string the properly quoted column alias
	 */
	public function quoteColumnAlias($name)
	{
		return parent::quoteColumnAlias($name, '`', '`');
	}

	/**
	 * Get the column definitions for given table.
	 * @param string $table table name.
	 * @return TMysqlTableInfo table information.
	 */
	protected function createTableInfo($table)
	{
		[$schemaName, $tableName] = $this->getSchemaTableName($table);
		$find = $schemaName === null ? "`{$tableName}`" : "`{$schemaName}`.`{$tableName}`";
		$colCase = $this->getDbConnection()->getColumnCase();
		if ($colCase != TDbColumnCaseMode::Preserved) {
			$this->getDbConnection()->setColumnCase('Preserved');
		}
		$this->getDbConnection()->setActive(true);
		$sql = "SHOW FULL FIELDS FROM {$find}";
		$command = $this->getDbConnection()->createCommand($sql);
		$tableInfo = $this->createNewTableInfo($table);
		$index = 0;
		foreach ($command->query() as $col) {
			$col['index'] = $index++;
			$this->processColumn($tableInfo, $col);
		}
		if ($index === 0) {
			throw new TDbException('dbmetadata_invalid_table_view', $table);
		}
		if ($colCase != TDbColumnCaseMode::Preserved) {
			$this->getDbConnection()->setColumnCase($colCase);
		}
		return $tableInfo;
	}

	/**
	 * @return float server version.
	 */
	protected function getServerVersion()
	{
		if (!$this->_serverVersion) {
			$version = $this->getDbConnection()->getAttribute(PDO::ATTR_SERVER_VERSION);
			$digits = [];
			preg_match('/(\d+)\.(\d+)\.(\d+)/', $version, $digits);
			$this->_serverVersion = (float) ($digits[1] . '.' . $digits[2] . $digits[3]);
		}
		return $this->_serverVersion;
	}

	/**
	 * @param TMysqlTableInfo $tableInfo table information.
	 * @param array $col column information.
	 */
	protected function processColumn($tableInfo, $col)
	{
		$columnId = $col['Field'];

		$info['ColumnName'] = "`$columnId`"; //quote the column names!

		$info['ColumnId'] = $columnId;
		$info['ColumnIndex'] = $col['index'];
		if ($col['Null'] === 'YES') {
			$info['AllowNull'] = true;
		}
		if (is_int(strpos(strtolower($col['Extra']), 'auto_increment'))) {

			$info['AutoIncrement'] = true;
		}
		if ($col['Default'] !== "") {
			$info['DefaultValue'] = $col['Default'];
		}

		if ($col['Key'] === 'PRI' || in_array($columnId, $tableInfo->getPrimaryKeys())) {
			$info['IsPrimaryKey'] = true;
		}
		if ($this->isForeignKeyColumn($columnId, $tableInfo)) {
			$info['IsForeignKey'] = true;
		}

		$info['DbType'] = $col['Type'];
		$match = [];
		//find SET/ENUM values, column size, precision, and scale
		if (preg_match('/\((.*)\)/', $col['Type'], $match)) {
			$info['DbType'] = preg_replace('/\(.*\)/', '', $col['Type']);

			//find SET/ENUM values
			if ($this->isEnumSetType($info['DbType'])) {
				$info['DbTypeValues'] = preg_split("/[',]/S", $match[1], -1, PREG_SPLIT_NO_EMPTY);
			}

			//find column size, precision and scale
			$pscale = [];
			if (preg_match('/(\d+)(?:,(\d+))?+/', $match[1], $pscale)) {
				if ($this->isPrecisionType($info['DbType'])) {
					$info['NumericPrecision'] = (int) ($pscale[1]);
					if (count($pscale) > 2) {
						$info['NumericScale'] = (int) ($pscale[2]);
					}
				} else {
					$info['ColumnSize'] = (int) ($pscale[1]);
				}
			}
		}

		$class = $this->getTableColumnClass();
		$tableInfo->Columns[$columnId] = new $class($info);

	}

	/**
	 * @param mixed $type
	 * @return bool true if column type if "numeric", "interval" or begins with "time".
	 */
	protected function isPrecisionType($type)
	{
		$type = strtolower(trim($type));
		return $type === 'decimal' || $type === 'dec'
				|| $type === 'float' || $type === 'double'
				|| $type === 'double precision' || $type === 'real';
	}

	/**
	 * @param mixed $type
	 * @return bool true if column type if "enum" or "set".
	 */
	protected function isEnumSetType($type)
	{
		$type = strtolower(trim($type));
		return $type === 'set' || $type === 'enum';
	}

	/**
	 * @param string $table table name, may be quoted with back-ticks and may contain database name.
	 * @throws TDbException when table name contains invalid identifier bytes.
	 * @return array tuple ($schema,$table), $schema may be null.
	 */
	protected function getSchemaTableName($table)
	{
		//remove the back ticks and separate out the "database.table"
		$result = explode('.', str_replace('`', '', $table));
		foreach ($result as $name) {
			if (!$this->isValidIdentifier($name)) {
				$ref = 'http://dev.mysql.com/doc/refman/5.0/en/identifiers.html';
				throw new TDbException('dbcommon_invalid_identifier_name', $table, $ref);
			}
		}
		return count($result) > 1 ? $result : [null, $result[0]];
	}

	/**
	 * http://dev.mysql.com/doc/refman/5.0/en/identifiers.html
	 * @param string $name identifier name
	 * @return bool true if valid identifier.
	 */
	protected function isValidIdentifier($name)
	{
		return !preg_match('#/|\\|.|\x00|\xFF#', $name);
	}

	/**
	 * @param string $table table schema name
	 * @return TMysqlTableInfo
	 */
	protected function createNewTableInfo($table)
	{
		[$schemaName, $tableName] = $this->getSchemaTableName($table);
		$info['SchemaName'] = $schemaName;

		$info['TableName'] = $tableName;
		if ($this->getIsView($schemaName, $tableName)) {
			$info['IsView'] = true;
		}
		[$primary, $foreign] = $this->getConstraintKeys($schemaName, $tableName);
		$class = $this->getTableInfoClass();
		return new $class($info, $primary, $foreign);
	}

	/**
	 * For MySQL version 5.0.1 or later we can use SHOW FULL TABLES
	 * http://dev.mysql.com/doc/refman/5.0/en/show-tables.html
	 *
	 * For MySQL version 5.0.1 or earlier, this always return false.
	 * @param string $schemaName database name, null to use default connection database.
	 * @param string $tableName table or view name.
	 * @throws TDbException if table or view does not exist.
	 * @return bool true if is view, false otherwise.
	 */
	protected function getIsView($schemaName, $tableName)
	{
		if ($this->getServerVersion() < 5.01) {
			return false;
		}
		if ($schemaName !== null) {

			$sql = "SHOW FULL TABLES FROM `{$schemaName}` LIKE '{$tableName}'";
		} else {
			$sql = "SHOW FULL TABLES LIKE '{$tableName}'";
		}

		$command = $this->getDbConnection()->createCommand($sql);
		try {
			$result = $command->queryRow();
			return $result && count($result) > 0 && $result['Table_type'] === 'VIEW';
		} catch (TDbException $e) {
			$table = $schemaName === null ? $tableName : $schemaName . '.' . $tableName;

			throw new TDbException('dbcommon_invalid_table_name', $table, $e->getMessage());
		}
	}

	/**
	 * Gets the primary and foreign key column details for the given table.
	 * @param string $schemaName schema name
	 * @param string $tableName table name.
	 * @return array tuple ($primary, $foreign)
	 */
	protected function getConstraintKeys($schemaName, $tableName)
	{
		$table = $schemaName === null ? "`{$tableName}`" : "`{$schemaName}`.`{$tableName}`";

		$sql = "SHOW INDEX FROM {$table}";
		$command = $this->getDbConnection()->createCommand($sql);
		$primary = [];
		foreach ($command->query() as $row) {
			if ($row['Key_name'] === 'PRIMARY') {
				$primary[] = $row['Column_name'];
			}
		}
		// MySQL version was increased to >=5.1.21 instead of 5.x
		// due to a MySQL bug (http://bugs.mysql.com/bug.php?id=19588)
		if ($this->getServerVersion() >= 5.121) {
			$foreign = $this->getForeignConstraints($schemaName, $tableName);
		} else {
			$foreign = $this->findForeignConstraints($schemaName, $tableName);
		}
		return [$primary, $foreign];
	}

	/**
	 * Gets foreign relationship constraint keys and table name
	 * @param string $schemaName database name
	 * @param string $tableName table name
	 * @return array foreign relationship table name and keys.
	 */
	protected function getForeignConstraints($schemaName, $tableName)
	{
		$andSchema = $schemaName !== null ? 'AND TABLE_SCHEMA LIKE :schema' : 'AND TABLE_SCHEMA LIKE DATABASE()';

		$sql = <<<EOD
			SELECT
				CONSTRAINT_NAME as con,
				COLUMN_NAME as col,
				REFERENCED_TABLE_SCHEMA as fkschema,
				REFERENCED_TABLE_NAME as fktable,
				REFERENCED_COLUMN_NAME as fkcol
			FROM
				`INFORMATION_SCHEMA`.`KEY_COLUMN_USAGE`
			WHERE
				REFERENCED_TABLE_NAME IS NOT NULL
				AND TABLE_NAME LIKE :table
				$andSchema
EOD;
		$command = $this->getDbConnection()->createCommand($sql);
		$command->bindValue(':table', $tableName);
		if ($schemaName !== null) {

			$command->bindValue(':schema', $schemaName);
		}
		$fkeys = [];
		foreach ($command->query() as $col) {
			$fkeys[$col['con']]['keys'][$col['col']] = $col['fkcol'];
			$fkeys[$col['con']]['table'] = $col['fktable'];
		}
		return count($fkeys) > 0 ? array_values($fkeys) : $fkeys;
	}

	/**
	 * @param string $schemaName database name
	 * @param string $tableName table name
	 * @throws TDbException if PHP version is less than 5.1.3
	 * @return string SQL command to create the table.
	 */
	protected function getShowCreateTable($schemaName, $tableName)
	{
		if (version_compare(PHP_VERSION, '5.1.3', '<')) {
			throw new TDbException('dbmetadata_requires_php_version', 'Mysql 4.1.x', '5.1.3');
		}

		//See http://netevil.org/node.php?nid=795&SC=1
		$this->getDbConnection()->setAttribute(PDO::ATTR_EMULATE_PREPARES, true);
		if ($schemaName !== null) {

			$sql = "SHOW CREATE TABLE `{$schemaName}`.`{$tableName}`";
		} else {
			$sql = "SHOW CREATE TABLE `{$tableName}`";
		}
		$command = $this->getDbConnection()->createCommand($sql);
		$result = $command->queryRow();
		return $result['Create Table'] ?? ($result['Create View'] ?? '');
	}

	/**
	 * Extract foreign key constraints by extracting the contraints from SHOW CREATE TABLE result.
	 * @param string $schemaName database name
	 * @param string $tableName table name
	 * @return array foreign relationship table name and keys.
	 */
	protected function findForeignConstraints($schemaName, $tableName)
	{
		$sql = $this->getShowCreateTable($schemaName, $tableName);
		$matches = [];
		$regexp = '/FOREIGN KEY\s+\(([^\)]+)\)\s+REFERENCES\s+`?([^`]+)`?\s\(([^\)]+)\)/mi';
		preg_match_all($regexp, $sql, $matches, PREG_SET_ORDER);
		$foreign = [];
		foreach ($matches as $match) {
			$fields = array_map('trim', explode(',', str_replace('`', '', $match[1])));
			$fk_fields = array_map('trim', explode(',', str_replace('`', '', $match[3])));
			$keys = [];
			foreach ($fields as $k => $v) {
				$keys[$v] = $fk_fields[$k];
			}
			$foreign[] = ['keys' => $keys, 'table' => trim($match[2])];
		}
		return $foreign;
	}

	/**
	 * @param string $columnId column name.
	 * @param TMysqlTableInfo $tableInfo table information.
	 * @return bool true if column is a foreign key.
	 */
	protected function isForeignKeyColumn($columnId, $tableInfo)
	{
		foreach ($tableInfo->getForeignKeys() as $fk) {
			if (in_array($columnId, array_keys($fk['keys']))) {
				return true;
			}
		}
		return false;
	}

	/**
	 * Returns all table names in the database.
	 * @param string $schema the schema of the tables. Defaults to empty string, meaning the current or default schema.
	 * If not empty, the returned table names will be prefixed with the schema name.
	 * @return array all table names in the database.
	 */
	public function findTableNames($schema = '')
	{
		if ($schema === '') {
			return $this->getDbConnection()->createCommand('SHOW TABLES')->queryColumn();
		}
		$names = $this->getDbConnection()->createCommand('SHOW TABLES FROM ' . $this->quoteTableName($schema))->queryColumn();
		foreach ($names as &$name) {
			$name = $schema . '.' . $name;
		}
		return $names;
	}
}


1		<?php
2		/**
3		* TMysqlMetaData class file.
4		*
5		* @author Wei Zhuo <weizhuo[at]gmail[dot]com>
6		* @link https://github.com/pradosoft/prado
7		* @license https://github.com/pradosoft/prado/blob/master/LICENSE
8		* @package Prado\Data\Common\Mysql
9		*/
10
11		namespace Prado\Data\Common\Mysql;
12
13		/**
14		* Load the base TDbMetaData class.
15		*/
16		use PDO;
17		use Prado\Data\Common\TDbMetaData;
18		use Prado\Data\TDbColumnCaseMode;
19		use Prado\Exceptions\TDbException;
20		use Prado\Prado;
21
22		/**
23		* TMysqlMetaData loads Mysql version 4.1.x and 5.x database table and column information.
24		*
25		* For Mysql version 4.1.x, PHP 5.1.3 or later is required.
26		* See http://netevil.org/node.php?nid=795&SC=1
27		*
28		* @author Wei Zhuo <weizho[at]gmail[dot]com>
29		* @package Prado\Data\Common\Mysql
30		* @since 3.1
31		*/
32		class TMysqlMetaData extends TDbMetaData
33		{
34		private $_serverVersion = 0;
35
36		/**
37		* @return string TDbTableInfo class name.
38		*/
39	11	protected function getTableInfoClass()
40		{
41	11	return '\Prado\Data\Common\Mysql\TMysqlTableInfo';
42		}
43
44		/**
45		* @return string TDbTableColumn class name.
46		*/
47	11	protected function getTableColumnClass()
48		{
49	11	return '\Prado\Data\Common\Mysql\TMysqlTableColumn';
50		}
51
52		/**
53		* Quotes a table name for use in a query.
54		* @param string $name $name table name
55		* @return string the properly quoted table name
56		*/
57		public function quoteTableName($name)
58		{
59		return parent::quoteTableName($name, '`', '`');
60		}
61
62		/**
63		* Quotes a column name for use in a query.
64		* @param string $name $name column name
65		* @return string the properly quoted column name
66		*/
67		public function quoteColumnName($name)
68		{
69		return parent::quoteColumnName($name, '`', '`');
70		}
71
72		/**
73		* Quotes a column alias for use in a query.
74		* @param string $name $name column alias
75		* @return string the properly quoted column alias
76		*/
77		public function quoteColumnAlias($name)
78		{
79		return parent::quoteColumnAlias($name, '`', '`');
80		}
81
82		/**
83		* Get the column definitions for given table.
84		* @param string $table table name.
85		* @return TMysqlTableInfo table information.
86		*/
87	11	protected function createTableInfo($table)
88		{
89	11	[$schemaName, $tableName] = $this->getSchemaTableName($table);
90	11	$find = $schemaName === null ? "`{$tableName}`" : "`{$schemaName}`.`{$tableName}`";
91	11	$colCase = $this->getDbConnection()->getColumnCase();
92	11	if ($colCase != TDbColumnCaseMode::Preserved) {
93		$this->getDbConnection()->setColumnCase('Preserved');
94		}
95	11	$this->getDbConnection()->setActive(true);
96	11	$sql = "SHOW FULL FIELDS FROM {$find}";
97	11	$command = $this->getDbConnection()->createCommand($sql);
98	11	$tableInfo = $this->createNewTableInfo($table);
99	11	$index = 0;
100	11	foreach ($command->query() as $col) {
101	11	$col['index'] = $index++;
102	11	$this->processColumn($tableInfo, $col);
103		}
104	11	if ($index === 0) {
105		throw new TDbException('dbmetadata_invalid_table_view', $table);
106		}
107	11	if ($colCase != TDbColumnCaseMode::Preserved) {
108		$this->getDbConnection()->setColumnCase($colCase);
109		}
110	11	return $tableInfo;
111		}
112
113		/**
114		* @return float server version.
115		*/
116	11	protected function getServerVersion()
117		{
118	11	if (!$this->_serverVersion) {
119	8	$version = $this->getDbConnection()->getAttribute(PDO::ATTR_SERVER_VERSION);
120	8	$digits = [];
121	8	preg_match('/(\d+)\.(\d+)\.(\d+)/', $version, $digits);
122	8	$this->_serverVersion = (float) ($digits[1] . '.' . $digits[2] . $digits[3]);
123		}
124	11	return $this->_serverVersion;
125		}
126
127		/**
128		* @param TMysqlTableInfo $tableInfo table information.
129		* @param array $col column information.
130		*/
131	11	protected function processColumn($tableInfo, $col)
132		{
133	11	$columnId = $col['Field'];
134
135	11	$info['ColumnName'] = "`$columnId`"; //quote the column names!
		0 ignored issues – show Comprehensibility Best Practice introduced 2018-02-15 21:32 UTC by Report Bug Copy Issue Report `$info` was never initialized. Although not strictly required by PHP, it is generally a good practice to add `$info = array();` before regardless. Loading history...
136	11	$info['ColumnId'] = $columnId;
137	11	$info['ColumnIndex'] = $col['index'];
138	11	if ($col['Null'] === 'YES') {
139	9	$info['AllowNull'] = true;
140		}
141	11	if (is_int(strpos(strtolower($col['Extra']), 'auto_increment'))) {
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `is_int(strpos(strtolower...']), 'auto_increment'))` is always `true`. Loading history...
142	5	$info['AutoIncrement'] = true;
143		}
144	11	if ($col['Default'] !== "") {
145	11	$info['DefaultValue'] = $col['Default'];
146		}
147
148	11	if ($col['Key'] === 'PRI' \|\| in_array($columnId, $tableInfo->getPrimaryKeys())) {
149	11	$info['IsPrimaryKey'] = true;
150		}
151	11	if ($this->isForeignKeyColumn($columnId, $tableInfo)) {
152		$info['IsForeignKey'] = true;
153		}
154
155	11	$info['DbType'] = $col['Type'];
156	11	$match = [];
157		//find SET/ENUM values, column size, precision, and scale
158	11	if (preg_match('/\((.*)\)/', $col['Type'], $match)) {
159	11	$info['DbType'] = preg_replace('/\(.*\)/', '', $col['Type']);
160
161		//find SET/ENUM values
162	11	if ($this->isEnumSetType($info['DbType'])) {
163	1	$info['DbTypeValues'] = preg_split("/[',]/S", $match[1], -1, PREG_SPLIT_NO_EMPTY);
164		}
165
166		//find column size, precision and scale
167	11	$pscale = [];
168	11	if (preg_match('/(\d+)(?:,(\d+))?+/', $match[1], $pscale)) {
169	11	if ($this->isPrecisionType($info['DbType'])) {
170	7	$info['NumericPrecision'] = (int) ($pscale[1]);
171	7	if (count($pscale) > 2) {
172	7	$info['NumericScale'] = (int) ($pscale[2]);
173		}
174		} else {
175	11	$info['ColumnSize'] = (int) ($pscale[1]);
176		}
177		}
178		}
179
180	11	$class = $this->getTableColumnClass();
181	11	$tableInfo->Columns[$columnId] = new $class($info);
		0 ignored issues – show Bug Best Practice introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The property `Columns` does not exist on `Prado\Data\Common\Mysql\TMysqlTableInfo`. Since you implemented `__get`, consider adding a @property annotation. Loading history...
182	11	}
183
184		/**
185		* @param mixed $type
186		* @return bool true if column type if "numeric", "interval" or begins with "time".
187		*/
188	11	protected function isPrecisionType($type)
189		{
190	11	$type = strtolower(trim($type));
191	11	return $type === 'decimal' \|\| $type === 'dec'
192	11	\|\| $type === 'float' \|\| $type === 'double'
193	11	\|\| $type === 'double precision' \|\| $type === 'real';
194		}
195
196		/**
197		* @param mixed $type
198		* @return bool true if column type if "enum" or "set".
199		*/
200	11	protected function isEnumSetType($type)
201		{
202	11	$type = strtolower(trim($type));
203	11	return $type === 'set' \|\| $type === 'enum';
204		}
205
206		/**
207		* @param string $table table name, may be quoted with back-ticks and may contain database name.
208		* @throws TDbException when table name contains invalid identifier bytes.
209		* @return array tuple ($schema,$table), $schema may be null.
210		*/
211	11	protected function getSchemaTableName($table)
212		{
213		//remove the back ticks and separate out the "database.table"
214	11	$result = explode('.', str_replace('`', '', $table));
215	11	foreach ($result as $name) {
216	11	if (!$this->isValidIdentifier($name)) {
217		$ref = 'http://dev.mysql.com/doc/refman/5.0/en/identifiers.html';
218	11	throw new TDbException('dbcommon_invalid_identifier_name', $table, $ref);
219		}
220		}
221	11	return count($result) > 1 ? $result : [null, $result[0]];
222		}
223
224		/**
225		* http://dev.mysql.com/doc/refman/5.0/en/identifiers.html
226		* @param string $name identifier name
227		* @return bool true if valid identifier.
228		*/
229	11	protected function isValidIdentifier($name)
230		{
231	11	return !preg_match('#/\|\\\|.\|\x00\|\xFF#', $name);
232		}
233
234		/**
235		* @param string $table table schema name
236		* @return TMysqlTableInfo
237		*/
238	11	protected function createNewTableInfo($table)
239		{
240	11	[$schemaName, $tableName] = $this->getSchemaTableName($table);
241	11	$info['SchemaName'] = $schemaName;
		0 ignored issues – show Comprehensibility Best Practice introduced 2018-02-15 21:32 UTC by Report Bug Copy Issue Report `$info` was never initialized. Although not strictly required by PHP, it is generally a good practice to add `$info = array();` before regardless. Loading history...
242	11	$info['TableName'] = $tableName;
243	11	if ($this->getIsView($schemaName, $tableName)) {
244		$info['IsView'] = true;
245		}
246	11	[$primary, $foreign] = $this->getConstraintKeys($schemaName, $tableName);
247	11	$class = $this->getTableInfoClass();
248	11	return new $class($info, $primary, $foreign);
249		}
250
251		/**
252		* For MySQL version 5.0.1 or later we can use SHOW FULL TABLES
253		* http://dev.mysql.com/doc/refman/5.0/en/show-tables.html
254		*
255		* For MySQL version 5.0.1 or earlier, this always return false.
256		* @param string $schemaName database name, null to use default connection database.
257		* @param string $tableName table or view name.
258		* @throws TDbException if table or view does not exist.
259		* @return bool true if is view, false otherwise.
260		*/
261	11	protected function getIsView($schemaName, $tableName)
262		{
263	11	if ($this->getServerVersion() < 5.01) {
264		return false;
265		}
266	11	if ($schemaName !== null) {
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `$schemaName !== null` is always `true`. Loading history...
267		$sql = "SHOW FULL TABLES FROM `{$schemaName}` LIKE '{$tableName}'";
268		} else {
269	11	$sql = "SHOW FULL TABLES LIKE '{$tableName}'";
270		}
271
272	11	$command = $this->getDbConnection()->createCommand($sql);
273		try {
274	11	$result = $command->queryRow();
275		return $result && count($result) > 0 && $result['Table_type'] === 'VIEW';
276		} catch (TDbException $e) {
277		$table = $schemaName === null ? $tableName : $schemaName . '.' . $tableName;
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `$schemaName === null` is always `false`. Loading history...
278		throw new TDbException('dbcommon_invalid_table_name', $table, $e->getMessage());
279		}
280		}
281
282		/**
283		* Gets the primary and foreign key column details for the given table.
284		* @param string $schemaName schema name
285		* @param string $tableName table name.
286		* @return array tuple ($primary, $foreign)
287	11	*/
288		protected function getConstraintKeys($schemaName, $tableName)
289	11	{
290	11	$table = $schemaName === null ? "`{$tableName}`" : "`{$schemaName}`.`{$tableName}`";
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `$schemaName === null` is always `false`. Loading history...
291	11	$sql = "SHOW INDEX FROM {$table}";
292	11	$command = $this->getDbConnection()->createCommand($sql);
293	11	$primary = [];
294	11	foreach ($command->query() as $row) {
295	11	if ($row['Key_name'] === 'PRIMARY') {
296		$primary[] = $row['Column_name'];
297		}
298		}
299		// MySQL version was increased to >=5.1.21 instead of 5.x
300	11	// due to a MySQL bug (http://bugs.mysql.com/bug.php?id=19588)
301	11	if ($this->getServerVersion() >= 5.121) {
302		$foreign = $this->getForeignConstraints($schemaName, $tableName);
303		} else {
304		$foreign = $this->findForeignConstraints($schemaName, $tableName);
305	11	}
306		return [$primary, $foreign];
307		}
308
309		/**
310		* Gets foreign relationship constraint keys and table name
311		* @param string $schemaName database name
312		* @param string $tableName table name
313		* @return array foreign relationship table name and keys.
314	11	*/
315		protected function getForeignConstraints($schemaName, $tableName)
316	11	{
317		$andSchema = $schemaName !== null ? 'AND TABLE_SCHEMA LIKE :schema' : 'AND TABLE_SCHEMA LIKE DATABASE()';
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `$schemaName !== null` is always `true`. Loading history...
318		$sql = <<<EOD
319		SELECT
320		CONSTRAINT_NAME as con,
321		COLUMN_NAME as col,
322		REFERENCED_TABLE_SCHEMA as fkschema,
323		REFERENCED_TABLE_NAME as fktable,
324		REFERENCED_COLUMN_NAME as fkcol
325		FROM
326		`INFORMATION_SCHEMA`.`KEY_COLUMN_USAGE`
327		WHERE
328		REFERENCED_TABLE_NAME IS NOT NULL
329	11	AND TABLE_NAME LIKE :table
330		$andSchema
331	11	EOD;
332	11	$command = $this->getDbConnection()->createCommand($sql);
333	11	$command->bindValue(':table', $tableName);
334		if ($schemaName !== null) {
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `$schemaName !== null` is always `true`. Loading history...
335		$command->bindValue(':schema', $schemaName);
336	11	}
337	11	$fkeys = [];
338		foreach ($command->query() as $col) {
339	11	$fkeys[$col['con']]['keys'][$col['col']] = $col['fkcol'];
340		$fkeys[$col['con']]['table'] = $col['fktable'];
341	11	}
342		return count($fkeys) > 0 ? array_values($fkeys) : $fkeys;
343		}
344
345		/**
346		* @param string $schemaName database name
347		* @param string $tableName table name
348		* @throws TDbException if PHP version is less than 5.1.3
349		* @return string SQL command to create the table.
350		*/
351		protected function getShowCreateTable($schemaName, $tableName)
352		{
353		if (version_compare(PHP_VERSION, '5.1.3', '<')) {
354		throw new TDbException('dbmetadata_requires_php_version', 'Mysql 4.1.x', '5.1.3');
355		}
356
357		//See http://netevil.org/node.php?nid=795&SC=1
358		$this->getDbConnection()->setAttribute(PDO::ATTR_EMULATE_PREPARES, true);
359		if ($schemaName !== null) {
		0 ignored issues – show introduced 2019-11-23 15:22 UTC by Report Bug Copy Issue Report The condition `$schemaName !== null` is always `true`. Loading history...
360		$sql = "SHOW CREATE TABLE `{$schemaName}`.`{$tableName}`";
361		} else {
362		$sql = "SHOW CREATE TABLE `{$tableName}`";
363		}
364		$command = $this->getDbConnection()->createCommand($sql);
365		$result = $command->queryRow();
366		return $result['Create Table'] ?? ($result['Create View'] ?? '');
367		}
368
369		/**
370		* Extract foreign key constraints by extracting the contraints from SHOW CREATE TABLE result.
371		* @param string $schemaName database name
372		* @param string $tableName table name
373		* @return array foreign relationship table name and keys.
374		*/
375		protected function findForeignConstraints($schemaName, $tableName)
376		{
377		$sql = $this->getShowCreateTable($schemaName, $tableName);
378		$matches = [];
379		$regexp = '/FOREIGN KEY\s+\(([^\)]+)\)\s+REFERENCES\s+`?([^`]+)`?\s\(([^\)]+)\)/mi';
380		preg_match_all($regexp, $sql, $matches, PREG_SET_ORDER);
381		$foreign = [];
382		foreach ($matches as $match) {
383		$fields = array_map('trim', explode(',', str_replace('`', '', $match[1])));
384		$fk_fields = array_map('trim', explode(',', str_replace('`', '', $match[3])));
385		$keys = [];
386		foreach ($fields as $k => $v) {
387		$keys[$v] = $fk_fields[$k];
388		}
389		$foreign[] = ['keys' => $keys, 'table' => trim($match[2])];
390		}
391		return $foreign;
392		}
393
394		/**
395		* @param string $columnId column name.
396		* @param TMysqlTableInfo $tableInfo table information.
397		* @return bool true if column is a foreign key.
398	11	*/
399		protected function isForeignKeyColumn($columnId, $tableInfo)
400	11	{
401		foreach ($tableInfo->getForeignKeys() as $fk) {
402		if (in_array($columnId, array_keys($fk['keys']))) {
403		return true;
404		}
405	11	}
406		return false;
407		}
408
409		/**
410		* Returns all table names in the database.
411		* @param string $schema the schema of the tables. Defaults to empty string, meaning the current or default schema.
412		* If not empty, the returned table names will be prefixed with the schema name.
413		* @return array all table names in the database.
414		*/
415		public function findTableNames($schema = '')
416		{
417		if ($schema === '') {
418		return $this->getDbConnection()->createCommand('SHOW TABLES')->queryColumn();
419		}
420		$names = $this->getDbConnection()->createCommand('SHOW TABLES FROM ' . $this->quoteTableName($schema))->queryColumn();
421		foreach ($names as &$name) {
422		$name = $schema . '.' . $name;
423		}
424		return $names;
425		}
426		}
427

pradosoft / prado

Push — master ( a8469e...0f6b23 )

TMysqlMetaData::getIsView() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like