smi2 / phpClickHouse

src/Client.php

Spacing +10 added lines, -10 removed lines

@@ -81,7 +81,7 @@ 
         $this->transport->addQueryDegeneration(new Bindings());
 
         // apply settings to transport class
-        if (! empty($settings)) {
+        if (!empty($settings)) {
             $this->getSettings()->apply($settings);
         }
 
@@ -195,8 +195,8 @@ 
      */
     public function useSession(bool $useSessionId = false)
     {
-        if (! $this->getSettings()->getSessionId()) {
-            if (! $useSessionId) {
+        if (!$this->getSettings()->getSessionId()) {
+            if (!$useSessionId) {
                 $this->getSettings()->makeSessionId();
             } else {
                 $this->getSettings()->session_id($useSessionId);
@@ -322,14 +322,14 @@ 
      */
     public function progressFunction(callable $callback)
     {
-        if (! is_callable($callback)) {
+        if (!is_callable($callback)) {
             throw new \InvalidArgumentException('Not is_callable progressFunction');
         }
 
-        if (! $this->getSettings()->isSet('send_progress_in_http_headers')) {
+        if (!$this->getSettings()->isSet('send_progress_in_http_headers')) {
             $this->getSettings()->set('send_progress_in_http_headers', 1);
         }
-        if (! $this->getSettings()->isSet('http_headers_progress_interval_ms')) {
+        if (!$this->getSettings()->isSet('http_headers_progress_interval_ms')) {
             $this->getSettings()->set('http_headers_progress_interval_ms', 100);
         }
 
@@ -463,14 +463,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'));
             }
 
@@ -487,7 +487,7 @@ 
 
         // fetch resutl
         foreach ($fileNames as $fileName) {
-            if (! $result[$fileName]->isError()) {
+            if (!$result[$fileName]->isError()) {
                 continue;
             }
 
@@ -510,7 +510,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/Settings.php

Spacing +3 added lines, -3 removed lines

@@ -18,7 +18,7 @@ 
      */
     public function get(string $key)
     {
-        if (! $this->isSet($key)) {
+        if (!$this->isSet($key)) {
             return null;
         }
 
@@ -100,7 +100,7 @@ 
     public function getQueryableSettings(array $forcedSettings) : array
     {
         $settings = $this->settings;
-        if (! empty($forcedSettings)) {
+        if (!empty($forcedSettings)) {
             $settings = $forcedSettings + $this->settings;
         }
 
@@ -126,7 +126,7 @@ 
      */
     public function getSetting($name)
     {
-        if (! isset($this->settings[$name])) {
+        if (!isset($this->settings[$name])) {
             return null;
         }
 

src/Transport/Http.php

Spacing +10 added lines, -10 removed lines

@@ -220,7 +220,7 @@ 
         $new = $this->newRequest($extendinfo);
         $new->url($url);
 
-        if (! $query_as_string) {
+        if (!$query_as_string) {
             $new->parameters_json($sql);
         }
         if ($this->getSettings()->isHttpCompressionEnabled()) {
@@ -281,7 +281,7 @@ 
         $request = $this->newRequest($extendinfo);
         $request->url($url);
 
-        $request->setCallbackFunction(function (CurlerRequest $request) {
+        $request->setCallbackFunction(function(CurlerRequest $request) {
             $handle = $request->getInfileHandle();
             if (is_resource($handle)) {
                 fclose($handle);
@@ -338,17 +338,17 @@ 
         if ($code == 200) {
             $response    = curl_multi_getcontent($handle);
             $header_size = curl_getinfo($handle, CURLINFO_HEADER_SIZE);
-            if (! $header_size) {
+            if (!$header_size) {
                 return false;
             }
 
             $header = substr($response, 0, $header_size);
-            if (! $header_size) {
+            if (!$header_size) {
                 return false;
             }
             $pos = strrpos($header, 'X-ClickHouse-Progress');
 
-            if (! $pos) {
+            if (!$pos) {
                 return false;
             }
 
@@ -413,13 +413,13 @@ 
                     fwrite($fout, "\x1f\x8b\x08\x00\x00\x00\x00\x00");
                 }
 
-                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) {
+                $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) {
                     fclose($request->getResultFileHandle());
                 });
             }
         }
         if ($this->xClickHouseProgress !== null) {
-            $request->setFunctionProgress(function ($x) {
+            $request->setFunctionProgress(function($x) {
                 return $this->findXClickHouseProgress($x);
             });
         }
@@ -594,14 +594,14 @@ 
 
         try {
 
-            if (! is_callable($callable)) {
+            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);
                     };
                 }

Braces +3 added lines, -2 removed lines

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