@@ -38,9 +38,9 @@ discard block |
||
38 | 38 | $selectColumns[] = "? AS {$this->quote($column)}"; |
39 | 39 | } |
40 | 40 | |
41 | - $statement[] = 'SELECT ' . implode(', ', $selectColumns); |
|
41 | + $statement[] = 'SELECT '.implode(', ', $selectColumns); |
|
42 | 42 | } else { |
43 | - $statement[] = 'UNION ALL SELECT ' . trim(str_repeat('?, ', count($columns)), ', '); |
|
43 | + $statement[] = 'UNION ALL SELECT '.trim(str_repeat('?, ', count($columns)), ', '); |
|
44 | 44 | } |
45 | 45 | } |
46 | 46 | |
@@ -61,7 +61,7 @@ discard block |
||
61 | 61 | $statement = ''; |
62 | 62 | |
63 | 63 | if (!empty($limit) || !empty($offset)) { |
64 | - $statement = 'LIMIT ' . ($limit ?: '-1') . ' '; |
|
64 | + $statement = 'LIMIT '.($limit ?: '-1').' '; |
|
65 | 65 | } |
66 | 66 | |
67 | 67 | if (!empty($offset)) { |
@@ -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 | - $entity->buildAtomics((!empty($container) ? $container . '.' : '') . $offset) |
|
329 | + $entity->buildAtomics((!empty($container) ? $container.'.' : '').$offset) |
|
330 | 330 | ); |
331 | 331 | } |
332 | 332 |
@@ -315,7 +315,7 @@ discard block |
||
315 | 315 | if ($value instanceof CompositableInterface) { |
316 | 316 | $atomics = array_merge_recursive( |
317 | 317 | $atomics, |
318 | - $value->buildAtomics((!empty($container) ? $container . '.' : '') . $field) |
|
318 | + $value->buildAtomics((!empty($container) ? $container.'.' : '').$field) |
|
319 | 319 | ); |
320 | 320 | |
321 | 321 | continue; |
@@ -330,7 +330,7 @@ discard block |
||
330 | 330 | |
331 | 331 | if (array_key_exists($field, $this->changes)) { |
332 | 332 | //Generating set operation for changed field |
333 | - $atomics['$set'][(!empty($container) ? $container . '.' : '') . $field] = $value; |
|
333 | + $atomics['$set'][(!empty($container) ? $container.'.' : '').$field] = $value; |
|
334 | 334 | } |
335 | 335 | } |
336 | 336 | |
@@ -377,7 +377,7 @@ discard block |
||
377 | 377 | { |
378 | 378 | $public = parent::publicFields(); |
379 | 379 | |
380 | - array_walk_recursive($public, function (&$value) { |
|
380 | + array_walk_recursive($public, function(&$value) { |
|
381 | 381 | if ($value instanceof ObjectID) { |
382 | 382 | $value = (string)$value; |
383 | 383 | } |
@@ -67,7 +67,7 @@ discard block |
||
67 | 67 | */ |
68 | 68 | public function identifier(string $identifier): string |
69 | 69 | { |
70 | - return $identifier == '*' ? '*' : '[' . str_replace('[', '[[', $identifier) . ']'; |
|
70 | + return $identifier == '*' ? '*' : '['.str_replace('[', '[[', $identifier).']'; |
|
71 | 71 | } |
72 | 72 | |
73 | 73 | /** |
@@ -125,7 +125,7 @@ discard block |
||
125 | 125 | $this->logger()->info("Transaction: new savepoint 'SVP{$name}'"); |
126 | 126 | } |
127 | 127 | |
128 | - $this->statement('SAVE TRANSACTION ' . $this->identifier("SVP{$name}")); |
|
128 | + $this->statement('SAVE TRANSACTION '.$this->identifier("SVP{$name}")); |
|
129 | 129 | } |
130 | 130 | |
131 | 131 | /** |
@@ -158,6 +158,6 @@ discard block |
||
158 | 158 | if ($this->isProfiling()) { |
159 | 159 | $this->logger()->info("Transaction: rollback savepoint 'SVP{$name}'"); |
160 | 160 | } |
161 | - $this->statement('ROLLBACK TRANSACTION ' . $this->identifier("SVP{$name}")); |
|
161 | + $this->statement('ROLLBACK TRANSACTION '.$this->identifier("SVP{$name}")); |
|
162 | 162 | } |
163 | 163 | } |
164 | 164 | \ No newline at end of file |