@@ -107,7 +107,7 @@ |
||
107 | 107 | return null; |
108 | 108 | } |
109 | 109 | |
110 | - return $this->entities[$class . '.' . $identity]; |
|
110 | + return $this->entities[$class.'.'.$identity]; |
|
111 | 111 | } |
112 | 112 | |
113 | 113 | /** |
@@ -95,7 +95,7 @@ discard block |
||
95 | 95 | * |
96 | 96 | * @param string|int $id Primary key value. |
97 | 97 | * |
98 | - * @return EntityInterface|Record|null |
|
98 | + * @return null|\Spiral\ORM\RecordInterface |
|
99 | 99 | */ |
100 | 100 | public function findByPK($id) |
101 | 101 | { |
@@ -108,7 +108,7 @@ discard block |
||
108 | 108 | * @param array $query Fields and conditions to query by. |
109 | 109 | * @param array $sortBy Always specify sort by to ensure that results are stable. |
110 | 110 | * |
111 | - * @return EntityInterface|Record|null |
|
111 | + * @return null|\Spiral\ORM\RecordInterface |
|
112 | 112 | */ |
113 | 113 | public function findOne(array $query = [], array $sortBy = []) |
114 | 114 | { |
@@ -259,7 +259,7 @@ discard block |
||
259 | 259 | * @param bool $changedEntities Reference, will be set to true if any of entities changed |
260 | 260 | * internally. |
261 | 261 | */ |
262 | - public function hasChanges(bool &$changedEntities = null): bool |
|
262 | + public function hasChanges(bool & $changedEntities = null): bool |
|
263 | 263 | { |
264 | 264 | foreach ($this->entities as $entity) { |
265 | 265 | if ($entity->hasChanges()) { |
@@ -326,7 +326,7 @@ discard block |
||
326 | 326 | |
327 | 327 | $atomics = array_merge( |
328 | 328 | $atomics, |
329 | - $entity->buildAtomics((!empty($container) ? $container . '.' : '') . $offset) |
|
329 | + $entity->buildAtomics((!empty($container) ? $container.'.' : '').$offset) |
|
330 | 330 | ); |
331 | 331 | } |
332 | 332 |
@@ -78,7 +78,7 @@ |
||
78 | 78 | */ |
79 | 79 | public function primaryKey(): string |
80 | 80 | { |
81 | - return $this->getAlias() . '.' . $this->schema[Record::SH_PRIMARY_KEY]; |
|
81 | + return $this->getAlias().'.'.$this->schema[Record::SH_PRIMARY_KEY]; |
|
82 | 82 | } |
83 | 83 | |
84 | 84 | /** |
@@ -99,8 +99,8 @@ discard block |
||
99 | 99 | * |
100 | 100 | * @see Record::INDEXES |
101 | 101 | */ |
102 | - const INDEX = 1000; //Default index type |
|
103 | - const UNIQUE = 2000; //Unique index definition |
|
102 | + const INDEX = 1000; //Default index type |
|
103 | + const UNIQUE = 2000; //Unique index definition |
|
104 | 104 | |
105 | 105 | /* |
106 | 106 | * ================================================ |
@@ -354,7 +354,7 @@ discard block |
||
354 | 354 | $this->dispatch('insert', new RecordEvent($this, $command)); |
355 | 355 | |
356 | 356 | //Executed when transaction successfully completed |
357 | - $command->onComplete(function (InsertCommand $command) { |
|
357 | + $command->onComplete(function(InsertCommand $command) { |
|
358 | 358 | $this->handleInsert($command); |
359 | 359 | }); |
360 | 360 | |
@@ -374,7 +374,7 @@ discard block |
||
374 | 374 | ); |
375 | 375 | |
376 | 376 | if (!empty($this->insertCommand)) { |
377 | - $this->insertCommand->onExecute(function (InsertCommand $insert) use ($command) { |
|
377 | + $this->insertCommand->onExecute(function(InsertCommand $insert) use ($command) { |
|
378 | 378 | //Sync primary key values |
379 | 379 | $command->setWhere([$this->primaryColumn() => $insert->getInsertID()]); |
380 | 380 | }); |
@@ -385,7 +385,7 @@ discard block |
||
385 | 385 | $this->dispatch('update', new RecordEvent($this)); |
386 | 386 | |
387 | 387 | //Executed when transaction successfully completed |
388 | - $command->onComplete(function (UpdateCommand $command) { |
|
388 | + $command->onComplete(function(UpdateCommand $command) { |
|
389 | 389 | $this->handleUpdate($command); |
390 | 390 | }); |
391 | 391 | |
@@ -403,7 +403,7 @@ discard block |
||
403 | 403 | ); |
404 | 404 | |
405 | 405 | if (!empty($this->insertCommand)) { |
406 | - $this->insertCommand->onExecute(function (InsertCommand $insert) use ($command) { |
|
406 | + $this->insertCommand->onExecute(function(InsertCommand $insert) use ($command) { |
|
407 | 407 | //Sync primary key values |
408 | 408 | $command->setWhere([$this->primaryColumn() => $insert->getInsertID()]); |
409 | 409 | }); |
@@ -414,7 +414,7 @@ discard block |
||
414 | 414 | $this->dispatch('delete', new RecordEvent($this)); |
415 | 415 | |
416 | 416 | //Executed when transaction successfully completed |
417 | - $command->onComplete(function (DeleteCommand $command) { |
|
417 | + $command->onComplete(function(DeleteCommand $command) { |
|
418 | 418 | $this->handleDelete($command); |
419 | 419 | }); |
420 | 420 |