|
1
|
|
|
<?php |
|
2
|
|
|
/** |
|
3
|
|
|
* components |
|
4
|
|
|
* |
|
5
|
|
|
* @author Wolfy-J |
|
6
|
|
|
*/ |
|
7
|
|
|
namespace Spiral\Database\Drivers\MySQL\Schemas; |
|
8
|
|
|
|
|
9
|
|
|
use Spiral\Database\Exceptions\SchemaException; |
|
10
|
|
|
use Spiral\Database\Schemas\Prototypes\AbstractTable; |
|
11
|
|
|
use Spiral\Database\Schemas\TableState; |
|
12
|
|
|
|
|
13
|
|
|
class TableSchema extends AbstractTable |
|
14
|
|
|
{ |
|
15
|
|
|
/** |
|
16
|
|
|
* List of most common MySQL table engines. |
|
17
|
|
|
*/ |
|
18
|
|
|
const ENGINE_INNODB = 'InnoDB'; |
|
19
|
|
|
const ENGINE_MYISAM = 'MyISAM'; |
|
20
|
|
|
const ENGINE_MEMORY = 'Memory'; |
|
21
|
|
|
|
|
22
|
|
|
/** |
|
23
|
|
|
* MySQL table engine. |
|
24
|
|
|
* |
|
25
|
|
|
* @var string |
|
26
|
|
|
*/ |
|
27
|
|
|
private $engine = self::ENGINE_INNODB; |
|
28
|
|
|
|
|
29
|
|
|
/** |
|
30
|
|
|
* Populate table schema with values from database. |
|
31
|
|
|
* |
|
32
|
|
|
* @param TableState $state |
|
33
|
|
|
*/ |
|
34
|
|
|
protected function initSchema(TableState $state) |
|
35
|
|
|
{ |
|
36
|
|
|
parent::initSchema($state); |
|
37
|
|
|
|
|
38
|
|
|
//Reading table schema |
|
39
|
|
|
$this->engine = $this->driver->query('SHOW TABLE STATUS WHERE `Name` = ?', [ |
|
40
|
|
|
$state->getName() |
|
41
|
|
|
])->fetch()['Engine']; |
|
42
|
|
|
} |
|
43
|
|
|
|
|
44
|
|
|
/** |
|
45
|
|
|
* Change table engine. Such operation will be applied only at moment of table creation. |
|
46
|
|
|
* |
|
47
|
|
|
* @param string $engine |
|
48
|
|
|
* |
|
49
|
|
|
* @return $this |
|
50
|
|
|
* |
|
51
|
|
|
* @throws SchemaException |
|
52
|
|
|
*/ |
|
53
|
|
|
public function setEngine($engine) |
|
54
|
|
|
{ |
|
55
|
|
|
if ($this->exists()) { |
|
56
|
|
|
throw new SchemaException('Table engine can be set only at moment of creation'); |
|
|
|
|
|
|
57
|
|
|
} |
|
58
|
|
|
|
|
59
|
|
|
$this->engine = $engine; |
|
60
|
|
|
|
|
61
|
|
|
return $this; |
|
62
|
|
|
} |
|
63
|
|
|
|
|
64
|
|
|
/** |
|
65
|
|
|
* @return string |
|
66
|
|
|
*/ |
|
67
|
|
|
public function getEngine() |
|
68
|
|
|
{ |
|
69
|
|
|
return $this->engine; |
|
70
|
|
|
} |
|
71
|
|
|
|
|
72
|
|
|
/** |
|
73
|
|
|
* {@inheritdoc} |
|
74
|
|
|
*/ |
|
75
|
|
View Code Duplication |
protected function fetchColumns(): array |
|
|
|
|
|
|
76
|
|
|
{ |
|
77
|
|
|
$query = "SHOW FULL COLUMNS FROM {$this->driver->identifier($this->getName())}"; |
|
78
|
|
|
|
|
79
|
|
|
$result = []; |
|
80
|
|
|
foreach ($this->driver->query($query) as $schema) { |
|
81
|
|
|
$result[] = ColumnSchema::createInstance($this->getName(), $schema); |
|
82
|
|
|
} |
|
83
|
|
|
|
|
84
|
|
|
return $result; |
|
85
|
|
|
} |
|
86
|
|
|
|
|
87
|
|
|
/** |
|
88
|
|
|
* {@inheritdoc} |
|
89
|
|
|
*/ |
|
90
|
|
|
protected function fetchIndexes(): array |
|
91
|
|
|
{ |
|
92
|
|
|
$query = "SHOW INDEXES FROM {$this->driver->identifier($this->getName())}"; |
|
93
|
|
|
|
|
94
|
|
|
//Gluing all index definitions together |
|
95
|
|
|
$schemas = []; |
|
96
|
|
|
foreach ($this->driver->query($query) as $index) { |
|
97
|
|
|
if ($index['Key_name'] == 'PRIMARY') { |
|
98
|
|
|
//Skipping PRIMARY index |
|
99
|
|
|
continue; |
|
100
|
|
|
} |
|
101
|
|
|
|
|
102
|
|
|
$schemas[$index['Key_name']][] = $index; |
|
103
|
|
|
} |
|
104
|
|
|
|
|
105
|
|
|
$result = []; |
|
106
|
|
|
foreach ($schemas as $name => $index) { |
|
107
|
|
|
$result[] = IndexSchema::createInstance($this->getName(), $name, $index); |
|
108
|
|
|
} |
|
109
|
|
|
|
|
110
|
|
|
return $result; |
|
111
|
|
|
} |
|
112
|
|
|
|
|
113
|
|
|
/** |
|
114
|
|
|
* {@inheritdoc} |
|
115
|
|
|
*/ |
|
116
|
|
|
protected function fetchReferences(): array |
|
117
|
|
|
{ |
|
118
|
|
|
$references = $this->driver->query( |
|
119
|
|
|
'SELECT * FROM `information_schema`.`referential_constraints` WHERE `constraint_schema` = ? AND `table_name` = ?', |
|
120
|
|
|
[$this->driver->getSource(), $this->getName()] |
|
121
|
|
|
); |
|
122
|
|
|
|
|
123
|
|
|
$result = []; |
|
124
|
|
|
foreach ($references as $schema) { |
|
|
|
|
|
|
125
|
|
|
$references = 'SELECT * FROM `information_schema`.`key_column_usage` WHERE `constraint_name` = ? AND `table_schema` = ? AND `table_name` = ?'; |
|
126
|
|
|
|
|
127
|
|
|
$column = $this->driver->query( |
|
128
|
|
|
$references, |
|
129
|
|
|
[$schema['CONSTRAINT_NAME'], $this->driver->getSource(), $this->getName()] |
|
130
|
|
|
)->fetch(); |
|
131
|
|
|
|
|
132
|
|
|
$result[] = ReferenceSchema::createInstance($this->getName(), $schema + $column); |
|
133
|
|
|
} |
|
134
|
|
|
|
|
135
|
|
|
return $result; |
|
136
|
|
|
} |
|
137
|
|
|
|
|
138
|
|
|
/** |
|
139
|
|
|
* Fetching primary keys from table. |
|
140
|
|
|
* |
|
141
|
|
|
* @return array |
|
142
|
|
|
*/ |
|
143
|
|
|
protected function fetchPrimaryKeys(): array |
|
144
|
|
|
{ |
|
145
|
|
|
$query = "SHOW INDEXES FROM {$this->driver->identifier($this->getName())}"; |
|
146
|
|
|
|
|
147
|
|
|
$primaryKeys = []; |
|
148
|
|
|
foreach ($this->driver->query($query) as $index) { |
|
149
|
|
|
if ($index['Key_name'] == 'PRIMARY') { |
|
150
|
|
|
$primaryKeys[] = $index['Column_name']; |
|
151
|
|
|
} |
|
152
|
|
|
} |
|
153
|
|
|
|
|
154
|
|
|
return $primaryKeys; |
|
155
|
|
|
} |
|
156
|
|
|
} |
This check compares calls to functions or methods with their respective definitions. If the call has more arguments than are defined, it raises an issue.
If a function is defined several times with a different number of parameters, the check may pick up the wrong definition and report false positives. One codebase where this has been known to happen is Wordpress.
In this case you can add the
@ignorePhpDoc annotation to the duplicate definition and it will be ignored.