@@ -115,14 +115,14 @@ discard block |
||
| 115 | 115 | public function getPrimary(string $prefix, string $table): string |
| 116 | 116 | { |
| 117 | 117 | if (!empty($this->memory) && empty($this->primaryKeys)) { |
| 118 | - $this->primaryKeys = (array)$this->memory->loadData($this->getSource() . '.keys'); |
|
| 118 | + $this->primaryKeys = (array)$this->memory->loadData($this->getSource().'.keys'); |
|
| 119 | 119 | } |
| 120 | 120 | |
| 121 | 121 | if (!empty($this->primaryKeys) && array_key_exists($table, $this->primaryKeys)) { |
| 122 | 122 | return $this->primaryKeys[$table]; |
| 123 | 123 | } |
| 124 | 124 | |
| 125 | - if (!$this->hasTable($prefix . $table)) { |
|
| 125 | + if (!$this->hasTable($prefix.$table)) { |
|
| 126 | 126 | throw new DriverException( |
| 127 | 127 | "Unable to fetch table primary key, no such table '{$prefix}{$table}' exists" |
| 128 | 128 | ); |
@@ -138,7 +138,7 @@ discard block |
||
| 138 | 138 | |
| 139 | 139 | //Caching |
| 140 | 140 | if (!empty($this->memory)) { |
| 141 | - $this->memory->saveData($this->getSource() . ',keys', $this->primaryKeys); |
|
| 141 | + $this->memory->saveData($this->getSource().',keys', $this->primaryKeys); |
|
| 142 | 142 | } |
| 143 | 143 | |
| 144 | 144 | return $this->primaryKeys[$table]; |
@@ -153,7 +153,7 @@ discard block |
||
| 153 | 153 | { |
| 154 | 154 | return $this->factory->make( |
| 155 | 155 | PostgresQuery::class, |
| 156 | - ['driver' => $this, 'compiler' => $this->queryCompiler($prefix),] + $parameters |
|
| 156 | + ['driver' => $this, 'compiler' => $this->queryCompiler($prefix), ] + $parameters |
|
| 157 | 157 | ); |
| 158 | 158 | } |
| 159 | 159 | |
@@ -322,7 +322,7 @@ discard block |
||
| 322 | 322 | $this->logger()->info("Creating savepoint '{$name}'"); |
| 323 | 323 | } |
| 324 | 324 | |
| 325 | - $this->statement('SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 325 | + $this->statement('SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 326 | 326 | } |
| 327 | 327 | |
| 328 | 328 | /** |
@@ -339,7 +339,7 @@ discard block |
||
| 339 | 339 | $this->logger()->info("Releasing savepoint '{$name}'"); |
| 340 | 340 | } |
| 341 | 341 | |
| 342 | - $this->statement('RELEASE SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 342 | + $this->statement('RELEASE SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 343 | 343 | } |
| 344 | 344 | |
| 345 | 345 | /** |
@@ -355,6 +355,6 @@ discard block |
||
| 355 | 355 | if ($this->isProfiling()) { |
| 356 | 356 | $this->logger()->info("Rolling back savepoint '{$name}'"); |
| 357 | 357 | } |
| 358 | - $this->statement('ROLLBACK TO SAVEPOINT ' . $this->identifier("SVP{$name}")); |
|
| 358 | + $this->statement('ROLLBACK TO SAVEPOINT '.$this->identifier("SVP{$name}")); |
|
| 359 | 359 | } |
| 360 | 360 | } |
@@ -255,7 +255,7 @@ |
||
| 255 | 255 | */ |
| 256 | 256 | public function identifier(string $identifier): string |
| 257 | 257 | { |
| 258 | - return $identifier == '*' ? '*' : '"' . str_replace('"', '""', $identifier) . '"'; |
|
| 258 | + return $identifier == '*' ? '*' : '"'.str_replace('"', '""', $identifier).'"'; |
|
| 259 | 259 | } |
| 260 | 260 | |
| 261 | 261 | /** |
@@ -288,8 +288,8 @@ discard block |
||
| 288 | 288 | bool $unique = true, |
| 289 | 289 | bool $resetState = false |
| 290 | 290 | ): AbstractTable { |
| 291 | - if (isset($this->tables[$database . '.table'])) { |
|
| 292 | - $schema = $this->tables[$database . '.table']; |
|
| 291 | + if (isset($this->tables[$database.'.table'])) { |
|
| 292 | + $schema = $this->tables[$database.'.table']; |
|
| 293 | 293 | |
| 294 | 294 | if ($unique) { |
| 295 | 295 | throw new DoubleReferenceException( |
@@ -299,7 +299,7 @@ discard block |
||
| 299 | 299 | } else { |
| 300 | 300 | //Requesting thought DatabaseManager |
| 301 | 301 | $schema = $this->manager->database($database)->table($table)->getSchema(); |
| 302 | - $this->tables[$database . '.' . $table] = $schema; |
|
| 302 | + $this->tables[$database.'.'.$table] = $schema; |
|
| 303 | 303 | } |
| 304 | 304 | |
| 305 | 305 | $schema = clone $schema; |
@@ -320,7 +320,7 @@ discard block |
||
| 320 | 320 | */ |
| 321 | 321 | protected function pushTable(AbstractTable $table, string $database = null) |
| 322 | 322 | { |
| 323 | - $this->tables[$database . '.' . $table->getName()] = $table; |
|
| 323 | + $this->tables[$database.'.'.$table->getName()] = $table; |
|
| 324 | 324 | |
| 325 | 325 | } |
| 326 | 326 | } |
| 327 | 327 | \ No newline at end of file |
@@ -136,8 +136,8 @@ |
||
| 136 | 136 | * |
| 137 | 137 | * @see Record::$indexes |
| 138 | 138 | */ |
| 139 | - const INDEX = 1000; //Default index type |
|
| 140 | - const UNIQUE = 2000; //Unique index definition |
|
| 139 | + const INDEX = 1000; //Default index type |
|
| 140 | + const UNIQUE = 2000; //Unique index definition |
|
| 141 | 141 | |
| 142 | 142 | /** |
| 143 | 143 | * Errors in relations and acessors. |
@@ -92,6 +92,6 @@ |
||
| 92 | 92 | throw new SchemaException('MySQL commander can process only MySQL tables'); |
| 93 | 93 | } |
| 94 | 94 | |
| 95 | - return parent::createStatement($table) . " ENGINE {$table->getEngine()}"; |
|
| 95 | + return parent::createStatement($table)." ENGINE {$table->getEngine()}"; |
|
| 96 | 96 | } |
| 97 | 97 | } |
@@ -21,7 +21,7 @@ discard block |
||
| 21 | 21 | */ |
| 22 | 22 | public function getName(): string |
| 23 | 23 | { |
| 24 | - return $this->tablePrefix . $this->table . '_' . $this->column . '_fk'; |
|
| 24 | + return $this->tablePrefix.$this->table.'_'.$this->column.'_fk'; |
|
| 25 | 25 | } |
| 26 | 26 | |
| 27 | 27 | /** |
@@ -32,10 +32,10 @@ discard block |
||
| 32 | 32 | $statement = []; |
| 33 | 33 | |
| 34 | 34 | $statement[] = 'FOREIGN KEY'; |
| 35 | - $statement[] = '(' . $driver->identifier($this->column) . ')'; |
|
| 35 | + $statement[] = '('.$driver->identifier($this->column).')'; |
|
| 36 | 36 | |
| 37 | - $statement[] = 'REFERENCES ' . $driver->identifier($this->foreignTable); |
|
| 38 | - $statement[] = '(' . $driver->identifier($this->foreignKey) . ')'; |
|
| 37 | + $statement[] = 'REFERENCES '.$driver->identifier($this->foreignTable); |
|
| 38 | + $statement[] = '('.$driver->identifier($this->foreignKey).')'; |
|
| 39 | 39 | |
| 40 | 40 | $statement[] = "ON DELETE {$this->deleteRule}"; |
| 41 | 41 | $statement[] = "ON UPDATE {$this->updateRule}"; |
@@ -637,7 +637,7 @@ discard block |
||
| 637 | 637 | */ |
| 638 | 638 | public function __toString() |
| 639 | 639 | { |
| 640 | - return $this->table . '.' . $this->getName(); |
|
| 640 | + return $this->table.'.'.$this->getName(); |
|
| 641 | 641 | } |
| 642 | 642 | |
| 643 | 643 | /** |
@@ -695,7 +695,7 @@ discard block |
||
| 695 | 695 | } |
| 696 | 696 | |
| 697 | 697 | if (!empty($enumValues)) { |
| 698 | - return '(' . implode(', ', $enumValues) . ')'; |
|
| 698 | + return '('.implode(', ', $enumValues).')'; |
|
| 699 | 699 | } |
| 700 | 700 | |
| 701 | 701 | return ''; |