Total Complexity | 42 |
Total Lines | 237 |
Duplicated Lines | 0 % |
Changes | 7 | ||
Bugs | 0 | Features | 0 |
Complex classes like Table 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.
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 Table, and based on these observations, apply Extract Interface, too.
1 | <?php |
||
24 | class Table extends AbstractTable |
||
25 | { |
||
26 | use TableTrait; |
||
27 | |||
28 | /** |
||
29 | * @inheritDoc |
||
30 | */ |
||
31 | public function supportForeignKeys(TableEntity $tableStatus) |
||
32 | { |
||
33 | return !$this->connection->result("SELECT sqlite_compileoption_used('OMIT_FOREIGN_KEY')"); |
||
34 | } |
||
35 | |||
36 | /** |
||
37 | * @param string $type |
||
38 | * |
||
39 | * @return string |
||
40 | */ |
||
41 | private function rowType(string $type) |
||
42 | { |
||
43 | if (preg_match('~int~i', $type)) { |
||
44 | return 'integer'; |
||
45 | } |
||
46 | if (preg_match('~char|clob|text~i', $type)) { |
||
47 | return 'text'; |
||
48 | } |
||
49 | if (preg_match('~blob~i', $type)) { |
||
50 | return 'blob'; |
||
51 | } |
||
52 | if (preg_match('~real|floa|doub~i', $type)) { |
||
53 | return 'real'; |
||
54 | } |
||
55 | return 'numeric'; |
||
56 | } |
||
57 | |||
58 | private function defaultvalue(array $row) |
||
59 | { |
||
60 | $default = $row["dflt_value"]; |
||
61 | if (preg_match("~'(.*)'~", $default, $match)) { |
||
62 | return str_replace("''", "'", $match[1]); |
||
63 | } |
||
64 | if ($default == "NULL") { |
||
65 | return null; |
||
66 | } |
||
67 | return $default; |
||
68 | } |
||
69 | |||
70 | /** |
||
71 | * @param array $row |
||
72 | * |
||
73 | * @return TableFieldEntity |
||
74 | */ |
||
75 | private function makeFieldEntity(array $row) |
||
76 | { |
||
77 | $field = new TableFieldEntity(); |
||
78 | |||
79 | $type = strtolower($row["type"]); |
||
80 | $field->name = $row["name"]; |
||
81 | $field->type = $this->rowType($type); |
||
82 | $field->fullType = $type; |
||
83 | $field->default = $this->defaultvalue($row); |
||
84 | $field->null = !$row["notnull"]; |
||
85 | $field->privileges = ["select" => 1, "insert" => 1, "update" => 1]; |
||
86 | $field->primary = $row["pk"]; |
||
87 | return $field; |
||
88 | } |
||
89 | |||
90 | /** |
||
91 | * @param string $table |
||
92 | * |
||
93 | * @return array |
||
94 | */ |
||
95 | private function tableFields(string $table) |
||
96 | { |
||
97 | $fields = []; |
||
98 | $rows = $this->driver->rows('PRAGMA table_info(' . $this->driver->table($table) . ')'); |
||
99 | $primary = ""; |
||
100 | foreach ($rows as $row) { |
||
101 | $name = $row["name"]; |
||
102 | $type = strtolower($row["type"]); |
||
103 | $field = $this->makeFieldEntity($row); |
||
104 | if ($row["pk"]) { |
||
105 | if ($primary != "") { |
||
106 | $fields[$primary]->autoIncrement = false; |
||
107 | } elseif (preg_match('~^integer$~i', $type)) { |
||
108 | $field->autoIncrement = true; |
||
109 | } |
||
110 | $primary = $name; |
||
111 | } |
||
112 | $fields[$name] = $field; |
||
113 | } |
||
114 | return $fields; |
||
115 | } |
||
116 | |||
117 | /** |
||
118 | * @inheritDoc |
||
119 | */ |
||
120 | public function fields(string $table) |
||
121 | { |
||
122 | $fields = $this->tableFields($table); |
||
123 | $query = "SELECT sql FROM sqlite_master WHERE type IN ('table', 'view') AND name = " . $this->driver->quote($table); |
||
124 | $result = $this->connection->result($query); |
||
125 | $pattern = '~(("[^"]*+")+|[a-z0-9_]+)\s+text\s+COLLATE\s+(\'[^\']+\'|\S+)~i'; |
||
126 | preg_match_all($pattern, $result, $matches, PREG_SET_ORDER); |
||
127 | foreach ($matches as $match) { |
||
128 | $name = str_replace('""', '"', preg_replace('~^"|"$~', '', $match[1])); |
||
129 | if (isset($fields[$name])) { |
||
130 | $fields[$name]->collation = trim($match[3], "'"); |
||
131 | } |
||
132 | } |
||
133 | return $fields; |
||
134 | } |
||
135 | |||
136 | /** |
||
137 | * @param array $row |
||
138 | * @param array $results |
||
139 | * @param string $table |
||
140 | * @param ConnectionInterface $connection |
||
141 | * |
||
142 | * @return IndexEntity |
||
143 | */ |
||
144 | private function makeIndexEntity(array $row, array $results, string $table, ConnectionInterface $connection) |
||
145 | { |
||
146 | $index = new IndexEntity(); |
||
147 | |||
148 | $name = $row["name"]; |
||
149 | $index->type = $row["unique"] ? "UNIQUE" : "INDEX"; |
||
150 | $index->lengths = []; |
||
151 | $index->descs = []; |
||
152 | $columns = $this->driver->rows("PRAGMA index_info(" . |
||
153 | $this->driver->escapeId($name) . ")", $connection); |
||
154 | foreach ($columns as $column) { |
||
155 | $index->columns[] = $column["name"]; |
||
156 | $index->descs[] = null; |
||
157 | } |
||
158 | if (preg_match('~^CREATE( UNIQUE)? INDEX ' . preg_quote($this->driver->escapeId($name) . ' ON ' . |
||
159 | $this->driver->escapeId($table), '~') . ' \((.*)\)$~i', $results[$name], $regs)) { |
||
160 | preg_match_all('/("[^"]*+")+( DESC)?/', $regs[2], $matches); |
||
161 | foreach ($matches[2] as $key => $val) { |
||
162 | if ($val) { |
||
163 | $index->descs[$key] = '1'; |
||
164 | } |
||
165 | } |
||
166 | } |
||
167 | return $index; |
||
168 | } |
||
169 | |||
170 | /** |
||
171 | * @inheritDoc |
||
172 | */ |
||
173 | public function indexes(string $table, ConnectionInterface $connection = null) |
||
174 | { |
||
175 | if (!$connection) { |
||
176 | $connection = $this->connection; |
||
177 | } |
||
178 | $primaryIndex = $this->makePrimaryIndex($table, $connection); |
||
179 | if ($primaryIndex === null) { |
||
180 | return []; |
||
181 | } |
||
182 | |||
183 | $indexes = ['' => $primaryIndex]; |
||
184 | $query = "SELECT name, sql FROM sqlite_master WHERE type = 'index' AND tbl_name = " . $this->driver->quote($table); |
||
185 | $results = $this->driver->keyValues($query, $connection); |
||
186 | $rows = $this->driver->rows("PRAGMA index_list(" . $this->driver->table($table) . ")", $connection); |
||
187 | foreach ($rows as $row) { |
||
188 | $index = $this->makeIndexEntity($row, $results, $table, $connection); |
||
189 | $name = $row["name"]; |
||
190 | if ($index->type === 'UNIQUE' && $index->columns == $primaryIndex->columns && |
||
191 | $index->descs == $primaryIndex->descs && preg_match("~^sqlite_~", $name)) { |
||
192 | $indexes[$name] = $index; |
||
193 | } |
||
194 | } |
||
195 | |||
196 | return $indexes; |
||
197 | } |
||
198 | |||
199 | /** |
||
200 | * @inheritDoc |
||
201 | */ |
||
202 | public function foreignKeys(string $table) |
||
203 | { |
||
204 | $foreignKeys = []; |
||
205 | foreach ($this->driver->rows("PRAGMA foreign_key_list(" . $this->driver->table($table) . ")") as $row) { |
||
206 | $name = $row["id"]; |
||
207 | if (!isset($foreignKeys[$name])) { |
||
208 | $foreignKeys[$name] = new ForeignKeyEntity(); |
||
209 | } |
||
210 | //! idf_unescape in SQLite2 |
||
211 | $foreignKeys[$name]->source[] = $row["from"]; |
||
212 | $foreignKeys[$name]->target[] = $row["to"]; |
||
213 | } |
||
214 | return $foreignKeys; |
||
215 | } |
||
216 | |||
217 | /** |
||
218 | * @inheritDoc |
||
219 | */ |
||
220 | public function trigger(string $name, string $table = '') |
||
221 | { |
||
222 | if ($name == "") { |
||
223 | return new TriggerEntity('', '', "BEGIN\n\t;\nEND"); |
||
224 | } |
||
225 | $idf = '(?:[^`"\s]+|`[^`]*`|"[^"]*")+'; |
||
226 | $options = $this->triggerOptions(); |
||
227 | preg_match("~^CREATE\\s+TRIGGER\\s*$idf\\s*(" . implode("|", $options["Timing"]) . |
||
228 | ")\\s+([a-z]+)(?:\\s+OF\\s+($idf))?\\s+ON\\s*$idf\\s*(?:FOR\\s+EACH\\s+ROW\\s)?(.*)~is", |
||
229 | $this->connection->result("SELECT sql FROM sqlite_master WHERE type = 'trigger' AND name = " . |
||
230 | $this->driver->quote($name)), $match); |
||
231 | $of = $match[3]; |
||
232 | return new TriggerEntity(strtoupper($match[1]), strtoupper($match[2]), $match[4], |
||
233 | ($of[0] == '`' || $of[0] == '"' ? $this->driver->unescapeId($of) : $of), $name); |
||
234 | } |
||
235 | |||
236 | /** |
||
237 | * @inheritDoc |
||
238 | */ |
||
239 | public function triggers(string $table) |
||
250 | } |
||
251 | |||
252 | /** |
||
253 | * @inheritDoc |
||
254 | */ |
||
255 | public function triggerOptions() |
||
261 | ]; |
||
262 | } |
||
263 | } |
||
264 |