smi2 / phpClickHouse

src/Cluster.php

Braces +2 added lines, -2 removed lines

@@ -277,7 +277,7 @@ 
                     $tables[$row['database']][$row['table']][$node] = $row;
                 }
                 $result['replicas'][$node] = $r;
-            }catch (\Exception $E) {
+            } catch (\Exception $E) {
                 $result['replicas'][$node] = false;
                 $badNodes[$node] = $E->getMessage();
                 $this->error[] = 'statementsReplicas:' . $E->getMessage();
@@ -299,7 +299,7 @@ 
                         ];
                 }
 
-            }catch (\Exception $E) {
+            } catch (\Exception $E) {
                 $result['clusters'][$node] = false;
 
                 $this->error[] = 'clusters:' . $E->getMessage();

src/Transport/StreamWrite.php

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
 class StreamWrite extends Stream
 {
 
-    public function __construct( $source)
+    public function __construct($source)
     {
 
         parent::__construct($source);

src/Transport/StreamInsert.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
      * @param CurlerRequest $request
      * @param CurlerRolling|null $curlerRolling
      */
-    public function __construct($source, CurlerRequest $request, $curlerRolling=null)
+    public function __construct($source, CurlerRequest $request, $curlerRolling = null)
     {
         if (!is_resource($source)) {
             throw new \InvalidArgumentException('Argument $source must be resource');

src/Transport/CurlerResponse.php

Spacing +1 added lines, -1 removed lines

@@ -293,7 +293,7 @@
 
         if (stripos($format, 'json') !== false)
         {
-            if (stripos($format,'JSONEachRow')===false)
+            if (stripos($format, 'JSONEachRow') === false)
             return $this->json();
         }
         return $this->body();

Braces +3 added lines, -2 removed lines

@@ -293,8 +293,9 @@
 
         if (stripos($format, 'json') !== false)
         {
-            if (stripos($format,'JSONEachRow')===false)
-            return $this->json();
+            if (stripos($format,'JSONEachRow')===false) {
+                        return $this->json();
+            }
         }
         return $this->body();
 

src/Transport/Http.php

Braces +3 added lines, -2 removed lines

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

Spacing +19 added lines, -19 removed lines

@@ -92,8 +92,8 @@ 
     /**
      * @param CurlerRolling $curler
      */
-    public function setDirtyCurler(CurlerRolling $curler){
-        if ($curler instanceof  CurlerRolling){
+    public function setDirtyCurler(CurlerRolling $curler) {
+        if ($curler instanceof  CurlerRolling) {
             $this->_curler = $curler;
         }
     }
@@ -129,10 +129,10 @@ 
             $proto = 'https';
         }
         $uri = $proto . '://' . $this->_host;
-        if (stripos($this->_host,'/')!==false || stripos($this->_host,':')!==false) {
+        if (stripos($this->_host, '/') !== false || stripos($this->_host, ':') !== false) {
             return $uri;
         }
-        if (intval($this->_port)>0) {
+        if (intval($this->_port) > 0) {
             return $uri . ':' . $this->_port;
         }
         return $uri;
@@ -204,7 +204,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;
@@ -257,7 +257,7 @@ 
     {
 
         if ($sql instanceof Query) {
-            $query=$sql;
+            $query = $sql;
         } else {
             $query = new Query($sql);
         }
@@ -619,10 +619,10 @@ 
      * @return Statement
      * @throws \ClickHouseDB\Exception\TransportException
      */
-    private function streaming(Stream $streamRW,CurlerRequest $request)
+    private function streaming(Stream $streamRW, CurlerRequest $request)
     {
-        $callable=$streamRW->getClosure();
-        $stream=$streamRW->getStream();
+        $callable = $streamRW->getClosure();
+        $stream = $streamRW->getStream();
 
 
 
@@ -633,11 +633,11 @@ 
                 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);
                     };
                 }
@@ -672,7 +672,7 @@ 
             }
 
 
-            $this->_curler->execOne($request,true);
+            $this->_curler->execOne($request, true);
             $response = new Statement($request);
             if ($response->isError()) {
                 $response->error();
@@ -694,11 +694,11 @@ 
      * @return Statement
      * @throws \ClickHouseDB\Exception\TransportException
      */
-    public function streamRead(Stream $streamRead,$sql,$bindings=[])
+    public function streamRead(Stream $streamRead, $sql, $bindings = [])
     {
-        $sql=$this->prepareQuery($sql,$bindings);
-        $request=$this->getRequestRead($sql);
-        return $this->streaming($streamRead,$request);
+        $sql = $this->prepareQuery($sql, $bindings);
+        $request = $this->getRequestRead($sql);
+        return $this->streaming($streamRead, $request);
 
     }
 
@@ -709,10 +709,10 @@ 
      * @return Statement
      * @throws \ClickHouseDB\Exception\TransportException
      */
-    public function streamWrite(Stream $streamWrite,$sql,$bindings=[])
+    public function streamWrite(Stream $streamWrite, $sql, $bindings = [])
     {
-        $sql=$this->prepareQuery($sql,$bindings);
+        $sql = $this->prepareQuery($sql, $bindings);
         $request = $this->writeStreamData($sql);
-        return $this->streaming($streamWrite,$request);
+        return $this->streaming($streamWrite, $request);
     }
 }

src/Transport/Stream.php

Spacing +4 added lines, -4 removed lines

@@ -15,11 +15,11 @@ 
     /**
      * @var bool
      */
-    private $gzip=false;
+    private $gzip = false;
     /**
      * @var null|callable
      */
-    private $callable=null;
+    private $callable = null;
     /**
      * @param resource $source
      */
@@ -60,7 +60,7 @@ 
      */
     public function closure(callable $callable)
     {
-        $this->callable=$callable;
+        $this->callable = $callable;
     }
 
     /**
@@ -68,7 +68,7 @@ 
      */
     public function enableGzipHeader()
     {
-        $this->gzip=true;
+        $this->gzip = true;
     }
 
 }

src/Query/Degeneration/Bindings.php

Spacing +10 added lines, -10 removed lines

@@ -56,10 +56,10 @@ 
      * @param string $pattern
      * @return string
      */
-    public function compile_binds($sql, $binds,$pattern)
+    public function compile_binds($sql, $binds, $pattern)
     {
         return preg_replace_callback($pattern, function($m) use ($binds){
-            if(isset($binds[$m[1]])){ // If it exists in our array
+            if (isset($binds[$m[1]])) { // If it exists in our array
                 return $binds[$m[1]]; // Then replace it from our array
             }
 
@@ -75,14 +75,14 @@ 
      */
     public function process($sql)
     {
-        $bindFormatted=[];
-        $bindRaw=[];
+        $bindFormatted = [];
+        $bindRaw = [];
         foreach ($this->bindings as $key => $value) {
             if (is_array($value)) {
                 $valueSet = implode(', ', $value);
 
                 $values = array_map(
-                    function ($value) {
+                    function($value) {
                         return ValueFormatter::formatValue($value);
                     },
                     $value
@@ -95,21 +95,21 @@ 
             }
 
             if ($formattedParameter !== null) {
-                $bindFormatted[$key]=$formattedParameter;
+                $bindFormatted[$key] = $formattedParameter;
             }
 
             if ($valueSet !== null) {
-                $bindRaw[$key]=$valueSet;
+                $bindRaw[$key] = $valueSet;
             }
         }
 
-        for ($loop=0;$loop<2;$loop++)
+        for ($loop = 0; $loop < 2; $loop++)
         {
             // dipping in binds
             // example ['A' => '{B}' , 'B'=>':C','C'=>123]
-            $sql=$this->compile_binds($sql,$bindRaw,'#{([\w+]+)}#');
+            $sql = $this->compile_binds($sql, $bindRaw, '#{([\w+]+)}#');
         }
-        $sql=$this->compile_binds($sql,$bindFormatted,'#:([\w+]+)#');
+        $sql = $this->compile_binds($sql, $bindFormatted, '#:([\w+]+)#');
 
         return $sql;
     }

src/Quote/StrictQuoteLine.php

Spacing +2 added lines, -2 removed lines

@@ -80,8 +80,8 @@
                 // Elements of the array - the numbers are formatted as usual, and the dates, dates-with-time, and lines are in
                 // single quotation marks with the same screening rules as above.
                 // as in the TabSeparated format, and then the resulting string is output in InsertRow in double quotes.
-                $value       = array_map(
-                    function ($v) use ($enclosure_esc, $encode_esc) {
+                $value = array_map(
+                    function($v) use ($enclosure_esc, $encode_esc) {
                         return is_string($v) ? $this->encodeString($v, $enclosure_esc, $encode_esc) : $v;
                     },
                     $value

src/Transport/CurlerRequest.php

Spacing +3 added lines, -3 removed lines

@@ -237,7 +237,7 @@ 
      */
     public function setWriteFunction($callback)
     {
-        $this->options[CURLOPT_WRITEFUNCTION]=$callback;
+        $this->options[CURLOPT_WRITEFUNCTION] = $callback;
     }
     /**
      * @param callable $callback
@@ -612,7 +612,7 @@ 
      */
     public function response()
     {
-        if (! $this->response) {
+        if (!$this->response) {
             throw new \ClickHouseDB\Exception\TransportException('Can`t fetch response - is empty');
         }
 
@@ -708,7 +708,7 @@ 
 
         if (!empty($curl_opt[CURLOPT_WRITEFUNCTION]))
         {
-            $curl_opt[CURLOPT_HEADER]=false;
+            $curl_opt[CURLOPT_HEADER] = false;
         }
 
         if ($this->resultFileHandle) {