@@ -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 | /** |
@@ -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 | |
@@ -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 | } |
@@ -237,7 +237,7 @@ discard block |
||
| 237 | 237 | return $helper->createAggregation($method); |
| 238 | 238 | } |
| 239 | 239 | |
| 240 | - throw new DocumentException("Undefined method call '{$method}' in '" . get_called_class() . "'"); |
|
| 240 | + throw new DocumentException("Undefined method call '{$method}' in '".get_called_class()."'"); |
|
| 241 | 241 | } |
| 242 | 242 | |
| 243 | 243 | /** |
@@ -303,7 +303,7 @@ discard block |
||
| 303 | 303 | if ($value instanceof CompositableInterface) { |
| 304 | 304 | $atomics = array_merge_recursive( |
| 305 | 305 | $atomics, |
| 306 | - $value->buildAtomics((!empty($container) ? $container . '.' : '') . $field) |
|
| 306 | + $value->buildAtomics((!empty($container) ? $container.'.' : '').$field) |
|
| 307 | 307 | ); |
| 308 | 308 | |
| 309 | 309 | continue; |
@@ -318,7 +318,7 @@ discard block |
||
| 318 | 318 | |
| 319 | 319 | if (array_key_exists($field, $this->changes)) { |
| 320 | 320 | //Generating set operation for changed field |
| 321 | - $atomics['$set'][(!empty($container) ? $container . '.' : '') . $field] = $value; |
|
| 321 | + $atomics['$set'][(!empty($container) ? $container.'.' : '').$field] = $value; |
|
| 322 | 322 | } |
| 323 | 323 | } |
| 324 | 324 | |
@@ -365,7 +365,7 @@ discard block |
||
| 365 | 365 | { |
| 366 | 366 | $public = parent::publicValue(); |
| 367 | 367 | |
| 368 | - array_walk_recursive($public, function (&$value) { |
|
| 368 | + array_walk_recursive($public, function(&$value) { |
|
| 369 | 369 | if ($value instanceof ObjectID) { |
| 370 | 370 | $value = (string)$value; |
| 371 | 371 | } |
@@ -359,7 +359,7 @@ |
||
| 359 | 359 | */ |
| 360 | 360 | protected function normalizeDates(array $query): array |
| 361 | 361 | { |
| 362 | - array_walk_recursive($query, function (&$value) { |
|
| 362 | + array_walk_recursive($query, function(&$value) { |
|
| 363 | 363 | if ($value instanceof \DateTime) { |
| 364 | 364 | //MongoDate is always UTC, which is good :) |
| 365 | 365 | $value = new UTCDateTime($value); |