@@ -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 hasUpdates(bool &$changedEntities = null): bool |
|
| 262 | + public function hasUpdates(bool & $changedEntities = null): bool |
|
| 263 | 263 | { |
| 264 | 264 | foreach ($this->entities as $entity) { |
| 265 | 265 | if ($entity->hasUpdates()) { |
@@ -326,7 +326,7 @@ discard block |
||
| 326 | 326 | |
| 327 | 327 | $atomics = array_merge( |
| 328 | 328 | $atomics, |
| 329 | - $document->buildAtomics((!empty($container) ? $container . '.' : '') . $offset) |
|
| 329 | + $document->buildAtomics((!empty($container) ? $container.'.' : '').$offset) |
|
| 330 | 330 | ); |
| 331 | 331 | } |
| 332 | 332 | |
@@ -94,7 +94,7 @@ discard block |
||
| 94 | 94 | * |
| 95 | 95 | * @param string|\MongoId $id Primary key value. |
| 96 | 96 | * |
| 97 | - * @return CompositableInterface|Document|null |
|
| 97 | + * @return CompositableInterface|null |
|
| 98 | 98 | */ |
| 99 | 99 | public function findByPK($id) |
| 100 | 100 | { |
@@ -107,7 +107,7 @@ discard block |
||
| 107 | 107 | * @param array $query Fields and conditions to query by. |
| 108 | 108 | * @param array $sortBy Always specify sort by to ensure that results are stable. |
| 109 | 109 | * |
| 110 | - * @return CompositableInterface|Document|null |
|
| 110 | + * @return CompositableInterface|null |
|
| 111 | 111 | */ |
| 112 | 112 | public function findOne(array $query = [], array $sortBy = []) |
| 113 | 113 | { |
@@ -93,13 +93,15 @@ |
||
| 93 | 93 | //Via global scope |
| 94 | 94 | $container = self::staticContainer(); |
| 95 | 95 | |
| 96 | - if (empty($container)) //Via global scope |
|
| 96 | + if (empty($container)) { |
|
| 97 | + //Via global scope |
|
| 97 | 98 | { |
| 98 | 99 | throw new ScopeException(sprintf( |
| 99 | 100 | "Unable to get '%s' source, no container scope is available", |
| 100 | 101 | static::class |
| 101 | 102 | )); |
| 102 | 103 | } |
| 104 | + } |
|
| 103 | 105 | |
| 104 | 106 | return $container->get(ODM::class)->source(static::class); |
| 105 | 107 | } |
@@ -176,7 +176,7 @@ discard block |
||
| 176 | 176 | $aggregationType = isset($type[Document::ONE]) ? Document::ONE : Document::MANY; |
| 177 | 177 | |
| 178 | 178 | $result[$field] = new AggregationDefinition( |
| 179 | - $aggregationType, //Aggregation type |
|
| 179 | + $aggregationType, //Aggregation type |
|
| 180 | 180 | $type[$aggregationType], //Class name |
| 181 | 181 | array_pop($type) //Query template |
| 182 | 182 | ); |
@@ -355,7 +355,7 @@ discard block |
||
| 355 | 355 | if ( |
| 356 | 356 | is_array($type) |
| 357 | 357 | && is_scalar($type[0]) |
| 358 | - && $filter = $this->mutatorsConfig->getMutators('array::' . $type[0]) |
|
| 358 | + && $filter = $this->mutatorsConfig->getMutators('array::'.$type[0]) |
|
| 359 | 359 | ) { |
| 360 | 360 | //Mutator associated to array with specified type |
| 361 | 361 | $resolved += $filter; |
@@ -115,14 +115,14 @@ discard block |
||
| 115 | 115 | public function getPrimary(string $prefix, string $table): string |
| 116 | 116 | { |
| 117 | 117 | if (!empty($this->memory) && empty($this->primaryKeys)) { |
| 118 | - $this->primaryKeys = (array)$this->memory->loadData($this->getSource() . '.keys'); |
|
| 118 | + $this->primaryKeys = (array)$this->memory->loadData($this->getSource().'.keys'); |
|
| 119 | 119 | } |
| 120 | 120 | |
| 121 | 121 | if (!empty($this->primaryKeys) && array_key_exists($table, $this->primaryKeys)) { |
| 122 | 122 | return $this->primaryKeys[$table]; |
| 123 | 123 | } |
| 124 | 124 | |
| 125 | - if (!$this->hasTable($prefix . $table)) { |
|
| 125 | + if (!$this->hasTable($prefix.$table)) { |
|
| 126 | 126 | throw new DriverException( |
| 127 | 127 | "Unable to fetch table primary key, no such table '{$prefix}{$table}' exists" |
| 128 | 128 | ); |
@@ -138,7 +138,7 @@ discard block |
||
| 138 | 138 | |
| 139 | 139 | //Caching |
| 140 | 140 | if (!empty($this->memory)) { |
| 141 | - $this->memory->saveData($this->getSource() . ',keys', $this->primaryKeys); |
|
| 141 | + $this->memory->saveData($this->getSource().',keys', $this->primaryKeys); |
|
| 142 | 142 | } |
| 143 | 143 | |
| 144 | 144 | return $this->primaryKeys[$table]; |
@@ -153,7 +153,7 @@ discard block |
||
| 153 | 153 | { |
| 154 | 154 | return $this->factory->make( |
| 155 | 155 | PostgresQuery::class, |
| 156 | - ['driver' => $this, 'compiler' => $this->queryCompiler($prefix),] + $parameters |
|
| 156 | + ['driver' => $this, 'compiler' => $this->queryCompiler($prefix), ] + $parameters |
|
| 157 | 157 | ); |
| 158 | 158 | } |
| 159 | 159 | |
@@ -322,7 +322,7 @@ discard block |
||
| 322 | 322 | $this->logger()->info("Creating savepoint '{$name}'"); |
| 323 | 323 | } |
| 324 | 324 | |
| 325 | - $this->statement('SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 325 | + $this->statement('SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 326 | 326 | } |
| 327 | 327 | |
| 328 | 328 | /** |
@@ -339,7 +339,7 @@ discard block |
||
| 339 | 339 | $this->logger()->info("Releasing savepoint '{$name}'"); |
| 340 | 340 | } |
| 341 | 341 | |
| 342 | - $this->statement('RELEASE SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 342 | + $this->statement('RELEASE SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 343 | 343 | } |
| 344 | 344 | |
| 345 | 345 | /** |
@@ -355,6 +355,6 @@ discard block |
||
| 355 | 355 | if ($this->isProfiling()) { |
| 356 | 356 | $this->logger()->info("Rolling back savepoint '{$name}'"); |
| 357 | 357 | } |
| 358 | - $this->statement('ROLLBACK TO SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 358 | + $this->statement('ROLLBACK TO SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 359 | 359 | } |
| 360 | 360 | } |
@@ -255,7 +255,7 @@ |
||
| 255 | 255 | */ |
| 256 | 256 | public function identifier(string $identifier): string |
| 257 | 257 | { |
| 258 | - return $identifier == '*' ? '*' : '"' . str_replace('"', '""', $identifier) . '"'; |
|
| 258 | + return $identifier == '*' ? '*' : '"'.str_replace('"', '""', $identifier).'"'; |
|
| 259 | 259 | } |
| 260 | 260 | |
| 261 | 261 | /** |
@@ -86,7 +86,7 @@ |
||
| 86 | 86 | * @param bool $hasDefault Must be set to true if default value was set by user. |
| 87 | 87 | * @param mixed $default Default value declared by record schema. |
| 88 | 88 | * |
| 89 | - * @return mixed |
|
| 89 | + * @return AbstractColumn |
|
| 90 | 90 | * |
| 91 | 91 | * @throws DefinitionException |
| 92 | 92 | * @throws \Spiral\Database\Exceptions\SchemaException |
@@ -613,7 +613,7 @@ discard block |
||
| 613 | 613 | */ |
| 614 | 614 | public function __toString() |
| 615 | 615 | { |
| 616 | - return $this->table . '.' . $this->getName(); |
|
| 616 | + return $this->table.'.'.$this->getName(); |
|
| 617 | 617 | } |
| 618 | 618 | |
| 619 | 619 | /** |
@@ -671,7 +671,7 @@ discard block |
||
| 671 | 671 | } |
| 672 | 672 | |
| 673 | 673 | if (!empty($enumValues)) { |
| 674 | - return '(' . implode(', ', $enumValues) . ')'; |
|
| 674 | + return '('.implode(', ', $enumValues).')'; |
|
| 675 | 675 | } |
| 676 | 676 | |
| 677 | 677 | return ''; |
@@ -740,7 +740,7 @@ discard block |
||
| 740 | 740 | $timestamp = strtotime($value); |
| 741 | 741 | if ($timestamp === false) { |
| 742 | 742 | throw new DefaultValueException( |
| 743 | - "Unable to normalize timestamp '{$value}' for column type '{$type}' in " . get_class($this) |
|
| 743 | + "Unable to normalize timestamp '{$value}' for column type '{$type}' in ".get_class($this) |
|
| 744 | 744 | ); |
| 745 | 745 | } |
| 746 | 746 | |