@@ -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 |
@@ -288,8 +288,8 @@ discard block |
||
288 | 288 | bool $unique = true, |
289 | 289 | bool $resetState = false |
290 | 290 | ): AbstractTable { |
291 | - if (isset($this->tables[$database . '.table'])) { |
|
292 | - $schema = $this->tables[$database . '.table']; |
|
291 | + if (isset($this->tables[$database.'.table'])) { |
|
292 | + $schema = $this->tables[$database.'.table']; |
|
293 | 293 | |
294 | 294 | if ($unique) { |
295 | 295 | throw new DoubleReferenceException( |
@@ -299,7 +299,7 @@ discard block |
||
299 | 299 | } else { |
300 | 300 | //Requesting thought DatabaseManager |
301 | 301 | $schema = $this->manager->database($database)->table($table)->getSchema(); |
302 | - $this->tables[$database . '.' . $table] = $schema; |
|
302 | + $this->tables[$database.'.'.$table] = $schema; |
|
303 | 303 | } |
304 | 304 | |
305 | 305 | $schema = clone $schema; |
@@ -320,7 +320,7 @@ discard block |
||
320 | 320 | */ |
321 | 321 | protected function pushTable(AbstractTable $table, string $database = null) |
322 | 322 | { |
323 | - $this->tables[$database . '.' . $table->getName()] = $table; |
|
323 | + $this->tables[$database.'.'.$table->getName()] = $table; |
|
324 | 324 | |
325 | 325 | } |
326 | 326 | } |
327 | 327 | \ No newline at end of file |
@@ -136,8 +136,8 @@ |
||
136 | 136 | * |
137 | 137 | * @see Record::$indexes |
138 | 138 | */ |
139 | - const INDEX = 1000; //Default index type |
|
140 | - const UNIQUE = 2000; //Unique index definition |
|
139 | + const INDEX = 1000; //Default index type |
|
140 | + const UNIQUE = 2000; //Unique index definition |
|
141 | 141 | |
142 | 142 | /** |
143 | 143 | * Errors in relations and acessors. |
@@ -92,6 +92,6 @@ |
||
92 | 92 | throw new SchemaException('MySQL commander can process only MySQL tables'); |
93 | 93 | } |
94 | 94 | |
95 | - return parent::createStatement($table) . " ENGINE {$table->getEngine()}"; |
|
95 | + return parent::createStatement($table)." ENGINE {$table->getEngine()}"; |
|
96 | 96 | } |
97 | 97 | } |