@@ -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 | } |