@@ -15,7 +15,7 @@ |
||
15 | 15 | { |
16 | 16 | return sprintf( |
17 | 17 | '%s %s %s', |
18 | - $this->transformField($comparison, $this->quote . $field . $this->quote), |
|
18 | + $this->transformField($comparison, $this->quote.$field.$this->quote), |
|
19 | 19 | $this->transformComparison($comparison, $value), |
20 | 20 | $this->normalizeValue($value) |
21 | 21 | ); |
@@ -51,7 +51,7 @@ discard block |
||
51 | 51 | public function beginTransaction() |
52 | 52 | { |
53 | 53 | $this->execute( |
54 | - function (TransactionalInterface $handler) { |
|
54 | + function(TransactionalInterface $handler) { |
|
55 | 55 | $handler->beginTransaction(); |
56 | 56 | } |
57 | 57 | ); |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | public function rollback() |
64 | 64 | { |
65 | 65 | $this->execute( |
66 | - function (TransactionalInterface $handler) { |
|
66 | + function(TransactionalInterface $handler) { |
|
67 | 67 | $handler->rollback(); |
68 | 68 | } |
69 | 69 | ); |
@@ -75,7 +75,7 @@ discard block |
||
75 | 75 | public function commit() |
76 | 76 | { |
77 | 77 | $this->execute( |
78 | - function (TransactionalInterface $handler) { |
|
78 | + function(TransactionalInterface $handler) { |
|
79 | 79 | $handler->commit(); |
80 | 80 | } |
81 | 81 | ); |
@@ -136,7 +136,7 @@ discard block |
||
136 | 136 | if (!empty($values)) { |
137 | 137 | $normalized = array(); |
138 | 138 | foreach ($values as $index => $value) { |
139 | - $normalized[':' . $index] = $value; |
|
139 | + $normalized[':'.$index] = $value; |
|
140 | 140 | } |
141 | 141 | |
142 | 142 | $values = $normalized; |
@@ -261,9 +261,9 @@ discard block |
||
261 | 261 | $wheres = $this->buildDataSets($conditions); |
262 | 262 | |
263 | 263 | return |
264 | - 'UPDATE ' . $this->quote($table) . |
|
265 | - ' SET ' . implode(', ', $sets) . |
|
266 | - ' WHERE ' . implode(' AND ', $wheres); |
|
264 | + 'UPDATE '.$this->quote($table). |
|
265 | + ' SET '.implode(', ', $sets). |
|
266 | + ' WHERE '.implode(' AND ', $wheres); |
|
267 | 267 | } |
268 | 268 | |
269 | 269 | /** |
@@ -280,8 +280,8 @@ discard block |
||
280 | 280 | $values = array_keys($values); |
281 | 281 | |
282 | 282 | return |
283 | - 'INSERT INTO ' . $this->quote($table) . |
|
284 | - ' (' . implode(', ', $keys) . ') VALUES (:' . implode(', :', $values) . ')'; |
|
283 | + 'INSERT INTO '.$this->quote($table). |
|
284 | + ' ('.implode(', ', $keys).') VALUES (:'.implode(', :', $values).')'; |
|
285 | 285 | } |
286 | 286 | |
287 | 287 | /** |
@@ -295,7 +295,7 @@ discard block |
||
295 | 295 | { |
296 | 296 | $sets = array(); |
297 | 297 | foreach ($parts as $name => $value) { |
298 | - $sets[] = $this->quote($name) . '=:' . $name; |
|
298 | + $sets[] = $this->quote($name).'=:'.$name; |
|
299 | 299 | } |
300 | 300 | |
301 | 301 | return $sets; |
@@ -310,7 +310,7 @@ discard block |
||
310 | 310 | */ |
311 | 311 | protected function quote($field) |
312 | 312 | { |
313 | - return $this->quote . $field . $this->quote; |
|
313 | + return $this->quote.$field.$this->quote; |
|
314 | 314 | } |
315 | 315 | |
316 | 316 | /** |
@@ -338,7 +338,7 @@ |
||
338 | 338 | } |
339 | 339 | |
340 | 340 | /** |
341 | - * @param mixed $value |
|
341 | + * @param string $value |
|
342 | 342 | * |
343 | 343 | * @return mixed|null|string |
344 | 344 | */ |
@@ -10,7 +10,6 @@ |
||
10 | 10 | |
11 | 11 | namespace Borobudur\Cqrs\ReadModel\Storage\Pdo; |
12 | 12 | |
13 | -use Borobudur\Collection\Collection; |
|
14 | 13 | use Borobudur\Cqrs\Exception\InvalidArgumentException; |
15 | 14 | use Borobudur\Cqrs\ReadModel\ReadModelInterface; |
16 | 15 | use Borobudur\Cqrs\ReadModel\Storage\Finder\Expression\CompositeExpressionInterface; |