@@ -21,10 +21,10 @@ |
||
| 21 | 21 | |
| 22 | 22 | $update = new \Sirius\Sql\Update($this->mapper->getWriteConnection()); |
| 23 | 23 | $update->table($this->mapper->getTable()) |
| 24 | - ->columns([ |
|
| 25 | - $this->getOption('deleted_at_column') => $this->now |
|
| 26 | - ]) |
|
| 27 | - ->where('id', $entityId); |
|
| 24 | + ->columns([ |
|
| 25 | + $this->getOption('deleted_at_column') => $this->now |
|
| 26 | + ]) |
|
| 27 | + ->where('id', $entityId); |
|
| 28 | 28 | $update->perform(); |
| 29 | 29 | } |
| 30 | 30 | |
@@ -13,7 +13,7 @@ |
||
| 13 | 13 | protected function execute() |
| 14 | 14 | { |
| 15 | 15 | $entityId = $this->entity->getPk(); |
| 16 | - if (! $entityId) { |
|
| 16 | + if (!$entityId) { |
|
| 17 | 17 | return; |
| 18 | 18 | } |
| 19 | 19 | |
@@ -83,7 +83,7 @@ |
||
| 83 | 83 | |
| 84 | 84 | $insert = new \Sirius\Sql\Insert($conn); |
| 85 | 85 | $insert->into($throughTable) |
| 86 | - ->columns($insertColumns) |
|
| 87 | - ->perform(); |
|
| 86 | + ->columns($insertColumns) |
|
| 87 | + ->perform(); |
|
| 88 | 88 | } |
| 89 | 89 | } |
@@ -51,10 +51,10 @@ |
||
| 51 | 51 | $conn = $this->relation->getNativeMapper()->getWriteConnection(); |
| 52 | 52 | $throughTable = (string)$this->relation->getOption(RelationOption::THROUGH_TABLE); |
| 53 | 53 | |
| 54 | - $throughNativeColumns = (array) $this->relation->getOption(RelationOption::THROUGH_NATIVE_COLUMN); |
|
| 55 | - $throughForeignColumns = (array) $this->relation->getOption(RelationOption::THROUGH_FOREIGN_COLUMN); |
|
| 56 | - $nativeKey = (array) $this->nativeEntity->getPk(); |
|
| 57 | - $foreignKey = (array) $this->foreignEntity->getPk(); |
|
| 54 | + $throughNativeColumns = (array)$this->relation->getOption(RelationOption::THROUGH_NATIVE_COLUMN); |
|
| 55 | + $throughForeignColumns = (array)$this->relation->getOption(RelationOption::THROUGH_FOREIGN_COLUMN); |
|
| 56 | + $nativeKey = (array)$this->nativeEntity->getPk(); |
|
| 57 | + $foreignKey = (array)$this->foreignEntity->getPk(); |
|
| 58 | 58 | |
| 59 | 59 | $delete = new \Sirius\Sql\Delete($conn); |
| 60 | 60 | $delete->from($throughTable); |
@@ -10,7 +10,7 @@ |
||
| 10 | 10 | public static function new(...$args) |
| 11 | 11 | { |
| 12 | 12 | if ($args[0] instanceof Connection) { |
| 13 | - return new ConnectionLocator(function () use ($args) { |
|
| 13 | + return new ConnectionLocator(function() use ($args) { |
|
| 14 | 14 | return $args[0]; |
| 15 | 15 | }); |
| 16 | 16 | } |
@@ -26,7 +26,7 @@ |
||
| 26 | 26 | if (strpos($key, $separator)) { |
| 27 | 27 | $parents = static::getParents($key, $separator); |
| 28 | 28 | foreach ($parents as $parent) { |
| 29 | - if (! isset($arr[$parent])) { |
|
| 29 | + if (!isset($arr[$parent])) { |
|
| 30 | 30 | $arr[$parent] = null; |
| 31 | 31 | } |
| 32 | 32 | } |
@@ -15,7 +15,7 @@ discard block |
||
| 15 | 15 | |
| 16 | 16 | public static function underscore($str) |
| 17 | 17 | { |
| 18 | - if (! isset(static::$cache['underscore'][$str])) { |
|
| 18 | + if (!isset(static::$cache['underscore'][$str])) { |
|
| 19 | 19 | $str = strtolower($str); |
| 20 | 20 | $str = preg_replace("/[^a-z0-9]+/", ' ', $str); |
| 21 | 21 | |
@@ -28,7 +28,7 @@ discard block |
||
| 28 | 28 | public static function methodName($str, $verb) |
| 29 | 29 | { |
| 30 | 30 | $key = $verb . $str; |
| 31 | - if (! isset(static::$cache['methodName'][$key])) { |
|
| 31 | + if (!isset(static::$cache['methodName'][$key])) { |
|
| 32 | 32 | static::$cache['methodName'][$key] = strtolower($verb) . static::className($str); |
| 33 | 33 | } |
| 34 | 34 | |
@@ -37,7 +37,7 @@ discard block |
||
| 37 | 37 | |
| 38 | 38 | public static function variableName($str) |
| 39 | 39 | { |
| 40 | - if (! isset(static::$cache['variableName'][$str])) { |
|
| 40 | + if (!isset(static::$cache['variableName'][$str])) { |
|
| 41 | 41 | $class = static::className($str); |
| 42 | 42 | |
| 43 | 43 | static::$cache['variableName'][$str] = strtolower(substr($class, 0, 1)) . substr($class, 1); |
@@ -48,7 +48,7 @@ discard block |
||
| 48 | 48 | |
| 49 | 49 | public static function className($str) |
| 50 | 50 | { |
| 51 | - if (! isset(static::$cache['className'][$str])) { |
|
| 51 | + if (!isset(static::$cache['className'][$str])) { |
|
| 52 | 52 | $str = strtolower($str); |
| 53 | 53 | $str = preg_replace("/[^a-z0-9]+/", ' ', $str); |
| 54 | 54 | $str = ucwords($str); |
@@ -77,7 +77,7 @@ |
||
| 77 | 77 | /** @var ArrayCollection $changeCollection */ |
| 78 | 78 | $changeCollection = $this->changes[$t]; |
| 79 | 79 | if ($t == $type) { |
| 80 | - if (! $changeCollection->contains($element)) { |
|
| 80 | + if (!$changeCollection->contains($element)) { |
|
| 81 | 81 | $changeCollection->add($element); |
| 82 | 82 | } |
| 83 | 83 | } else { |
@@ -45,7 +45,7 @@ discard block |
||
| 45 | 45 | |
| 46 | 46 | public function setRelation($name, Relation $relation, $callback, $overwrite = false) |
| 47 | 47 | { |
| 48 | - if ($overwrite || ! isset($this->relations[$name])) { |
|
| 48 | + if ($overwrite || !isset($this->relations[$name])) { |
|
| 49 | 49 | $this->relations[$name] = $relation; |
| 50 | 50 | $this->relationCallbacks[$name] = $callback; |
| 51 | 51 | } |
@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | |
| 64 | 64 | public function getRelationResults($name) |
| 65 | 65 | { |
| 66 | - if (! isset($this->relations[$name])) { |
|
| 66 | + if (!isset($this->relations[$name])) { |
|
| 67 | 67 | return null; |
| 68 | 68 | } |
| 69 | 69 | |
@@ -42,7 +42,7 @@ |
||
| 42 | 42 | } |
| 43 | 43 | } |
| 44 | 44 | if ($action instanceof Update && $this->updateColumn) { |
| 45 | - if (! empty($action->getEntity()->getChanges())) { |
|
| 45 | + if (!empty($action->getEntity()->getChanges())) { |
|
| 46 | 46 | $action->addColumns([$this->updateColumn => time()]); |
| 47 | 47 | } |
| 48 | 48 | } |
@@ -136,7 +136,7 @@ discard block |
||
| 136 | 136 | $mapper->entityClass = $mapperConfig->entityClass; |
| 137 | 137 | } |
| 138 | 138 | |
| 139 | - if ($mapperConfig->behaviours && ! empty($mapperConfig->behaviours)) { |
|
| 139 | + if ($mapperConfig->behaviours && !empty($mapperConfig->behaviours)) { |
|
| 140 | 140 | $mapper->use(...$mapperConfig->behaviours); |
| 141 | 141 | } |
| 142 | 142 | |
@@ -146,10 +146,10 @@ discard block |
||
| 146 | 146 | public function __construct(Orm $orm, FactoryInterface $entityFactory = null, QueryBuilder $queryBuilder = null) |
| 147 | 147 | { |
| 148 | 148 | $this->orm = $orm; |
| 149 | - if (! $entityFactory) { |
|
| 149 | + if (!$entityFactory) { |
|
| 150 | 150 | $entityFactory = new GenericEntityFactory($orm, $this); |
| 151 | 151 | } |
| 152 | - if (! $queryBuilder) { |
|
| 152 | + if (!$queryBuilder) { |
|
| 153 | 153 | $this->queryBuilder = QueryBuilder::getInstance(); |
| 154 | 154 | } |
| 155 | 155 | $this->entityFactory = $entityFactory; |
@@ -220,12 +220,12 @@ discard block |
||
| 220 | 220 | $mapper = $this; |
| 221 | 221 | |
| 222 | 222 | $singular = Inflector::singularize($this->getTableAlias(true)); |
| 223 | - $castingManager->register($singular, function ($value) use ($mapper, $castingManager) { |
|
| 223 | + $castingManager->register($singular, function($value) use ($mapper, $castingManager) { |
|
| 224 | 224 | return $value !== null ? $mapper->newEntity($value, $castingManager) : null; |
| 225 | 225 | }); |
| 226 | 226 | |
| 227 | 227 | $plural = $this->getTableAlias(true); |
| 228 | - $castingManager->register($plural, function ($values) use ($mapper, $castingManager) { |
|
| 228 | + $castingManager->register($plural, function($values) use ($mapper, $castingManager) { |
|
| 229 | 229 | $collection = new Collection(); |
| 230 | 230 | foreach ($values as $value) { |
| 231 | 231 | $collection->add($mapper->newEntity($value, $castingManager)); |
@@ -256,7 +256,7 @@ discard block |
||
| 256 | 256 | */ |
| 257 | 257 | public function getTableAlias($returnTableIfNull = false) |
| 258 | 258 | { |
| 259 | - return (! $this->tableAlias && $returnTableIfNull) ? $this->table : $this->tableAlias; |
|
| 259 | + return (!$this->tableAlias && $returnTableIfNull) ? $this->table : $this->tableAlias; |
|
| 260 | 260 | } |
| 261 | 261 | |
| 262 | 262 | public function getTableReference() |
@@ -321,8 +321,8 @@ discard block |
||
| 321 | 321 | return null; |
| 322 | 322 | } |
| 323 | 323 | |
| 324 | - $receivedTracker = ! ! $tracker; |
|
| 325 | - if (! $tracker) { |
|
| 324 | + $receivedTracker = !!$tracker; |
|
| 325 | + if (!$tracker) { |
|
| 326 | 326 | $receivedTracker = false; |
| 327 | 327 | $tracker = new Tracker($this, [$data]); |
| 328 | 328 | } |
@@ -331,7 +331,7 @@ discard block |
||
| 331 | 331 | $this->injectRelations($entity, $tracker, $load); |
| 332 | 332 | $entity->setPersistanceState(StateEnum::SYNCHRONIZED); |
| 333 | 333 | |
| 334 | - if (! $receivedTracker) { |
|
| 334 | + if (!$receivedTracker) { |
|
| 335 | 335 | $tracker->replaceRows([$entity]); |
| 336 | 336 | if ($tracker->isDisposable()) { |
| 337 | 337 | unset($tracker); |
@@ -386,7 +386,7 @@ discard block |
||
| 386 | 386 | $queryCallback = $eagerLoad[$name] ?? null; |
| 387 | 387 | $nextLoad = Arr::getChildren($eagerLoad, $name); |
| 388 | 388 | |
| 389 | - if (! $tracker->hasRelation($name)) { |
|
| 389 | + if (!$tracker->hasRelation($name)) { |
|
| 390 | 390 | $tracker->setRelation($name, $relation, $queryCallback); |
| 391 | 391 | } |
| 392 | 392 | |
@@ -423,7 +423,7 @@ discard block |
||
| 423 | 423 | |
| 424 | 424 | public function getRelation($name): Relation |
| 425 | 425 | { |
| 426 | - if (! $this->hasRelation($name)) { |
|
| 426 | + if (!$this->hasRelation($name)) { |
|
| 427 | 427 | throw new \InvalidArgumentException("Relation named {$name} is not registered for this mapper"); |
| 428 | 428 | } |
| 429 | 429 | |
@@ -431,7 +431,7 @@ discard block |
||
| 431 | 431 | $this->relations[$name] = $this->orm->createRelation($this, $name, $this->relations[$name]); |
| 432 | 432 | } |
| 433 | 433 | $relation = $this->relations[$name]; |
| 434 | - if (! $relation instanceof Relation) { |
|
| 434 | + if (!$relation instanceof Relation) { |
|
| 435 | 435 | throw new \InvalidArgumentException("Relation named {$name} is not a proper Relation instance"); |
| 436 | 436 | } |
| 437 | 437 | |
@@ -474,7 +474,7 @@ discard block |
||
| 474 | 474 | |
| 475 | 475 | public function newSaveAction(EntityInterface $entity, $options): BaseAction |
| 476 | 476 | { |
| 477 | - if (! $entity->getPk()) { |
|
| 477 | + if (!$entity->getPk()) { |
|
| 478 | 478 | $action = new Insert($this, $entity, $options); |
| 479 | 479 | } else { |
| 480 | 480 | $action = new Update($this, $entity, $options); |
@@ -501,7 +501,7 @@ discard block |
||
| 501 | 501 | |
| 502 | 502 | protected function assertCanPersistEntity($entity) |
| 503 | 503 | { |
| 504 | - if (! $entity || ! $entity instanceof $this->entityClass) { |
|
| 504 | + if (!$entity || !$entity instanceof $this->entityClass) { |
|
| 505 | 505 | throw new \InvalidArgumentException(sprintf( |
| 506 | 506 | 'Mapper %s can only persist entity of class %s. %s class provided', |
| 507 | 507 | __CLASS__, |