smi2 / phpClickHouse

src/Transport/Http.php

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);
     }
 }