smi2 / phpClickHouse

src/Query/Query.php

Spacing +6 added lines, -6 removed lines

@@ -22,7 +22,7 @@ 
      */
     private $degenerations = [];
 
-    private $supportFormats=[
+    private $supportFormats = [
         "FORMAT\\s+TSVRaw",
         "FORMAT\\s+TSVWithNamesAndTypes",
         "FORMAT\\s+TSVWithNames",
@@ -71,7 +71,7 @@ 
         if (null === $this->format) {
             return false;
         }
-        $supportFormats = implode("|",$this->supportFormats);
+        $supportFormats = implode("|", $this->supportFormats);
 
         $this->sql = trim($this->sql);
         if (substr($this->sql, -1) == ';') {
@@ -110,16 +110,16 @@ 
     public function isUseInUrlBindingsParams():bool
     {
         //  'query=select {p1:UInt8} + {p2:UInt8}' -F "param_p1=3" -F "param_p2=4"
-        return preg_match('#{[\w+]+:[\w+()]+}#',$this->sql);
+        return preg_match('#{[\w+]+:[\w+()]+}#', $this->sql);
 
     }
     public function getUrlBindingsParams():array
     {
-        $out=[];
+        $out = [];
         if (sizeof($this->degenerations)) {
             foreach ($this->degenerations as $degeneration) {
                 if ($degeneration instanceof Degeneration) {
-                    $params=$degeneration->getBind();
+                    $params = $degeneration->getBind();
                     break;
                     // need first response
                 }
@@ -128,7 +128,7 @@ 
         if (sizeof($params)) {
             foreach ($params as $key=>$value)
             {
-                $out['param_'.$key]=$value;
+                $out['param_' . $key] = $value;
             }
         }
         return $out;

src/Transport/Http.php

Spacing +7 added lines, -7 removed lines

@@ -266,7 +266,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;
@@ -301,7 +301,7 @@ 
          */
 
         if ($query->isUseInUrlBindingsParams()) {
-            $urlParams=array_replace_recursive($query->getUrlBindingsParams());
+            $urlParams = array_replace_recursive($query->getUrlBindingsParams());
         }
         $url = $this->getUrl($urlParams);
         $new->url($url);
@@ -322,7 +322,7 @@ 
     public function setStdErrOut($stream)
     {
         if (is_resource($stream)) {
-            $this->stdErrOut=$stream;
+            $this->stdErrOut = $stream;
         }
 
     }
@@ -391,7 +391,7 @@ 
 
         $request->url($url);
 
-        $request->setCallbackFunction(function (CurlerRequest $request) {
+        $request->setCallbackFunction(function(CurlerRequest $request) {
             $handle = $request->getInfileHandle();
             if (is_resource($handle)) {
                 fclose($handle);
@@ -524,7 +524,7 @@ 
                 }
 
 
-                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) {
+                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) {
                     fclose($request->getResultFileHandle());
                 });
             }
@@ -715,11 +715,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);
                     };
                 }