@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | ORDER BY `order` ASC |
80 | 80 | LIMIT $limit |
81 | 81 | OFFSET $offset |
82 | -SQL; |
|
82 | +sql; |
|
83 | 83 | |
84 | 84 | $storedEventRows = $this->pdo->query($sql, ['occurredOn' => $since]); |
85 | 85 | $storedEvents = $this->buildStoredEvents($storedEventRows); |
@@ -164,7 +164,7 @@ discard block |
||
164 | 164 | `stream_version` INT NOT NULL, |
165 | 165 | PRIMARY KEY (`order`) |
166 | 166 | ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin; |
167 | -SQL; |
|
167 | +sql; |
|
168 | 168 | } |
169 | 169 | |
170 | 170 | public static function removeSchema() : string |
@@ -9,7 +9,7 @@ discard block |
||
9 | 9 | * file that was distributed with this source code. |
10 | 10 | */ |
11 | 11 | |
12 | -declare(strict_types=1); |
|
12 | +declare(strict_types = 1); |
|
13 | 13 | |
14 | 14 | namespace LIN3S\SharedKernel\Infrastructure\Persistence\Sql\Event; |
15 | 15 | |
@@ -41,7 +41,7 @@ discard block |
||
41 | 41 | return; |
42 | 42 | } |
43 | 43 | |
44 | - $this->pdo->insert(self::TABLE_NAME, array_map(function (StoredEvent $event) { |
|
44 | + $this->pdo->insert(self::TABLE_NAME, array_map(function(StoredEvent $event) { |
|
45 | 45 | return $event->normalizeToAppend(); |
46 | 46 | }, $events)); |
47 | 47 | } |