@@ -18,6 +18,9 @@ |
||
18 | 18 | $this->dsn = $dsn; |
19 | 19 | } |
20 | 20 | |
21 | + /** |
|
22 | + * @param string $query |
|
23 | + */ |
|
21 | 24 | public function query($query) |
22 | 25 | { |
23 | 26 | $this->initialize(); |
@@ -34,7 +34,7 @@ discard block |
||
34 | 34 | $indexer = $this->getIndexer($index); |
35 | 35 | $range = array_replace($indexer->getRangeCriterias(), $rangeCriterias); |
36 | 36 | |
37 | - $reindexCallback = function ($data) use ($index, $indexer, $batchCallback, $range) { |
|
37 | + $reindexCallback = function($data) use ($index, $indexer, $batchCallback, $range) { |
|
38 | 38 | if (null !== $batchCallback) { |
39 | 39 | $batchCallback( |
40 | 40 | array( |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | { |
64 | 64 | $indexer = $this->getIndexer($index); |
65 | 65 | |
66 | - $reindexItemsCallback = function ($itemsIdsToProcess) use ($index, $indexer) { |
|
66 | + $reindexItemsCallback = function($itemsIdsToProcess) use ($index, $indexer) { |
|
67 | 67 | $items = $indexer->getItemsByIds($itemsIdsToProcess); |
68 | 68 | $this->processItems($index, $indexer, $items); |
69 | 69 | }; |
@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | |
77 | 77 | public function removeItems($index, $itemsIds) |
78 | 78 | { |
79 | - $removeItemsCallback = function () use ($index, $itemsIds) { |
|
79 | + $removeItemsCallback = function() use ($index, $itemsIds) { |
|
80 | 80 | return $this->conn->createQueryBuilder() |
81 | 81 | ->delete($this->conn->getEscaper()->quoteIdentifier($index)) |
82 | 82 | ->where('id IN :ids') |
@@ -89,7 +89,7 @@ discard block |
||
89 | 89 | |
90 | 90 | public function getIndexRange($index) |
91 | 91 | { |
92 | - $getIndexRangeCallback = function () use ($index) { |
|
92 | + $getIndexRangeCallback = function() use ($index) { |
|
93 | 93 | return $this->conn |
94 | 94 | ->createQueryBuilder() |
95 | 95 | ->select('MIN(id) AS `min`, MAX(id) AS `max`') |