@@ -318,7 +318,7 @@ discard block |
||
| 318 | 318 | */ |
| 319 | 319 | public function enableLogQueries(bool $flag = true) |
| 320 | 320 | { |
| 321 | - $this->settings()->set('log_queries', (int)$flag); |
|
| 321 | + $this->settings()->set('log_queries', (int) $flag); |
|
| 322 | 322 | |
| 323 | 323 | return $this; |
| 324 | 324 | } |
@@ -354,7 +354,7 @@ discard block |
||
| 354 | 354 | */ |
| 355 | 355 | public function enableExtremes(bool $flag = true) |
| 356 | 356 | { |
| 357 | - $this->settings()->set('extremes', (int)$flag); |
|
| 357 | + $this->settings()->set('extremes', (int) $flag); |
|
| 358 | 358 | |
| 359 | 359 | return $this; |
| 360 | 360 | } |
@@ -778,7 +778,7 @@ discard block |
||
| 778 | 778 | public function partitions(string $table, int $limit = null, bool $active = null) |
| 779 | 779 | { |
| 780 | 780 | $database = $this->settings()->getDatabase(); |
| 781 | - $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int)$active); |
|
| 781 | + $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int) $active); |
|
| 782 | 782 | $limitClause = $limit !== null ? ' LIMIT ' . $limit : ''; |
| 783 | 783 | |
| 784 | 784 | return $this->select(<<<CLICKHOUSE |
@@ -842,7 +842,7 @@ discard block |
||
| 842 | 842 | */ |
| 843 | 843 | public function getServerVersion(): string |
| 844 | 844 | { |
| 845 | - return (string)$this->select('SELECT version() as version')->fetchOne('version'); |
|
| 845 | + return (string) $this->select('SELECT version() as version')->fetchOne('version'); |
|
| 846 | 846 | } |
| 847 | 847 | |
| 848 | 848 | /** |
@@ -221,7 +221,7 @@ discard block |
||
| 221 | 221 | } |
| 222 | 222 | |
| 223 | 223 | $new->timeOut($this->settings()->getTimeOut()); |
| 224 | - $new->connectTimeOut($this->_connectTimeOut);//->keepAlive(); // one sec |
|
| 224 | + $new->connectTimeOut($this->_connectTimeOut); //->keepAlive(); // one sec |
|
| 225 | 225 | $new->verbose(boolval($this->_verbose)); |
| 226 | 226 | |
| 227 | 227 | return $new; |
@@ -317,7 +317,7 @@ discard block |
||
| 317 | 317 | $request = $this->newRequest($extendinfo); |
| 318 | 318 | $request->url($url); |
| 319 | 319 | |
| 320 | - $request->setCallbackFunction(function (CurlerRequest $request) { |
|
| 320 | + $request->setCallbackFunction(function(CurlerRequest $request) { |
|
| 321 | 321 | $handle = $request->getInfileHandle(); |
| 322 | 322 | if (is_resource($handle)) { |
| 323 | 323 | fclose($handle); |
@@ -456,7 +456,7 @@ discard block |
||
| 456 | 456 | } |
| 457 | 457 | |
| 458 | 458 | |
| 459 | - $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) { |
|
| 459 | + $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) { |
|
| 460 | 460 | fclose($request->getResultFileHandle()); |
| 461 | 461 | }); |
| 462 | 462 | } |
@@ -643,11 +643,11 @@ discard block |
||
| 643 | 643 | if (!is_callable($callable)) { |
| 644 | 644 | if ($streamRW->isWrite()) { |
| 645 | 645 | |
| 646 | - $callable = function ($ch, $fd, $length) use ($stream) { |
|
| 646 | + $callable = function($ch, $fd, $length) use ($stream) { |
|
| 647 | 647 | return ($line = fread($stream, $length)) ? $line : ''; |
| 648 | 648 | }; |
| 649 | 649 | } else { |
| 650 | - $callable = function ($ch, $fd) use ($stream) { |
|
| 650 | + $callable = function($ch, $fd) use ($stream) { |
|
| 651 | 651 | return fwrite($stream, $fd); |
| 652 | 652 | }; |
| 653 | 653 | } |