@@ -170,14 +170,14 @@ discard block |
||
| 170 | 170 | if (is_array($sql)) { |
| 171 | 171 | foreach ($sql as $key => $query) { |
| 172 | 172 | $this->sql[] = $query; |
| 173 | - if ( ! empty($params[$key])) { |
|
| 173 | + if (!empty($params[$key])) { |
|
| 174 | 174 | $queryTypes = $types[$key] ?? []; |
| 175 | 175 | $this->addQueryParams($params[$key], $queryTypes); |
| 176 | 176 | } |
| 177 | 177 | } |
| 178 | 178 | } else { |
| 179 | 179 | $this->sql[] = $sql; |
| 180 | - if ( ! empty($params)) { |
|
| 180 | + if (!empty($params)) { |
|
| 181 | 181 | $this->addQueryParams($params, $types); |
| 182 | 182 | } |
| 183 | 183 | } |
@@ -207,11 +207,11 @@ discard block |
||
| 207 | 207 | { |
| 208 | 208 | $queries = $this->execute($direction, true); |
| 209 | 209 | |
| 210 | - if ( ! empty($this->params)) { |
|
| 210 | + if (!empty($this->params)) { |
|
| 211 | 211 | throw MigrationException::migrationNotConvertibleToSql($this->class); |
| 212 | 212 | } |
| 213 | 213 | |
| 214 | - $this->outputWriter->write("\n-- Version " . $this->version . "\n"); |
|
| 214 | + $this->outputWriter->write("\n-- Version ".$this->version."\n"); |
|
| 215 | 215 | |
| 216 | 216 | $sqlQueries = [$this->version => $queries]; |
| 217 | 217 | |
@@ -264,12 +264,12 @@ discard block |
||
| 264 | 264 | $this->state = self::STATE_PRE; |
| 265 | 265 | $fromSchema = $this->schemaProvider->createFromSchema(); |
| 266 | 266 | |
| 267 | - $this->migration->{'pre' . ucfirst($direction)}($fromSchema); |
|
| 267 | + $this->migration->{'pre'.ucfirst($direction)}($fromSchema); |
|
| 268 | 268 | |
| 269 | 269 | if ($direction === self::DIRECTION_UP) { |
| 270 | - $this->outputWriter->write("\n" . sprintf(' <info>++</info> migrating <comment>%s</comment>', $this->version) . "\n"); |
|
| 270 | + $this->outputWriter->write("\n".sprintf(' <info>++</info> migrating <comment>%s</comment>', $this->version)."\n"); |
|
| 271 | 271 | } else { |
| 272 | - $this->outputWriter->write("\n" . sprintf(' <info>--</info> reverting <comment>%s</comment>', $this->version) . "\n"); |
|
| 272 | + $this->outputWriter->write("\n".sprintf(' <info>--</info> reverting <comment>%s</comment>', $this->version)."\n"); |
|
| 273 | 273 | } |
| 274 | 274 | |
| 275 | 275 | $this->state = self::STATE_EXEC; |
@@ -282,9 +282,9 @@ discard block |
||
| 282 | 282 | $this->executeRegisteredSql($dryRun, $timeAllQueries); |
| 283 | 283 | |
| 284 | 284 | $this->state = self::STATE_POST; |
| 285 | - $this->migration->{'post' . ucfirst($direction)}($toSchema); |
|
| 285 | + $this->migration->{'post'.ucfirst($direction)}($toSchema); |
|
| 286 | 286 | |
| 287 | - if ( ! $dryRun) { |
|
| 287 | + if (!$dryRun) { |
|
| 288 | 288 | if ($direction === self::DIRECTION_UP) { |
| 289 | 289 | $this->markMigrated(); |
| 290 | 290 | } else { |
@@ -392,13 +392,13 @@ discard block |
||
| 392 | 392 | |
| 393 | 393 | private function executeRegisteredSql($dryRun = false, $timeAllQueries = false) |
| 394 | 394 | { |
| 395 | - if ( ! $dryRun) { |
|
| 396 | - if ( ! empty($this->sql)) { |
|
| 395 | + if (!$dryRun) { |
|
| 396 | + if (!empty($this->sql)) { |
|
| 397 | 397 | foreach ($this->sql as $key => $query) { |
| 398 | 398 | $queryStart = microtime(true); |
| 399 | 399 | |
| 400 | - if ( ! isset($this->params[$key])) { |
|
| 401 | - $this->outputWriter->write(' <comment>-></comment> ' . $query); |
|
| 400 | + if (!isset($this->params[$key])) { |
|
| 401 | + $this->outputWriter->write(' <comment>-></comment> '.$query); |
|
| 402 | 402 | $this->connection->executeQuery($query); |
| 403 | 403 | } else { |
| 404 | 404 | $this->outputWriter->write(sprintf(' <comment>-></comment> %s (with parameters)', $query)); |