@@ -81,7 +81,7 @@ |
||
| 81 | 81 | */ |
| 82 | 82 | public function fullName(): string |
| 83 | 83 | { |
| 84 | - return $this->database->getPrefix() . $this->name; |
|
| 84 | + return $this->database->getPrefix().$this->name; |
|
| 85 | 85 | } |
| 86 | 86 | |
| 87 | 87 | /** |
@@ -330,7 +330,7 @@ discard block |
||
| 330 | 330 | if (!empty($table->getPrimaryKeys())) { |
| 331 | 331 | $primaryKeys = array_map([$this, 'identify'], $table->getPrimaryKeys()); |
| 332 | 332 | |
| 333 | - $innerStatement[] = 'PRIMARY KEY (' . join(', ', $primaryKeys) . ')'; |
|
| 333 | + $innerStatement[] = 'PRIMARY KEY ('.join(', ', $primaryKeys).')'; |
|
| 334 | 334 | } |
| 335 | 335 | |
| 336 | 336 | //Constraints and foreign keys |
@@ -338,7 +338,7 @@ discard block |
||
| 338 | 338 | $innerStatement[] = $reference->sqlStatement($this->driver); |
| 339 | 339 | } |
| 340 | 340 | |
| 341 | - $statement[] = " " . join(",\n ", $innerStatement); |
|
| 341 | + $statement[] = " ".join(",\n ", $innerStatement); |
|
| 342 | 342 | $statement[] = ')'; |
| 343 | 343 | |
| 344 | 344 | return join("\n", $statement); |
@@ -328,7 +328,7 @@ discard block |
||
| 328 | 328 | $this->logger()->info("Transaction: new savepoint 'SVP{$name}'"); |
| 329 | 329 | } |
| 330 | 330 | |
| 331 | - $this->statement('SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 331 | + $this->statement('SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 332 | 332 | } |
| 333 | 333 | |
| 334 | 334 | /** |
@@ -345,7 +345,7 @@ discard block |
||
| 345 | 345 | $this->logger()->info("Transaction: release savepoint 'SVP{$name}'"); |
| 346 | 346 | } |
| 347 | 347 | |
| 348 | - $this->statement('RELEASE SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 348 | + $this->statement('RELEASE SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 349 | 349 | } |
| 350 | 350 | |
| 351 | 351 | /** |
@@ -362,6 +362,6 @@ discard block |
||
| 362 | 362 | $this->logger()->info("Transaction: rollback savepoint 'SVP{$name}'"); |
| 363 | 363 | } |
| 364 | 364 | |
| 365 | - $this->statement('ROLLBACK TO SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 365 | + $this->statement('ROLLBACK TO SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 366 | 366 | } |
| 367 | 367 | } |
@@ -90,7 +90,7 @@ |
||
| 90 | 90 | { |
| 91 | 91 | if (defined('static::GUARD_NAMESPACE')) { |
| 92 | 92 | //Yay! Isolation |
| 93 | - $permission = constant(get_called_class() . '::' . 'GUARD_NAMESPACE') . '.' . $permission; |
|
| 93 | + $permission = constant(get_called_class().'::'.'GUARD_NAMESPACE').'.'.$permission; |
|
| 94 | 94 | } |
| 95 | 95 | |
| 96 | 96 | return $permission; |
@@ -136,7 +136,7 @@ discard block |
||
| 136 | 136 | $migration = $migration->withCapsule($capsule); |
| 137 | 137 | |
| 138 | 138 | //Executing migration inside global transaction |
| 139 | - $this->execute(function () use ($migration) { |
|
| 139 | + $this->execute(function() use ($migration) { |
|
| 140 | 140 | $migration->up(); |
| 141 | 141 | }); |
| 142 | 142 | |
@@ -182,7 +182,7 @@ discard block |
||
| 182 | 182 | $migration = $migration->withCapsule($capsule); |
| 183 | 183 | |
| 184 | 184 | //Executing migration inside global transaction |
| 185 | - $this->execute(function () use ($migration) { |
|
| 185 | + $this->execute(function() use ($migration) { |
|
| 186 | 186 | $migration->down(); |
| 187 | 187 | }); |
| 188 | 188 | |
@@ -123,8 +123,8 @@ discard block |
||
| 123 | 123 | * |
| 124 | 124 | * @see Record::INDEXES |
| 125 | 125 | */ |
| 126 | - const INDEX = 1000; //Default index type |
|
| 127 | - const UNIQUE = 2000; //Unique index definition |
|
| 126 | + const INDEX = 1000; //Default index type |
|
| 127 | + const UNIQUE = 2000; //Unique index definition |
|
| 128 | 128 | |
| 129 | 129 | /* |
| 130 | 130 | * ================================================ |
@@ -330,12 +330,12 @@ discard block |
||
| 330 | 330 | $command = new InsertCommand($this->orm->table(static::class), $data); |
| 331 | 331 | |
| 332 | 332 | //Executed when transaction successfully completed |
| 333 | - $command->onComplete(function (InsertCommand $command) { |
|
| 333 | + $command->onComplete(function(InsertCommand $command) { |
|
| 334 | 334 | $this->lastInsert = null; |
| 335 | 335 | $this->handleInsert($command); |
| 336 | 336 | }); |
| 337 | 337 | |
| 338 | - $command->onRollBack(function () { |
|
| 338 | + $command->onRollBack(function() { |
|
| 339 | 339 | //Flushing existed insert command to prevent collisions |
| 340 | 340 | $this->lastInsert = null; |
| 341 | 341 | $this->state = ORMInterface::STATE_NEW; |
@@ -363,7 +363,7 @@ discard block |
||
| 363 | 363 | ); |
| 364 | 364 | |
| 365 | 365 | if (!empty($this->lastInsert)) { |
| 366 | - $this->lastInsert->onExecute(function (InsertCommand $insert) use ($command) { |
|
| 366 | + $this->lastInsert->onExecute(function(InsertCommand $insert) use ($command) { |
|
| 367 | 367 | //Sync primary key values |
| 368 | 368 | $command->setWhere([$this->primaryColumn() => $insert->getInsertID()]); |
| 369 | 369 | $command->setPrimaryKey($insert->getInsertID()); |
@@ -371,11 +371,11 @@ discard block |
||
| 371 | 371 | } |
| 372 | 372 | |
| 373 | 373 | //Executed when transaction successfully completed |
| 374 | - $command->onComplete(function (UpdateCommand $command) { |
|
| 374 | + $command->onComplete(function(UpdateCommand $command) { |
|
| 375 | 375 | $this->handleUpdate($command); |
| 376 | 376 | }); |
| 377 | 377 | |
| 378 | - $command->onRollBack(function () { |
|
| 378 | + $command->onRollBack(function() { |
|
| 379 | 379 | //Flushing existed insert command to prevent collisions |
| 380 | 380 | $this->state = ORMInterface::STATE_LOADED; |
| 381 | 381 | }); |
@@ -399,13 +399,13 @@ discard block |
||
| 399 | 399 | |
| 400 | 400 | if (!empty($this->lastInsert)) { |
| 401 | 401 | //Sync primary key values |
| 402 | - $this->lastInsert->onExecute(function (InsertCommand $insert) use ($command) { |
|
| 402 | + $this->lastInsert->onExecute(function(InsertCommand $insert) use ($command) { |
|
| 403 | 403 | $command->setWhere([$this->primaryColumn() => $insert->primaryKey()]); |
| 404 | 404 | }); |
| 405 | 405 | } |
| 406 | 406 | |
| 407 | 407 | //Executed when transaction successfully completed |
| 408 | - $command->onComplete(function (DeleteCommand $command) { |
|
| 408 | + $command->onComplete(function(DeleteCommand $command) { |
|
| 409 | 409 | $this->handleDelete($command); |
| 410 | 410 | }); |
| 411 | 411 | |
@@ -234,7 +234,7 @@ discard block |
||
| 234 | 234 | return null; |
| 235 | 235 | } |
| 236 | 236 | |
| 237 | - return $this->getAlias() . '.' . $this->schema[$key]; |
|
| 237 | + return $this->getAlias().'.'.$this->schema[$key]; |
|
| 238 | 238 | } |
| 239 | 239 | |
| 240 | 240 | /** |
@@ -246,7 +246,7 @@ discard block |
||
| 246 | 246 | */ |
| 247 | 247 | protected function parentKey($key): string |
| 248 | 248 | { |
| 249 | - return $this->parent->getAlias() . '.' . $this->schema[$key]; |
|
| 249 | + return $this->parent->getAlias().'.'.$this->schema[$key]; |
|
| 250 | 250 | } |
| 251 | 251 | |
| 252 | 252 | /** |
@@ -260,10 +260,10 @@ discard block |
||
| 260 | 260 | if (empty($this->options['alias'])) { |
| 261 | 261 | if ($this->isLoaded() && $this->isJoined()) { |
| 262 | 262 | //Let's create unique alias, we are able to do that for relations just loaded |
| 263 | - $this->options['alias'] = 'd' . decoct(++self::$countLevels); |
|
| 263 | + $this->options['alias'] = 'd'.decoct(++self::$countLevels); |
|
| 264 | 264 | } else { |
| 265 | 265 | //Let's use parent alias to continue chain |
| 266 | - $this->options['alias'] = $parent->getAlias() . '_' . $this->relation; |
|
| 266 | + $this->options['alias'] = $parent->getAlias().'_'.$this->relation; |
|
| 267 | 267 | |
| 268 | 268 | } |
| 269 | 269 | } |
@@ -230,7 +230,7 @@ |
||
| 230 | 230 | public function __toString() |
| 231 | 231 | { |
| 232 | 232 | //Do we need to worry about collision rate in this context? |
| 233 | - return static::class . '#' . hash('crc32', spl_object_hash($this)); |
|
| 233 | + return static::class.'#'.hash('crc32', spl_object_hash($this)); |
|
| 234 | 234 | } |
| 235 | 235 | |
| 236 | 236 | /** |
@@ -91,7 +91,7 @@ |
||
| 91 | 91 | $query = $aggregation[2]; |
| 92 | 92 | |
| 93 | 93 | //Mounting selection values |
| 94 | - array_walk_recursive($query, function (&$value) { |
|
| 94 | + array_walk_recursive($query, function(&$value) { |
|
| 95 | 95 | if (strpos($value, 'self::') === 0) { |
| 96 | 96 | $value = $this->findValue(substr($value, 6)); |
| 97 | 97 | } |