o2system /
database
| Conditions | 47 |
| Paths | > 20000 |
| Total Lines | 202 |
| Code Lines | 118 |
| Lines | 0 |
| Ratio | 0 % |
| Changes | 3 | ||
| Bugs | 1 | Features | 0 |
Small methods make your code easier to understand, in particular if combined with a good name. Besides, if your method is small, finding a good name is usually much easier.
For example, if you find yourself adding comments to a method's body, this is usually a good sign to extract the commented part to a new method, and use the comment as a starting point when coming up with a good name for this new method.
Commonly applied refactorings include:
If many parameters/temporary variables are present:
| 1 | <?php |
||
| 129 | public function platformCreateTableStatement($table, array $columns = [], $force = false, array $attributes = []) |
||
| 130 | { |
||
| 131 | $primaryKeys = $foreignKeys = $uniqueKeys = $indexesKeys = []; |
||
|
Unused Code
introduced
by
|
|||
| 132 | |||
| 133 | // Open Statement |
||
| 134 | $statementLines[] = 'CREATE TABLE ' . ($force === true ? ' IF NOT EXISTS ' : '') . $this->conn->escapeIdentifiers($table) . ' ('; |
||
| 135 | |||
| 136 | // Columns Statement |
||
| 137 | $columnStatements = []; |
||
| 138 | foreach ($columns as $columnName => $columnAttributes) { |
||
| 139 | if (isset($columnAttributes[ 'type' ])) { |
||
| 140 | if (isset($columnAttributes[ 'foreign_key' ])) { |
||
| 141 | $foreignKeys[ $columnName ] = $columnAttributes[ 'foreign_key' ]; |
||
| 142 | } |
||
| 143 | |||
| 144 | $columnStatementLine = []; |
||
| 145 | $columnName = $this->conn->escapeIdentifiers($columnName); |
||
| 146 | $columnAttributes[ 'type' ] = strtoupper($columnAttributes[ 'type' ]); |
||
| 147 | |||
| 148 | if (isset($columnAttributes[ 'primary_key' ])) { |
||
| 149 | if ($columnAttributes[ 'primary_key' ] === true) { |
||
| 150 | $primaryKeys[] = $columnName; |
||
| 151 | } |
||
| 152 | } |
||
| 153 | |||
| 154 | if (isset($columnAttributes[ 'unique' ])) { |
||
| 155 | if ($columnAttributes[ 'unique' ] === true) { |
||
| 156 | $uniqueKeys[] = $columnName; |
||
| 157 | } |
||
| 158 | } |
||
| 159 | |||
| 160 | if ($columnAttributes[ 'type' ] === 'ENUM') { |
||
| 161 | if (empty($columnAttributes[ 'value' ])) { |
||
| 162 | continue; |
||
| 163 | } else { |
||
| 164 | if (is_string($columnAttributes[ 'value' ])) { |
||
| 165 | $columnAttributes[ 'value' ] = explode(',', $columnAttributes[ 'value' ]); |
||
| 166 | } |
||
| 167 | |||
| 168 | $columnAttributes[ 'value' ] = array_map(function ($value) { |
||
| 169 | return $this->conn->escape(str_replace('\'', '', trim($value))); |
||
| 170 | }, $columnAttributes[ 'value' ]); |
||
| 171 | |||
| 172 | $columnStatementLine[] = $columnName . |
||
| 173 | ' ' . $columnAttributes[ 'type' ] . '(' . |
||
| 174 | implode(',', $columnAttributes[ 'value' ]) |
||
| 175 | . ')'; |
||
| 176 | } |
||
| 177 | } elseif (isset($columnAttributes[ 'length' ])) { |
||
| 178 | $columnStatementLine[] = $columnName . ' ' . $columnAttributes[ 'type' ] . '(' . $columnAttributes[ 'length' ] . ')'; |
||
| 179 | } else { |
||
| 180 | $columnStatementLine[] = $columnName . ' ' . $columnAttributes[ 'type' ]; |
||
| 181 | } |
||
| 182 | |||
| 183 | if (isset($columnAttributes[ 'unsigned' ])) { |
||
| 184 | if ($columnAttributes[ 'unsigned' ] === true) { |
||
| 185 | if (in_array($columnAttributes[ 'type' ], $this->unsignedSupportColumnTypes)) { |
||
| 186 | $columnStatementLine[] = 'UNSIGNED'; |
||
| 187 | } |
||
| 188 | } |
||
| 189 | } |
||
| 190 | |||
| 191 | if (isset($columnAttributes[ 'collate' ])) { |
||
| 192 | $columnStatementLine[] = 'COLLATE ' . $columnAttributes[ 'collate' ]; |
||
| 193 | } elseif (in_array($columnAttributes[ 'type' ], |
||
| 194 | ['CHAR', 'VARCHAR', 'TEXT', 'LONGTEXT', 'TINYTEXT', 'ENUM'])) { |
||
| 195 | $columnStatementLine[] = 'COLLATE ' . $this->conn->getConfig('collate'); |
||
| 196 | } |
||
| 197 | |||
| 198 | if (isset($columnAttributes[ 'not_null' ])) { |
||
| 199 | if ($columnAttributes[ 'not_null' ] === true) { |
||
| 200 | $columnStatementLine[] = 'NOT NULL'; |
||
| 201 | } |
||
| 202 | } elseif (isset($columnAttributes[ 'null' ])) { |
||
| 203 | if ($columnAttributes[ 'null' ] === false) { |
||
| 204 | $columnStatementLine[] = 'NOT NULL'; |
||
| 205 | } |
||
| 206 | } |
||
| 207 | |||
| 208 | if (isset($columnAttributes[ 'timestamp' ])) { |
||
| 209 | if ($columnAttributes[ 'timestamp' ] === true) { |
||
| 210 | $columnStatementLine[] = 'ON UPDATE CURRENT_TIMESTAMP'; |
||
| 211 | } |
||
| 212 | } |
||
| 213 | |||
| 214 | if (isset($columnAttributes[ 'default' ])) { |
||
| 215 | $columnStatementLine[] = 'DEFAULT ' . $this->conn->escape($columnAttributes[ 'default' ]); |
||
| 216 | } |
||
| 217 | |||
| 218 | if (isset($columnAttributes[ 'auto_increment' ])) { |
||
| 219 | if ($columnAttributes[ 'auto_increment' ] === true) { |
||
| 220 | $columnStatementLine[] = 'AUTO_INCREMENT'; |
||
| 221 | } |
||
| 222 | } |
||
| 223 | |||
| 224 | if (isset($columnAttributes[ 'comment' ])) { |
||
| 225 | $columnStatementLine[] = 'COMMENT ' . $columnAttributes[ 'comment' ]; |
||
| 226 | } |
||
| 227 | |||
| 228 | $columnStatements[] = "\t" . implode(' ', $columnStatementLine); |
||
| 229 | } |
||
| 230 | } |
||
| 231 | |||
| 232 | // Keys Statement |
||
| 233 | $keyStatements = []; |
||
| 234 | $constraintStatements = []; |
||
| 235 | |||
| 236 | // Primary Key Statement |
||
| 237 | if (count($primaryKeys)) { |
||
| 238 | $keyStatements[] = 'PRIMARY KEY (' . implode(', ', |
||
| 239 | $primaryKeys) . ')' . (count($primaryKeys) >= 2 ? ' USING BTREE' : ''); |
||
| 240 | } |
||
| 241 | |||
| 242 | // Unique Key Statement |
||
| 243 | if (count($uniqueKeys)) { |
||
| 244 | if (count($uniqueKeys) == 1) { |
||
| 245 | $constraintStatements[] = 'UNIQUE (' . implode(',', $uniqueKeys) . ')'; |
||
| 246 | } else { |
||
| 247 | $uniqueName = 'idx_' . implode('_', $uniqueKeys); |
||
| 248 | $constraintStatements[] = 'CONSTRAINT ' . $uniqueName . ' UNIQUE (' . implode(',', $uniqueKeys) . ')'; |
||
| 249 | } |
||
| 250 | } |
||
| 251 | |||
| 252 | // Foreign Keys Statement |
||
| 253 | if (count($foreignKeys)) { |
||
| 254 | foreach ($foreignKeys as $foreignKeyColumnName => $foreignKeyAttributes) { |
||
| 255 | if (empty($foreignKeyAttributes[ 'name' ])) { |
||
| 256 | $foreignKeyAttributes[ 'name' ] = 'fk_' . $foreignKeyColumnName; |
||
| 257 | } |
||
| 258 | |||
| 259 | if (isset($foreignKeyAttributes[ 'references' ])) { |
||
| 260 | $keyStatements[] = 'KEY ' . |
||
| 261 | $this->conn->escapeIdentifiers($foreignKeyAttributes[ 'name' ]) . |
||
| 262 | ' (' . $this->conn->escapeIdentifiers($foreignKeyColumnName) . ')'; |
||
| 263 | |||
| 264 | $referenceParts = array_map('trim', explode('.', $foreignKeyAttributes[ 'references' ])); |
||
| 265 | list($referenceTable, $referenceColumn) = $referenceParts; |
||
| 266 | |||
| 267 | $referenceOnDelete = 'NO ACTION'; |
||
| 268 | $referenceOnUpdate = 'NO ACTION'; |
||
| 269 | |||
| 270 | $validReferenceActions = [ |
||
| 271 | 'NO ACTION', |
||
| 272 | 'CASCADE', |
||
| 273 | 'RESTRICT', |
||
| 274 | 'SET NULL', |
||
| 275 | ]; |
||
| 276 | |||
| 277 | if (isset($foreignKeyAttributes[ 'on_delete' ])) { |
||
| 278 | if (in_array($foreignKeyAttributes[ 'on_delete' ], $validReferenceActions)) { |
||
| 279 | $referenceOnDelete = $foreignKeyAttributes[ 'on_delete' ]; |
||
| 280 | } |
||
| 281 | } |
||
| 282 | |||
| 283 | if (isset($foreignKeyAttributes[ 'on_update' ])) { |
||
| 284 | if (in_array($foreignKeyAttributes[ 'on_update' ], $validReferenceActions)) { |
||
| 285 | $referenceOnUpdate = $foreignKeyAttributes[ 'on_update' ]; |
||
| 286 | } |
||
| 287 | } |
||
| 288 | |||
| 289 | $constraintStatements[] = 'CONSTRAINT ' . |
||
| 290 | $this->conn->escapeIdentifiers($foreignKeyAttributes[ 'name' ]) . |
||
| 291 | ' FOREIGN KEY (' . $this->conn->escapeIdentifiers($foreignKeyColumnName) . ') REFERENCES ' . |
||
| 292 | $this->conn->escapeIdentifiers($referenceTable) . ' (' . $this->conn->escapeIdentifiers($referenceColumn) . |
||
| 293 | ') ON DELETE ' . $referenceOnDelete . ' ON UPDATE ' . $referenceOnUpdate; |
||
| 294 | } |
||
| 295 | } |
||
| 296 | } |
||
| 297 | |||
| 298 | $statementLines[] = implode(',' . PHP_EOL, |
||
| 299 | array_merge($columnStatements, $keyStatements, $constraintStatements)); |
||
| 300 | |||
| 301 | if (empty($attributes)) { |
||
| 302 | $attributes[ 'engine' ] = 'InnoDB'; |
||
| 303 | } |
||
| 304 | |||
| 305 | if( ! array_key_exists('charset', $attributes) ) { |
||
| 306 | $attributes[ 'charset' ] = $this->conn->getConfig('charset'); |
||
| 307 | } |
||
| 308 | |||
| 309 | if( ! array_key_exists('collate', $attributes) ) { |
||
| 310 | $attributes[ 'collate' ] = $this->conn->getConfig('collate'); |
||
| 311 | } |
||
| 312 | |||
| 313 | $attributeStatements = []; |
||
| 314 | foreach ($attributes as $key => $value) { |
||
| 315 | if(is_string($key)) { |
||
| 316 | $key = strtoupper(dash($key)); |
||
| 317 | |||
| 318 | if ($key === 'CHARSET') { |
||
| 319 | $attributeStatements[] = 'DEFAULT CHARSET=' . $value; |
||
| 320 | } elseif(in_array($key, $this->quotedTableOptions)) { |
||
| 321 | $attributeStatements[] = $this->conn->escape($key) . '=' . $value; |
||
| 322 | } else { |
||
| 323 | $attributeStatements[] = $this->conn->escapeString($key) . '=' . $value; |
||
| 324 | } |
||
| 325 | } |
||
| 326 | } |
||
| 327 | |||
| 328 | $statementLines[] = ') ' . implode(' ', $attributeStatements); |
||
| 329 | |||
| 330 | return implode(PHP_EOL, $statementLines) . ';'; |
||
| 331 | } |
||
| 739 | } |
Loading history...