@@ -229,14 +229,14 @@ discard block |
||
229 | 229 | $this->connection->beginTransaction(); |
230 | 230 | |
231 | 231 | $this->connection->exec( |
232 | - 'CREATE TABLE `'.self::STREAMS_TABLE.'` ( |
|
232 | + 'CREATE TABLE `' . self::STREAMS_TABLE . '` ( |
|
233 | 233 | `id` varchar(255) NOT NULL, |
234 | 234 | PRIMARY KEY (`id`) |
235 | 235 | )' |
236 | 236 | ); |
237 | 237 | |
238 | 238 | $this->connection->exec( |
239 | - 'CREATE TABLE `'.self::EVENTS_TABLE.'` ( |
|
239 | + 'CREATE TABLE `' . self::EVENTS_TABLE . '` ( |
|
240 | 240 | `id` int(11) NOT NULL AUTO_INCREMENT, |
241 | 241 | `stream_id` varchar(255) NOT NULL, |
242 | 242 | `type` varchar(255) NOT NULL, |
@@ -263,7 +263,7 @@ discard block |
||
263 | 263 | public function initialized() |
264 | 264 | { |
265 | 265 | try { |
266 | - $result = $this->connection->query('SELECT 1 FROM `'.self::STREAMS_TABLE.'` LIMIT 1'); |
|
266 | + $result = $this->connection->query('SELECT 1 FROM `' . self::STREAMS_TABLE . '` LIMIT 1'); |
|
267 | 267 | } catch (\Exception $e) { |
268 | 268 | return false; |
269 | 269 | } |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | public function initialize() |
86 | 86 | { |
87 | 87 | $this->connection->exec( |
88 | - 'CREATE TABLE `'.self::SNAPSHOTS_TABLE.'` ( |
|
88 | + 'CREATE TABLE `' . self::SNAPSHOTS_TABLE . '` ( |
|
89 | 89 | `id` int(11) NOT NULL AUTO_INCREMENT, |
90 | 90 | `aggregate_type` varchar(255) NOT NULL, |
91 | 91 | `aggregate_id` varchar(255) NOT NULL, |
@@ -103,7 +103,7 @@ discard block |
||
103 | 103 | public function initialized() |
104 | 104 | { |
105 | 105 | try { |
106 | - $result = $this->connection->query('SELECT 1 FROM `'.self::SNAPSHOTS_TABLE.'` LIMIT 1'); |
|
106 | + $result = $this->connection->query('SELECT 1 FROM `' . self::SNAPSHOTS_TABLE . '` LIMIT 1'); |
|
107 | 107 | } catch (\Exception $e) { |
108 | 108 | return false; |
109 | 109 | } |