@@ -38,7 +38,7 @@ discard block |
||
| 38 | 38 | */ |
| 39 | 39 | class Client |
| 40 | 40 | { |
| 41 | - const SUPPORTED_FORMATS = ['TabSeparated', 'TabSeparatedWithNames', 'CSV', 'CSVWithNames', 'JSONEachRow','CSVWithNamesAndTypes','TSVWithNamesAndTypes']; |
|
| 41 | + const SUPPORTED_FORMATS = ['TabSeparated', 'TabSeparatedWithNames', 'CSV', 'CSVWithNames', 'JSONEachRow', 'CSVWithNamesAndTypes', 'TSVWithNamesAndTypes']; |
|
| 42 | 42 | |
| 43 | 43 | /** @var Http */ |
| 44 | 44 | private $transport; |
@@ -344,7 +344,7 @@ discard block |
||
| 344 | 344 | */ |
| 345 | 345 | public function enableLogQueries(bool $flag = true) |
| 346 | 346 | { |
| 347 | - $this->settings()->set('log_queries', (int)$flag); |
|
| 347 | + $this->settings()->set('log_queries', (int) $flag); |
|
| 348 | 348 | |
| 349 | 349 | return $this; |
| 350 | 350 | } |
@@ -380,7 +380,7 @@ discard block |
||
| 380 | 380 | */ |
| 381 | 381 | public function enableExtremes(bool $flag = true) |
| 382 | 382 | { |
| 383 | - $this->settings()->set('extremes', (int)$flag); |
|
| 383 | + $this->settings()->set('extremes', (int) $flag); |
|
| 384 | 384 | |
| 385 | 385 | return $this; |
| 386 | 386 | } |
@@ -743,9 +743,9 @@ discard block |
||
| 743 | 743 | * @return bool |
| 744 | 744 | * @throws TransportException |
| 745 | 745 | */ |
| 746 | - public function ping(bool $throwException=false): bool |
|
| 746 | + public function ping(bool $throwException = false): bool |
|
| 747 | 747 | { |
| 748 | - $result=$this->transport()->ping(); |
|
| 748 | + $result = $this->transport()->ping(); |
|
| 749 | 749 | if ($throwException && !$result) throw new TransportException('Can`t ping server'); |
| 750 | 750 | return $result; |
| 751 | 751 | } |
@@ -814,7 +814,7 @@ discard block |
||
| 814 | 814 | public function partitions(string $table, int $limit = null, bool $active = null) |
| 815 | 815 | { |
| 816 | 816 | $database = $this->settings()->getDatabase(); |
| 817 | - $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int)$active); |
|
| 817 | + $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int) $active); |
|
| 818 | 818 | $limitClause = $limit !== null ? ' LIMIT ' . $limit : ''; |
| 819 | 819 | |
| 820 | 820 | return $this->select(<<<CLICKHOUSE |
@@ -885,7 +885,7 @@ discard block |
||
| 885 | 885 | */ |
| 886 | 886 | public function getServerVersion(): string |
| 887 | 887 | { |
| 888 | - return (string)$this->select('SELECT version() as version')->fetchOne('version'); |
|
| 888 | + return (string) $this->select('SELECT version() as version')->fetchOne('version'); |
|
| 889 | 889 | } |
| 890 | 890 | |
| 891 | 891 | /** |