smi2 / phpClickHouse

src/Statement.php

Spacing +9 added lines, -9 removed lines

@@ -83,7 +83,7 @@ 
     /**
      * @var int
      */
-    public $iterator=0;
+    public $iterator = 0;
 
 
     public function __construct(CurlerRequest $request)
@@ -221,15 +221,15 @@ 
             $this->_init = true;
             return false;
         }
-        $data=[];
+        $data = [];
         foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
 
             if (isset($this->_rawData[$key])) {
-                if ($key=='data')
+                if ($key == 'data')
                 {
-                    $data=$this->_rawData[$key];
+                    $data = $this->_rawData[$key];
                 }
-                else{
+                else {
                     $this->{$key} = $this->_rawData[$key];
                 }
 
@@ -240,7 +240,7 @@ 
             throw  new QueryException('Can`t find meta');
         }
 
-        $isJSONCompact=(stripos($this->format,'JSONCompact')!==false?true:false);
+        $isJSONCompact = (stripos($this->format, 'JSONCompact') !== false ?true:false);
         $this->array_data = [];
         foreach ($data as $rows) {
             $r = [];
@@ -248,7 +248,7 @@ 
 
             if ($isJSONCompact)
             {
-                $r[]=$rows;
+                $r[] = $rows;
             }
             else {
                 foreach ($this->meta as $meta) {
@@ -404,14 +404,14 @@ 
      */
     public function resetIterator()
     {
-        $this->iterator=0;
+        $this->iterator = 0;
     }
 
     public function fetchRow($key = null)
     {
         $this->init();
 
-        $position=$this->iterator;
+        $position = $this->iterator;
 
         if (!isset($this->array_data[$position])) {
             return null;

Braces +5 added lines, -5 removed lines

@@ -228,8 +228,7 @@ 
                 if ($key=='data')
                 {
                     $data=$this->_rawData[$key];
-                }
-                else{
+                } else{
                     $this->{$key} = $this->_rawData[$key];
                 }
 
@@ -249,8 +248,7 @@ 
             if ($isJSONCompact)
             {
                 $r[]=$rows;
-            }
-            else {
+            } else {
                 foreach ($this->meta as $meta) {
                     $r[$meta['name']] = $rows[$meta['name']];
                 }
@@ -364,7 +362,9 @@ 
             return null;
         }
 
-        if (!$key) return $this->statistics;
+        if (!$key) {
+            return $this->statistics;
+        }
 
         if (!isset($this->statistics[$key])) {
             return null;

src/Client.php

Spacing +4 added lines, -4 removed lines

@@ -318,7 +318,7 @@ 
      */
     public function enableLogQueries(bool $flag = true)
     {
-        $this->settings()->set('log_queries', (int)$flag);
+        $this->settings()->set('log_queries', (int) $flag);
 
         return $this;
     }
@@ -354,7 +354,7 @@ 
      */
     public function enableExtremes(bool $flag = true)
     {
-        $this->settings()->set('extremes', (int)$flag);
+        $this->settings()->set('extremes', (int) $flag);
 
         return $this;
     }
@@ -778,7 +778,7 @@ 
     public function partitions(string $table, int $limit = null, bool $active = null)
     {
         $database = $this->settings()->getDatabase();
-        $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int)$active);
+        $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int) $active);
         $limitClause = $limit !== null ? ' LIMIT ' . $limit : '';
 
         return $this->select(<<<CLICKHOUSE
@@ -842,7 +842,7 @@ 
      */
     public function getServerVersion(): string
     {
-        return (string)$this->select('SELECT version() as version')->fetchOne('version');
+        return (string) $this->select('SELECT version() as version')->fetchOne('version');
     }
 
     /**

src/Transport/Http.php

Spacing +5 added lines, -5 removed lines

@@ -221,7 +221,7 @@ 
         }
 
         $new->timeOut($this->settings()->getTimeOut());
-        $new->connectTimeOut($this->_connectTimeOut);//->keepAlive(); // one sec
+        $new->connectTimeOut($this->_connectTimeOut); //->keepAlive(); // one sec
         $new->verbose(boolval($this->_verbose));
 
         return $new;
@@ -317,7 +317,7 @@ 
         $request = $this->newRequest($extendinfo);
         $request->url($url);
 
-        $request->setCallbackFunction(function (CurlerRequest $request) {
+        $request->setCallbackFunction(function(CurlerRequest $request) {
             $handle = $request->getInfileHandle();
             if (is_resource($handle)) {
                 fclose($handle);
@@ -456,7 +456,7 @@ 
                 }
 
 
-                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) {
+                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) {
                     fclose($request->getResultFileHandle());
                 });
             }
@@ -643,11 +643,11 @@ 
             if (!is_callable($callable)) {
                 if ($streamRW->isWrite()) {
 
-                    $callable = function ($ch, $fd, $length) use ($stream) {
+                    $callable = function($ch, $fd, $length) use ($stream) {
                         return ($line = fread($stream, $length)) ? $line : '';
                     };
                 } else {
-                    $callable = function ($ch, $fd) use ($stream) {
+                    $callable = function($ch, $fd) use ($stream) {
                         return fwrite($stream, $fd);
                     };
                 }

Braces +3 added lines, -2 removed lines

@@ -685,8 +685,9 @@
             }
             return $response;
         } finally {
-            if ($streamRW->isWrite())
-                fclose($stream);
+            if ($streamRW->isWrite()) {
+                            fclose($stream);
+            }
         }