@@ -264,7 +264,7 @@ discard block |
||
264 | 264 | */ |
265 | 265 | public function identifier($identifier) |
266 | 266 | { |
267 | - return $identifier == '*' ? '*' : '"' . str_replace('"', '""', $identifier) . '"'; |
|
267 | + return $identifier == '*' ? '*' : '"'.str_replace('"', '""', $identifier).'"'; |
|
268 | 268 | } |
269 | 269 | |
270 | 270 | /** |
@@ -587,7 +587,7 @@ discard block |
||
587 | 587 | protected function savepointCreate($name) |
588 | 588 | { |
589 | 589 | $this->logger()->info("Creating savepoint '{$name}'"); |
590 | - $this->statement('SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
590 | + $this->statement('SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
591 | 591 | } |
592 | 592 | |
593 | 593 | /** |
@@ -601,7 +601,7 @@ discard block |
||
601 | 601 | protected function savepointRelease($name) |
602 | 602 | { |
603 | 603 | $this->logger()->info("Releasing savepoint '{$name}'"); |
604 | - $this->statement('RELEASE SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
604 | + $this->statement('RELEASE SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
605 | 605 | } |
606 | 606 | |
607 | 607 | /** |
@@ -615,7 +615,7 @@ discard block |
||
615 | 615 | protected function savepointRollback($name) |
616 | 616 | { |
617 | 617 | $this->logger()->info("Rolling back savepoint '{$name}'"); |
618 | - $this->statement('ROLLBACK TO SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
618 | + $this->statement('ROLLBACK TO SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
619 | 619 | } |
620 | 620 | |
621 | 621 | /** |
@@ -120,16 +120,16 @@ |
||
120 | 120 | return sprintf('%F', $parameter); |
121 | 121 | |
122 | 122 | case 'string': |
123 | - return "'" . addcslashes($parameter, "'") . "'"; |
|
123 | + return "'".addcslashes($parameter, "'")."'"; |
|
124 | 124 | |
125 | 125 | case 'object': |
126 | 126 | if (method_exists($parameter, '__toString')) { |
127 | - return "'" . addcslashes((string)$parameter, "'") . "'"; |
|
127 | + return "'".addcslashes((string)$parameter, "'")."'"; |
|
128 | 128 | } |
129 | 129 | |
130 | 130 | if ($parameter instanceof \DateTime) { |
131 | 131 | //Let's process dates different way |
132 | - return "'" . $parameter->format(\DateTime::ISO8601) . "'"; |
|
132 | + return "'".$parameter->format(\DateTime::ISO8601)."'"; |
|
133 | 133 | } |
134 | 134 | } |
135 | 135 |
@@ -404,7 +404,7 @@ discard block |
||
404 | 404 | public function __call($method, $arguments) |
405 | 405 | { |
406 | 406 | if (!in_array($method = strtoupper($method), ['AVG', 'MIN', 'MAX', 'SUM'])) { |
407 | - throw new BuilderException("Unknown method '{$method}' in '" . get_class($this) . "'"); |
|
407 | + throw new BuilderException("Unknown method '{$method}' in '".get_class($this)."'"); |
|
408 | 408 | } |
409 | 409 | |
410 | 410 | if (!isset($arguments[0]) || count($arguments) > 1) { |
@@ -453,7 +453,7 @@ discard block |
||
453 | 453 | */ |
454 | 454 | private function havingWrapper() |
455 | 455 | { |
456 | - return function ($parameter) { |
|
456 | + return function($parameter) { |
|
457 | 457 | if ($parameter instanceof FragmentInterface) { |
458 | 458 | //We are only not creating bindings for plan fragments |
459 | 459 | if (!$parameter instanceof ParameterInterface && !$parameter instanceof QueryBuilder) { |
@@ -54,7 +54,7 @@ |
||
54 | 54 | $statement = ''; |
55 | 55 | if (!empty($limit) || !empty($offset)) { |
56 | 56 | //When limit is not provided but offset does we can replace limit value with PHP_INT_MAX |
57 | - $statement = 'LIMIT ' . ($limit ?: '18446744073709551615') . ' '; |
|
57 | + $statement = 'LIMIT '.($limit ?: '18446744073709551615').' '; |
|
58 | 58 | } |
59 | 59 | |
60 | 60 | if (!empty($offset)) { |
@@ -35,9 +35,9 @@ discard block |
||
35 | 35 | $selectColumns[] = "? AS {$this->quote($column)}"; |
36 | 36 | } |
37 | 37 | |
38 | - $statement[] = 'SELECT ' . implode(', ', $selectColumns); |
|
38 | + $statement[] = 'SELECT '.implode(', ', $selectColumns); |
|
39 | 39 | } else { |
40 | - $statement[] = 'UNION SELECT ' . trim(str_repeat('?, ', count($columns)), ', '); |
|
40 | + $statement[] = 'UNION SELECT '.trim(str_repeat('?, ', count($columns)), ', '); |
|
41 | 41 | } |
42 | 42 | } |
43 | 43 | |
@@ -58,7 +58,7 @@ discard block |
||
58 | 58 | $statement = ''; |
59 | 59 | |
60 | 60 | if (!empty($limit) || !empty($offset)) { |
61 | - $statement = 'LIMIT ' . ($limit ?: '-1') . ' '; |
|
61 | + $statement = 'LIMIT '.($limit ?: '-1').' '; |
|
62 | 62 | } |
63 | 63 | |
64 | 64 | if (!empty($offset)) { |
@@ -68,7 +68,7 @@ |
||
68 | 68 | /** |
69 | 69 | * Migration status. |
70 | 70 | * |
71 | - * @return int |
|
71 | + * @return boolean |
|
72 | 72 | */ |
73 | 73 | public function getStatus() |
74 | 74 | { |
@@ -436,7 +436,7 @@ |
||
436 | 436 | * Debug information and logging. |
437 | 437 | * |
438 | 438 | * @param \MongoCursor $cursor |
439 | - * @param int|bool $profiling Profiling level |
|
439 | + * @param integer $profiling Profiling level |
|
440 | 440 | */ |
441 | 441 | protected function describeCursor( |
442 | 442 | \MongoCursor $cursor, |
@@ -328,7 +328,7 @@ discard block |
||
328 | 328 | public function __debugInfo() |
329 | 329 | { |
330 | 330 | return [ |
331 | - 'collection' => $this->getDatabase() . '/' . $this->getCollection(), |
|
331 | + 'collection' => $this->getDatabase().'/'.$this->getCollection(), |
|
332 | 332 | 'query' => $this->query, |
333 | 333 | 'limit' => $this->getLimit(), |
334 | 334 | 'offset' => $this->getOffset(), |
@@ -422,7 +422,7 @@ discard block |
||
422 | 422 | */ |
423 | 423 | private function normalizeDates(array $query) |
424 | 424 | { |
425 | - array_walk_recursive($query, function (&$value) { |
|
425 | + array_walk_recursive($query, function(&$value) { |
|
426 | 426 | if ($value instanceof \DateTime) { |
427 | 427 | //MongoDate is always UTC, which is good :) |
428 | 428 | $value = new \MongoDate($value->getTimestamp()); |
@@ -471,7 +471,7 @@ discard block |
||
471 | 471 | $debug['explained'] = $cursor->explain(); |
472 | 472 | } |
473 | 473 | |
474 | - $this->logger()->debug('{db}/{collection}: ' . json_encode($debug, JSON_PRETTY_PRINT), [ |
|
474 | + $this->logger()->debug('{db}/{collection}: '.json_encode($debug, JSON_PRETTY_PRINT), [ |
|
475 | 475 | 'db' => $this->getDatabase(), |
476 | 476 | 'collection' => $this->getCollection(), |
477 | 477 | 'queryInfo' => $debug, |
@@ -68,7 +68,7 @@ |
||
68 | 68 | /** |
69 | 69 | * Migration status. |
70 | 70 | * |
71 | - * @return int |
|
71 | + * @return boolean |
|
72 | 72 | */ |
73 | 73 | public function getStatus() |
74 | 74 | { |
@@ -317,7 +317,7 @@ |
||
317 | 317 | if ( |
318 | 318 | is_array($type) |
319 | 319 | && is_scalar($type[0]) |
320 | - && $filter = $this->builder->getMutators('array::' . $type[0]) |
|
320 | + && $filter = $this->builder->getMutators('array::'.$type[0]) |
|
321 | 321 | ) { |
322 | 322 | //Mutator associated to array with specified type |
323 | 323 | $resolved += $filter; |
@@ -330,7 +330,7 @@ |
||
330 | 330 | * Perform iterator on pre-loaded data. Use relation selector to iterate thought custom relation |
331 | 331 | * query. |
332 | 332 | * |
333 | - * @return RecordEntity|RecordEntity[]|RecordIterator |
|
333 | + * @return null|EntityInterface |
|
334 | 334 | */ |
335 | 335 | public function getIterator() |
336 | 336 | { |