@@ -25,7 +25,7 @@ |
||
25 | 25 | /** |
26 | 26 | * Set of allowed enum values. |
27 | 27 | */ |
28 | - const VALUES = []; |
|
28 | + const VALUES = []; |
|
29 | 29 | |
30 | 30 | /** |
31 | 31 | * Default value. |
@@ -61,7 +61,7 @@ |
||
61 | 61 | |
62 | 62 | $schemas[] = $this->container->get(FactoryInterface::class)->make( |
63 | 63 | RecordSchema::class, |
64 | - ['reflection' => new ReflectionEntity($class['name']),] |
|
64 | + ['reflection' => new ReflectionEntity($class['name']), ] |
|
65 | 65 | ); |
66 | 66 | } |
67 | 67 |
@@ -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 |
@@ -80,7 +80,7 @@ |
||
80 | 80 | |
81 | 81 | if (!$this->isSynced($this->parent, $this->instance)) { |
82 | 82 | //Syncing FKs before primary command been executed |
83 | - $innerCommand->onExecute(function ($innerCommand) use ($parentCommand) { |
|
83 | + $innerCommand->onExecute(function($innerCommand) use ($parentCommand) { |
|
84 | 84 | $parentCommand->addContext( |
85 | 85 | $this->key(Record::INNER_KEY), |
86 | 86 | $this->lookupKey(Record::OUTER_KEY, $this->parent, $innerCommand) |
@@ -63,10 +63,10 @@ discard block |
||
63 | 63 | } |
64 | 64 | |
65 | 65 | if (empty($entity->primaryKey())) { |
66 | - throw new MapException("Unable to store non identified entity " . get_class($entity)); |
|
66 | + throw new MapException("Unable to store non identified entity ".get_class($entity)); |
|
67 | 67 | } |
68 | 68 | |
69 | - $cacheID = get_class($entity) . ':' . $entity->primaryKey(); |
|
69 | + $cacheID = get_class($entity).':'.$entity->primaryKey(); |
|
70 | 70 | |
71 | 71 | return $this->entities[$cacheID] = $entity; |
72 | 72 | } |
@@ -78,7 +78,7 @@ discard block |
||
78 | 78 | */ |
79 | 79 | public function forget(RecordInterface $entity) |
80 | 80 | { |
81 | - $cacheID = get_class($entity) . ':' . $entity->primaryKey(); |
|
81 | + $cacheID = get_class($entity).':'.$entity->primaryKey(); |
|
82 | 82 | unset($this->entities[$cacheID]); |
83 | 83 | } |
84 | 84 |
@@ -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 | /** |
@@ -307,6 +307,6 @@ |
||
307 | 307 | $names = [$source->getRole(), $target->getRole()]; |
308 | 308 | asort($names); |
309 | 309 | |
310 | - return implode('_', $names) . static::PIVOT_POSTFIX; |
|
310 | + return implode('_', $names).static::PIVOT_POSTFIX; |
|
311 | 311 | } |
312 | 312 | } |
313 | 313 | \ No newline at end of file |
@@ -55,7 +55,7 @@ |
||
55 | 55 | */ |
56 | 56 | public function getName(): string |
57 | 57 | { |
58 | - $name = ($this->isUnique() ? 'unique_' : 'index_') . join('_', $this->getColumns()); |
|
58 | + $name = ($this->isUnique() ? 'unique_' : 'index_').join('_', $this->getColumns()); |
|
59 | 59 | |
60 | 60 | return strlen($name) > 64 ? md5($name) : $name; |
61 | 61 | } |
@@ -239,8 +239,8 @@ discard block |
||
239 | 239 | bool $unique = false, |
240 | 240 | bool $resetState = false |
241 | 241 | ): AbstractTable { |
242 | - if (isset($this->tables[$database . '.' . $table])) { |
|
243 | - $schema = $this->tables[$database . '.' . $table]; |
|
242 | + if (isset($this->tables[$database.'.'.$table])) { |
|
243 | + $schema = $this->tables[$database.'.'.$table]; |
|
244 | 244 | |
245 | 245 | if ($unique) { |
246 | 246 | throw new DoubleReferenceException( |
@@ -250,7 +250,7 @@ discard block |
||
250 | 250 | } else { |
251 | 251 | //Requesting thought DatabaseManager |
252 | 252 | $schema = $this->manager->database($database)->table($table)->getSchema(); |
253 | - $this->tables[$database . '.' . $table] = $schema; |
|
253 | + $this->tables[$database.'.'.$table] = $schema; |
|
254 | 254 | } |
255 | 255 | |
256 | 256 | $schema = clone $schema; |
@@ -473,10 +473,10 @@ discard block |
||
473 | 473 | //We have to make sure that local table name is used |
474 | 474 | $table = substr($schema->getName(), strlen($schema->getPrefix())); |
475 | 475 | |
476 | - if (empty($this->tables[$database . '.' . $table])) { |
|
476 | + if (empty($this->tables[$database.'.'.$table])) { |
|
477 | 477 | throw new SchemaException("AbstractTable must be requested before pushing back"); |
478 | 478 | } |
479 | 479 | |
480 | - $this->tables[$database . '.' . $table] = $schema; |
|
480 | + $this->tables[$database.'.'.$table] = $schema; |
|
481 | 481 | } |
482 | 482 | } |
483 | 483 | \ No newline at end of file |