@@ -49,7 +49,7 @@ discard block |
||
49 | 49 | $tableName = self::TABLE_NAME; |
50 | 50 | $sql = <<<SQL |
51 | 51 | SELECT * FROM $tableName WHERE stream = :stream ORDER BY id ASC |
52 | -SQL; |
|
52 | +sql; |
|
53 | 53 | $storedEventRows = $this->pdo->execute($sql, ['stream' => $name->name()])->fetchAll(\PDO::FETCH_ASSOC); |
54 | 54 | $domainEventsCollection = $this->buildDomainEventsCollection($storedEventRows); |
55 | 55 | |
@@ -114,7 +114,7 @@ discard block |
||
114 | 114 | `stream` VARCHAR(255) NOT NULL, |
115 | 115 | PRIMARY KEY (`id`) |
116 | 116 | ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin; |
117 | -SQL; |
|
117 | +sql; |
|
118 | 118 | } |
119 | 119 | |
120 | 120 | public static function removeSchema() : string |