@@ -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 | /** |
@@ -268,7 +268,7 @@ discard block |
||
268 | 268 | |
269 | 269 | //Dropping enum constrain before any operation |
270 | 270 | if ($initial->abstractType() == 'enum' && $this->constrained) { |
271 | - $operations[] = 'DROP CONSTRAINT ' . $driver->identifier($this->enumConstraint()); |
|
271 | + $operations[] = 'DROP CONSTRAINT '.$driver->identifier($this->enumConstraint()); |
|
272 | 272 | } |
273 | 273 | |
274 | 274 | //Default value set and dropping |
@@ -282,7 +282,7 @@ discard block |
||
282 | 282 | |
283 | 283 | //Nullable option |
284 | 284 | if ($initial->nullable != $this->nullable) { |
285 | - $operations[] = "ALTER COLUMN {$identifier} " . (!$this->nullable ? 'SET' : 'DROP') . ' NOT NULL'; |
|
285 | + $operations[] = "ALTER COLUMN {$identifier} ".(!$this->nullable ? 'SET' : 'DROP').' NOT NULL'; |
|
286 | 286 | } |
287 | 287 | |
288 | 288 | if ($this->abstractType() == 'enum') { |
@@ -292,7 +292,7 @@ discard block |
||
292 | 292 | } |
293 | 293 | |
294 | 294 | $operations[] = "ADD CONSTRAINT {$driver->identifier($this->enumConstraint())} " |
295 | - . "CHECK ({$identifier} IN (" . implode(', ', $enumValues) . '))'; |
|
295 | + . "CHECK ({$identifier} IN (".implode(', ', $enumValues).'))'; |
|
296 | 296 | } |
297 | 297 | |
298 | 298 | return $operations; |
@@ -304,7 +304,7 @@ discard block |
||
304 | 304 | protected function quoteEnum(Driver $driver): string |
305 | 305 | { |
306 | 306 | //Postgres enums are just constrained strings |
307 | - return '(' . $this->size . ')'; |
|
307 | + return '('.$this->size.')'; |
|
308 | 308 | } |
309 | 309 | |
310 | 310 | /** |
@@ -315,7 +315,7 @@ discard block |
||
315 | 315 | private function enumConstraint(): string |
316 | 316 | { |
317 | 317 | if (empty($this->constrainName)) { |
318 | - $this->constrainName = $this->table . '_' . $this->getName() . '_enum_' . uniqid(); |
|
318 | + $this->constrainName = $this->table.'_'.$this->getName().'_enum_'.uniqid(); |
|
319 | 319 | } |
320 | 320 | |
321 | 321 | return $this->constrainName; |
@@ -419,11 +419,11 @@ discard block |
||
419 | 419 | |
420 | 420 | $constraints = $driver->query($query, [ |
421 | 421 | $tableOID, |
422 | - '(' . $column->name . '%', |
|
423 | - '("' . $column->name . '%', |
|
422 | + '('.$column->name.'%', |
|
423 | + '("'.$column->name.'%', |
|
424 | 424 | //Postgres magic |
425 | - $column->name . '::text%', |
|
426 | - '%(' . $column->name . ')::text%' |
|
425 | + $column->name.'::text%', |
|
426 | + '%('.$column->name.')::text%' |
|
427 | 427 | ]); |
428 | 428 | |
429 | 429 | foreach ($constraints as $constraint) { |
@@ -453,7 +453,7 @@ discard block |
||
453 | 453 | */ |
454 | 454 | private static function resolveEnum(Driver $driver, PostgresColumn $column) |
455 | 455 | { |
456 | - $range = $driver->query('SELECT enum_range(NULL::' . $column->type . ')')->fetchColumn(0); |
|
456 | + $range = $driver->query('SELECT enum_range(NULL::'.$column->type.')')->fetchColumn(0); |
|
457 | 457 | |
458 | 458 | $column->enumValues = explode(',', substr($range, 1, -1)); |
459 | 459 |
@@ -212,7 +212,7 @@ |
||
212 | 212 | $class = (new \ReflectionClass($accessor->getClass()))->getShortName(); |
213 | 213 | |
214 | 214 | //[+] for loaded, [~] for lazy loaded |
215 | - $relations[$relation] = $type . '(' . $class . ') [' . ($accessor->isLoaded() ? '+]' : '~]'); |
|
215 | + $relations[$relation] = $type.'('.$class.') ['.($accessor->isLoaded() ? '+]' : '~]'); |
|
216 | 216 | } |
217 | 217 | |
218 | 218 | return $relations; |
@@ -187,7 +187,7 @@ |
||
187 | 187 | * Delete multiple records, strict compaction, make sure exactly same instance is given. Method |
188 | 188 | * would not autoload instance and will mark it as partial. |
189 | 189 | * |
190 | - * @param array|\Traversable $records |
|
190 | + * @param RecordInterface[] $records |
|
191 | 191 | */ |
192 | 192 | public function deleteMultiple($records) |
193 | 193 | { |
@@ -371,7 +371,7 @@ |
||
371 | 371 | * Particular case when parent entity exists but now saved yet AND outer key is PK. |
372 | 372 | * Basically inversed case of BELONGS_TO. |
373 | 373 | */ |
374 | - $command->onExecute(function (ContextualCommandInterface $command) use ($inner) { |
|
374 | + $command->onExecute(function(ContextualCommandInterface $command) use ($inner) { |
|
375 | 375 | $inner->addContext($this->schema[Record::OUTER_KEY], $command->primaryKey()); |
376 | 376 | }); |
377 | 377 | } else { |
@@ -97,8 +97,8 @@ discard block |
||
97 | 97 | * |
98 | 98 | * @see Record::INDEXES |
99 | 99 | */ |
100 | - const INDEX = 1000; //Default index type |
|
101 | - const UNIQUE = 2000; //Unique index definition |
|
100 | + const INDEX = 1000; //Default index type |
|
101 | + const UNIQUE = 2000; //Unique index definition |
|
102 | 102 | |
103 | 103 | /* |
104 | 104 | * ================================================ |
@@ -302,11 +302,11 @@ discard block |
||
302 | 302 | $this->dispatch('insert', new RecordEvent($this, $command)); |
303 | 303 | |
304 | 304 | //Executed when transaction successfully completed |
305 | - $command->onComplete(function (InsertCommand $command) { |
|
305 | + $command->onComplete(function(InsertCommand $command) { |
|
306 | 306 | $this->handleInsert($command); |
307 | 307 | }); |
308 | 308 | |
309 | - $command->onRollBack(function () { |
|
309 | + $command->onRollBack(function() { |
|
310 | 310 | //Flushing existed insert command to prevent collisions |
311 | 311 | $this->lastInsert = null; |
312 | 312 | $this->state = ORMInterface::STATE_NEW; |
@@ -329,7 +329,7 @@ discard block |
||
329 | 329 | ); |
330 | 330 | |
331 | 331 | if (!empty($this->lastInsert)) { |
332 | - $this->lastInsert->onExecute(function (InsertCommand $insert) use ($command) { |
|
332 | + $this->lastInsert->onExecute(function(InsertCommand $insert) use ($command) { |
|
333 | 333 | //Sync primary key values |
334 | 334 | $command->setWhere([$this->primaryColumn() => $insert->getInsertID()]); |
335 | 335 | $command->setPrimaryKey($insert->getInsertID()); |
@@ -341,11 +341,11 @@ discard block |
||
341 | 341 | $this->dispatch('update', new RecordEvent($this)); |
342 | 342 | |
343 | 343 | //Executed when transaction successfully completed |
344 | - $command->onComplete(function (UpdateCommand $command) { |
|
344 | + $command->onComplete(function(UpdateCommand $command) { |
|
345 | 345 | $this->handleUpdate($command); |
346 | 346 | }); |
347 | 347 | |
348 | - $command->onRollBack(function () { |
|
348 | + $command->onRollBack(function() { |
|
349 | 349 | //Flushing existed insert command to prevent collisions |
350 | 350 | $this->state = ORMInterface::STATE_LOADED; |
351 | 351 | }); |
@@ -365,7 +365,7 @@ discard block |
||
365 | 365 | |
366 | 366 | if (!empty($this->lastInsert)) { |
367 | 367 | //Sync primary key values |
368 | - $this->lastInsert->onExecute(function (InsertCommand $insert) use ($command) { |
|
368 | + $this->lastInsert->onExecute(function(InsertCommand $insert) use ($command) { |
|
369 | 369 | $command->setWhere([$this->primaryColumn() => $insert->primaryKey()]); |
370 | 370 | }); |
371 | 371 | } |
@@ -375,7 +375,7 @@ discard block |
||
375 | 375 | $this->dispatch('delete', new RecordEvent($this)); |
376 | 376 | |
377 | 377 | //Executed when transaction successfully completed |
378 | - $command->onComplete(function (DeleteCommand $command) { |
|
378 | + $command->onComplete(function(DeleteCommand $command) { |
|
379 | 379 | $this->handleDelete($command); |
380 | 380 | }); |
381 | 381 |
@@ -165,11 +165,11 @@ |
||
165 | 165 | } |
166 | 166 | } elseif (!is_object($value)) { |
167 | 167 | throw new RelationException( |
168 | - "Must be an instance of '{$this->class}', '" . gettype($value) . "' given" |
|
168 | + "Must be an instance of '{$this->class}', '".gettype($value)."' given" |
|
169 | 169 | ); |
170 | 170 | } elseif (!is_a($value, $this->class, false)) { |
171 | 171 | throw new RelationException( |
172 | - "Must be an instance of '{$this->class}', '" . get_class($value) . "' given" |
|
172 | + "Must be an instance of '{$this->class}', '".get_class($value)."' given" |
|
173 | 173 | ); |
174 | 174 | } |
175 | 175 | } |
@@ -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 | } |
@@ -109,7 +109,7 @@ discard block |
||
109 | 109 | return null; |
110 | 110 | } |
111 | 111 | |
112 | - return $this->entities[$class . ':' . $identity]; |
|
112 | + return $this->entities[$class.':'.$identity]; |
|
113 | 113 | } |
114 | 114 | |
115 | 115 | /** |
@@ -224,7 +224,7 @@ |
||
224 | 224 | */ |
225 | 225 | public function __toString() |
226 | 226 | { |
227 | - return static::class . '#' . hash('crc32', spl_object_hash($this)); |
|
227 | + return static::class.'#'.hash('crc32', spl_object_hash($this)); |
|
228 | 228 | } |
229 | 229 | |
230 | 230 | /** |
@@ -82,7 +82,7 @@ |
||
82 | 82 | ); |
83 | 83 | } else { |
84 | 84 | //Syncing using promise |
85 | - $related->onExecute(function (ContextualCommandInterface $related) use ($command) { |
|
85 | + $related->onExecute(function(ContextualCommandInterface $related) use ($command) { |
|
86 | 86 | //Giving our child our context in a form of FK value |
87 | 87 | $command->addContext($this->key(Record::INNER_KEY), $related->primaryKey()); |
88 | 88 | }); |