@@ -67,7 +67,7 @@ |
||
67 | 67 | return $this->name; |
68 | 68 | } |
69 | 69 | |
70 | - $name = ($this->isUnique() ? 'unique_' : 'index_') . join('_', $this->getColumns()); |
|
70 | + $name = ($this->isUnique() ? 'unique_' : 'index_').join('_', $this->getColumns()); |
|
71 | 71 | |
72 | 72 | return strlen($name) > 64 ? md5($name) : $name; |
73 | 73 | } |
@@ -279,7 +279,7 @@ discard block |
||
279 | 279 | if (!empty($filter = $this->mutatorsConfig->getMutators($column->abstractType()))) { |
280 | 280 | //Mutator associated with type directly |
281 | 281 | $resolved += $filter; |
282 | - } elseif (!empty($filter = $this->mutatorsConfig->getMutators('php:' . $column->phpType()))) { |
|
282 | + } elseif (!empty($filter = $this->mutatorsConfig->getMutators('php:'.$column->phpType()))) { |
|
283 | 283 | //Mutator associated with php type |
284 | 284 | $resolved += $filter; |
285 | 285 | } |
@@ -340,7 +340,7 @@ discard block |
||
340 | 340 | if ($key == RecordEntity::INDEX || $key == RecordEntity::UNIQUE) { |
341 | 341 | $unique = ($key === RecordEntity::UNIQUE); |
342 | 342 | |
343 | - if (!is_string($value) || empty($value)){ |
|
343 | + if (!is_string($value) || empty($value)) { |
|
344 | 344 | throw new DefinitionException( |
345 | 345 | "Record '{$this}' has index definition with invalid index name" |
346 | 346 | ); |
@@ -145,8 +145,8 @@ discard block |
||
145 | 145 | * |
146 | 146 | * @see Record::INDEXES |
147 | 147 | */ |
148 | - const INDEX = 1000; //Default index type |
|
149 | - const UNIQUE = 2000; //Unique index definition |
|
148 | + const INDEX = 1000; //Default index type |
|
149 | + const UNIQUE = 2000; //Unique index definition |
|
150 | 150 | |
151 | 151 | /* |
152 | 152 | * ================================================ |
@@ -351,12 +351,12 @@ discard block |
||
351 | 351 | $command = new InsertCommand($this->orm->table(static::class), $data); |
352 | 352 | |
353 | 353 | //Executed when transaction successfully completed |
354 | - $command->onComplete(function (InsertCommand $command) { |
|
354 | + $command->onComplete(function(InsertCommand $command) { |
|
355 | 355 | $this->lastInsert = null; |
356 | 356 | $this->handleInsert($command); |
357 | 357 | }); |
358 | 358 | |
359 | - $command->onRollBack(function () { |
|
359 | + $command->onRollBack(function() { |
|
360 | 360 | //Flushing existed insert command to prevent collisions |
361 | 361 | $this->lastInsert = null; |
362 | 362 | $this->state = ORMInterface::STATE_NEW; |
@@ -384,7 +384,7 @@ discard block |
||
384 | 384 | ); |
385 | 385 | |
386 | 386 | if (!empty($this->lastInsert)) { |
387 | - $this->lastInsert->onExecute(function (InsertCommand $insert) use ($command) { |
|
387 | + $this->lastInsert->onExecute(function(InsertCommand $insert) use ($command) { |
|
388 | 388 | //Sync primary key values |
389 | 389 | $command->setWhere([$this->primaryColumn() => $insert->getInsertID()]); |
390 | 390 | $command->setPrimaryKey($insert->getInsertID()); |
@@ -392,11 +392,11 @@ discard block |
||
392 | 392 | } |
393 | 393 | |
394 | 394 | //Executed when transaction successfully completed |
395 | - $command->onComplete(function (UpdateCommand $command) { |
|
395 | + $command->onComplete(function(UpdateCommand $command) { |
|
396 | 396 | $this->handleUpdate($command); |
397 | 397 | }); |
398 | 398 | |
399 | - $command->onRollBack(function () { |
|
399 | + $command->onRollBack(function() { |
|
400 | 400 | //Flushing existed insert command to prevent collisions |
401 | 401 | $this->state = ORMInterface::STATE_LOADED; |
402 | 402 | }); |
@@ -420,13 +420,13 @@ discard block |
||
420 | 420 | |
421 | 421 | if (!empty($this->lastInsert)) { |
422 | 422 | //Sync primary key values |
423 | - $this->lastInsert->onExecute(function (InsertCommand $insert) use ($command) { |
|
423 | + $this->lastInsert->onExecute(function(InsertCommand $insert) use ($command) { |
|
424 | 424 | $command->setWhere([$this->primaryColumn() => $insert->primaryKey()]); |
425 | 425 | }); |
426 | 426 | } |
427 | 427 | |
428 | 428 | //Executed when transaction successfully completed |
429 | - $command->onComplete(function (DeleteCommand $command) { |
|
429 | + $command->onComplete(function(DeleteCommand $command) { |
|
430 | 430 | $this->handleDelete($command); |
431 | 431 | }); |
432 | 432 |
@@ -295,7 +295,7 @@ discard block |
||
295 | 295 | } |
296 | 296 | |
297 | 297 | //Syncing pivot data values |
298 | - $command->onComplete(function (ContextualCommandInterface $command) use ($record) { |
|
298 | + $command->onComplete(function(ContextualCommandInterface $command) use ($record) { |
|
299 | 299 | //Now when we are done we can sync our values with current data |
300 | 300 | $this->pivotData->offsetSet( |
301 | 301 | $record, |
@@ -342,7 +342,7 @@ discard block |
||
342 | 342 | ContextualCommandInterface $outerCommand |
343 | 343 | ) { |
344 | 344 | //Parent record dependency |
345 | - $parentCommand->onExecute(function ($parentCommand) use ($pivotCommand, $parent) { |
|
345 | + $parentCommand->onExecute(function($parentCommand) use ($pivotCommand, $parent) { |
|
346 | 346 | $pivotCommand->addContext( |
347 | 347 | $this->key(Record::THOUGHT_INNER_KEY), |
348 | 348 | $this->lookupKey(Record::INNER_KEY, $parent, $parentCommand) |
@@ -350,7 +350,7 @@ discard block |
||
350 | 350 | }); |
351 | 351 | |
352 | 352 | //Outer record dependency |
353 | - $outerCommand->onExecute(function ($outerCommand) use ($pivotCommand, $outer) { |
|
353 | + $outerCommand->onExecute(function($outerCommand) use ($pivotCommand, $outer) { |
|
354 | 354 | $pivotCommand->addContext( |
355 | 355 | $this->key(Record::THOUGHT_OUTER_KEY), |
356 | 356 | $this->lookupKey(Record::OUTER_KEY, $outer, $outerCommand) |
@@ -426,7 +426,7 @@ discard block |
||
426 | 426 | $loader, |
427 | 427 | [ |
428 | 428 | 'alias' => $table->getName(), |
429 | - 'pivotAlias' => $table->getName() . '_pivot', |
|
429 | + 'pivotAlias' => $table->getName().'_pivot', |
|
430 | 430 | 'method' => RelationLoader::POSTLOAD |
431 | 431 | ] |
432 | 432 | ); |
@@ -436,7 +436,7 @@ discard block |
||
436 | 436 | $query = $loader->configureQuery($query, true, [$innerKey]); |
437 | 437 | |
438 | 438 | //Additional pivot conditions |
439 | - $pivotDecorator = new AliasDecorator($query, 'onWhere', $table->getName() . '_pivot'); |
|
439 | + $pivotDecorator = new AliasDecorator($query, 'onWhere', $table->getName().'_pivot'); |
|
440 | 440 | $pivotDecorator->where($this->schema[Record::WHERE_PIVOT]); |
441 | 441 | |
442 | 442 | $decorator = new AliasDecorator($query, 'where', 'root'); |
@@ -509,7 +509,7 @@ discard block |
||
509 | 509 | { |
510 | 510 | if ($diff = array_diff(array_keys($pivotData), $this->schema[Record::PIVOT_COLUMNS])) { |
511 | 511 | throw new RelationException( |
512 | - "Invalid pivot data, undefined columns found: " . join(', ', $diff) |
|
512 | + "Invalid pivot data, undefined columns found: ".join(', ', $diff) |
|
513 | 513 | ); |
514 | 514 | } |
515 | 515 | } |