smi2 / phpClickHouse

src/Transport/Http.php

Spacing +5 added lines, -5 removed lines

@@ -260,7 +260,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;
@@ -371,7 +371,7 @@ 
 
         $request->url($url);
 
-        $request->setCallbackFunction(function (CurlerRequest $request) {
+        $request->setCallbackFunction(function(CurlerRequest $request) {
             $handle = $request->getInfileHandle();
             if (is_resource($handle)) {
                 fclose($handle);
@@ -510,7 +510,7 @@ 
                 }
 
 
-                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) {
+                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) {
                     fclose($request->getResultFileHandle());
                 });
             }
@@ -697,11 +697,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);
                     };
                 }

src/Transport/CurlerRolling.php

Spacing +4 added lines, -4 removed lines

@@ -290,9 +290,9 @@ 
 
 
             if (is_object($done['handle'])) {
-                $key = spl_object_id( $done['handle'] );
+                $key = spl_object_id($done['handle']);
             } else {
-                $key = (string) $done['handle'] ;
+                $key = (string) $done['handle'];
             }
 
             $task_id = $this->handleMapTasks[$key];
@@ -374,9 +374,9 @@ 
         curl_multi_add_handle($this->handlerMulti(), $h);
 
         if (is_object($h)) {
-            $key = spl_object_id( $h );
+            $key = spl_object_id($h);
         } else {
-            $key = (string) $h ;
+            $key = (string) $h;
         }
 
         $this->handleMapTasks[$key] = $task_id;

src/Transport/CurlerRequest.php

Spacing +1 added lines, -1 removed lines

@@ -719,7 +719,7 @@
                 $curl_opt[CURLOPT_POSTFIELDS] = $this->parameters;
 
                 if (!is_array($this->parameters)) {
-                    $this->header('Content-Length',  mb_strlen($this->parameters, '8bit'));
+                    $this->header('Content-Length', mb_strlen($this->parameters, '8bit'));
                 }
             }
         }

src/Statement.php

Spacing +5 added lines, -5 removed lines

@@ -245,8 +245,8 @@ 
         foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
 
             if (isset($this->_rawData[$key])) {
-                if ($key=='data') {
-                    $data=$this->_rawData[$key];
+                if ($key == 'data') {
+                    $data = $this->_rawData[$key];
                 } else {
                     $this->{$key} = $this->_rawData[$key];
                 }
@@ -257,7 +257,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 = [];
@@ -419,14 +419,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;