smi2 / phpClickHouse

src/Transport/CurlerRolling.php

Spacing +6 added lines, -6 removed lines

@@ -144,22 +144,22 @@
     public function execLoopWait()
     {
         $c = 0;
-        $timeStart=time();
-        $uSleep=1000; // Timer: check response from server, and add new Task/Que to loop
-        $PendingAllConnections=$this->countPending();
+        $timeStart = time();
+        $uSleep = 1000; // Timer: check response from server, and add new Task/Que to loop
+        $PendingAllConnections = $this->countPending();
 
         // Max loop check
 
-        $count=0;
+        $count = 0;
         // add all tasks
         do {
             $this->exec();
-            $timeWork=time()-$timeStart;
+            $timeWork = time() - $timeStart;
             //
             $ActiveNowConnections = $this->countActive();
             $PendingNowConnections = $this->countPending();
 
-            $count=$ActiveNowConnections+$PendingNowConnections;
+            $count = $ActiveNowConnections + $PendingNowConnections;
             $c++;
 
             if ($c > 20000) {

src/Query/Query.php

Spacing +2 added lines, -2 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);
 
         $matches = [];
         if (preg_match_all('%(' . $supportFormats . ')%ius', $this->sql, $matches)) {

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