smi2 / phpClickHouse

src/Transport/Http.php

Spacing +17 added lines, -17 removed lines

@@ -120,10 +120,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;
@@ -195,7 +195,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;
@@ -248,7 +248,7 @@ 
     {
 
         if ($sql instanceof Query) {
-            $query=$sql;
+            $query = $sql;
         } else {
             $query = new Query($sql);
         }
@@ -610,10 +610,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();
 
 
 
@@ -624,11 +624,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);
                     };
                 }
@@ -663,7 +663,7 @@ 
             }
 
 
-            $this->_curler->execOne($request,true);
+            $this->_curler->execOne($request, true);
             $response = new Statement($request);
             if ($response->isError()) {
                 $response->error();
@@ -685,11 +685,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);
 
     }
 
@@ -700,10 +700,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/Client.php

Spacing +15 added lines, -15 removed lines

@@ -63,19 +63,19 @@ 
      */
     public function __construct(array $connectParams, array $settings = [])
     {
-        if (! isset($connectParams['username'])) {
+        if (!isset($connectParams['username'])) {
             throw  new \InvalidArgumentException('not set username');
         }
 
-        if (! isset($connectParams['password'])) {
+        if (!isset($connectParams['password'])) {
             throw  new \InvalidArgumentException('not set password');
         }
 
-        if (! isset($connectParams['port'])) {
+        if (!isset($connectParams['port'])) {
             throw  new \InvalidArgumentException('not set port');
         }
 
-        if (! isset($connectParams['host'])) {
+        if (!isset($connectParams['host'])) {
             throw  new \InvalidArgumentException('not set host');
         }
 
@@ -96,7 +96,7 @@ 
 
         // apply settings to transport class
         $this->settings()->database('default');
-        if (! empty($settings)) {
+        if (!empty($settings)) {
             $this->settings()->apply($settings);
         }
 
@@ -198,7 +198,7 @@ 
      */
     public function transport()
     {
-        if (! $this->transport) {
+        if (!$this->transport) {
             throw  new \InvalidArgumentException('Empty transport class');
         }
 
@@ -267,8 +267,8 @@ 
      */
     public function useSession(string $useSessionId = null)
     {
-        if (! $this->settings()->getSessionId()) {
-            if (! $useSessionId) {
+        if (!$this->settings()->getSessionId()) {
+            if (!$useSessionId) {
                 $this->settings()->makeSessionId();
             } else {
                 $this->settings()->session_id($useSessionId);
@@ -386,14 +386,14 @@ 
      */
     public function progressFunction(callable $callback)
     {
-        if (! is_callable($callback)) {
+        if (!is_callable($callback)) {
             throw new \InvalidArgumentException('Not is_callable progressFunction');
         }
 
-        if (! $this->settings()->is('send_progress_in_http_headers')) {
+        if (!$this->settings()->is('send_progress_in_http_headers')) {
             $this->settings()->set('send_progress_in_http_headers', 1);
         }
-        if (! $this->settings()->is('http_headers_progress_interval_ms')) {
+        if (!$this->settings()->is('http_headers_progress_interval_ms')) {
             $this->settings()->set('http_headers_progress_interval_ms', 100);
         }
 
@@ -574,14 +574,14 @@ 
             throw new QueryException('Queue must be empty, before insertBatch, need executeAsync');
         }
 
-        if (! in_array($format, self::SUPPORTED_FORMATS, true)) {
+        if (!in_array($format, self::SUPPORTED_FORMATS, true)) {
             throw new QueryException('Format not support in insertBatchFiles');
         }
 
         $result = [];
 
         foreach ($fileNames as $fileName) {
-            if (! is_file($fileName) || ! is_readable($fileName)) {
+            if (!is_file($fileName) || !is_readable($fileName)) {
                 throw  new QueryException('Cant read file: ' . $fileName . ' ' . (is_file($fileName) ? '' : ' is not file'));
             }
 
@@ -598,7 +598,7 @@ 
 
         // fetch resutl
         foreach ($fileNames as $fileName) {
-            if (! $result[$fileName]->isError()) {
+            if (!$result[$fileName]->isError()) {
                 continue;
             }
 
@@ -621,7 +621,7 @@ 
             throw new QueryException('Queue must be empty, before insertBatch, need executeAsync');
         }
 
-        if (! in_array($format, self::SUPPORTED_FORMATS, true)) {
+        if (!in_array($format, self::SUPPORTED_FORMATS, true)) {
             throw new QueryException('Format not support in insertBatchFiles');
         }
 

src/Query/Degeneration/Conditions.php

Spacing +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
         $markers = $this->bindings;
 
         // ------ if/else conditions & if[set|int]/else conditions -----
-        $sql = preg_replace_callback('#\{if(.{0,}?)\s+([^\}]+?)\}(.+?)(\{else\}([^\{]+?)?)?\s*\{\/if}#sui', function ($matches) use ($markers) {
+        $sql = preg_replace_callback('#\{if(.{0,}?)\s+([^\}]+?)\}(.+?)(\{else\}([^\{]+?)?)?\s*\{\/if}#sui', function($matches) use ($markers) {
             return self::__ifsets($matches, $markers);
         }
             , $sql);