@@ -150,7 +150,7 @@ |
||
| 150 | 150 | */ |
| 151 | 151 | public function query(array $query = []) |
| 152 | 152 | { |
| 153 | - array_walk_recursive($query, function (&$value) { |
|
| 153 | + array_walk_recursive($query, function(&$value) { |
|
| 154 | 154 | if ($value instanceof \DateTime) { |
| 155 | 155 | //MongoDate is always UTC, which is good :) |
| 156 | 156 | $value = new \MongoDate($value->getTimestamp()); |
@@ -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 | { |
@@ -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; |
@@ -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 | /** |
@@ -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 | } |
@@ -21,7 +21,7 @@ discard block |
||
| 21 | 21 | */ |
| 22 | 22 | public function getName(): string |
| 23 | 23 | { |
| 24 | - return $this->tablePrefix . $this->table . '_' . $this->column . '_fk'; |
|
| 24 | + return $this->tablePrefix.$this->table.'_'.$this->column.'_fk'; |
|
| 25 | 25 | } |
| 26 | 26 | |
| 27 | 27 | /** |
@@ -32,10 +32,10 @@ discard block |
||
| 32 | 32 | $statement = []; |
| 33 | 33 | |
| 34 | 34 | $statement[] = 'FOREIGN KEY'; |
| 35 | - $statement[] = '(' . $driver->identifier($this->column) . ')'; |
|
| 35 | + $statement[] = '('.$driver->identifier($this->column).')'; |
|
| 36 | 36 | |
| 37 | - $statement[] = 'REFERENCES ' . $driver->identifier($this->foreignTable); |
|
| 38 | - $statement[] = '(' . $driver->identifier($this->foreignKey) . ')'; |
|
| 37 | + $statement[] = 'REFERENCES '.$driver->identifier($this->foreignTable); |
|
| 38 | + $statement[] = '('.$driver->identifier($this->foreignKey).')'; |
|
| 39 | 39 | |
| 40 | 40 | $statement[] = "ON DELETE {$this->deleteRule}"; |
| 41 | 41 | $statement[] = "ON UPDATE {$this->updateRule}"; |
@@ -637,7 +637,7 @@ discard block |
||
| 637 | 637 | */ |
| 638 | 638 | public function __toString() |
| 639 | 639 | { |
| 640 | - return $this->table . '.' . $this->getName(); |
|
| 640 | + return $this->table.'.'.$this->getName(); |
|
| 641 | 641 | } |
| 642 | 642 | |
| 643 | 643 | /** |
@@ -695,7 +695,7 @@ discard block |
||
| 695 | 695 | } |
| 696 | 696 | |
| 697 | 697 | if (!empty($enumValues)) { |
| 698 | - return '(' . implode(', ', $enumValues) . ')'; |
|
| 698 | + return '('.implode(', ', $enumValues).')'; |
|
| 699 | 699 | } |
| 700 | 700 | |
| 701 | 701 | return ''; |
@@ -265,7 +265,7 @@ |
||
| 265 | 265 | public function __call(string $method, array $arguments) |
| 266 | 266 | { |
| 267 | 267 | if (!in_array($method = strtoupper($method), ['AVG', 'MIN', 'MAX', 'SUM'])) { |
| 268 | - throw new BuilderException("Unknown method '{$method}' in '" . get_class($this) . "'"); |
|
| 268 | + throw new BuilderException("Unknown method '{$method}' in '".get_class($this)."'"); |
|
| 269 | 269 | } |
| 270 | 270 | |
| 271 | 271 | if (!isset($arguments[0]) || count($arguments) > 1) { |