smi2 / phpClickHouse

src/Transport/CurlerRolling.php

Spacing +4 added lines, -4 removed lines

@@ -290,9 +290,9 @@ 
 
 
             if (is_object($done['handle'])) {
-                $key = spl_object_id( $done['handle'] );
+                $key = spl_object_id($done['handle']);
             } else {
-                $key = (string) $done['handle'] ;
+                $key = (string) $done['handle'];
             }
 
             $task_id = $this->handleMapTasks[$key];
@@ -374,9 +374,9 @@ 
         curl_multi_add_handle($this->handlerMulti(), $h);
 
         if (is_object($h)) {
-            $key = spl_object_id( $h );
+            $key = spl_object_id($h);
         } else {
-            $key = (string) $h ;
+            $key = (string) $h;
         }
 
         $this->handleMapTasks[$key] = $task_id;

src/Statement.php

Spacing +5 added lines, -5 removed lines

@@ -245,8 +245,8 @@ 
         foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
 
             if (isset($this->_rawData[$key])) {
-                if ($key=='data') {
-                    $data=$this->_rawData[$key];
+                if ($key == 'data') {
+                    $data = $this->_rawData[$key];
                 } else {
                     $this->{$key} = $this->_rawData[$key];
                 }
@@ -257,7 +257,7 @@ 
             throw new QueryException('Can`t find meta');
         }
 
-        $isJSONCompact=(stripos($this->format,'JSONCompact')!==false?true:false);
+        $isJSONCompact = (stripos($this->format, 'JSONCompact') !== false ?true:false);
         $this->array_data = [];
         foreach ($data as $rows) {
             $r = [];
@@ -419,14 +419,14 @@ 
      */
     public function resetIterator()
     {
-        $this->iterator=0;
+        $this->iterator = 0;
     }
 
     public function fetchRow($key = null)
     {
         $this->init();
 
-        $position=$this->iterator;
+        $position = $this->iterator;
 
         if (!isset($this->array_data[$position])) {
             return null;

Braces +3 added lines, -1 removed lines

@@ -379,7 +379,9 @@
             return null;
         }
 
-        if (!$key) return $this->statistics;
+        if (!$key) {
+            return $this->statistics;
+        }
 
         if (!isset($this->statistics[$key])) {
             return null;

Indentation +1 added lines, -1 removed lines

@@ -536,7 +536,7 @@
 
     /**
      * @return false|string
-    */
+     */
     public function jsonRows()
     {
         return json_encode($this->rows(), JSON_PRETTY_PRINT);

src/Client.php

Spacing +6 added lines, -6 removed lines

@@ -341,7 +341,7 @@ 
      */
     public function enableLogQueries(bool $flag = true)
     {
-        $this->settings()->set('log_queries', (int)$flag);
+        $this->settings()->set('log_queries', (int) $flag);
 
         return $this;
     }
@@ -377,7 +377,7 @@ 
      */
     public function enableExtremes(bool $flag = true)
     {
-        $this->settings()->set('extremes', (int)$flag);
+        $this->settings()->set('extremes', (int) $flag);
 
         return $this;
     }
@@ -740,9 +740,9 @@ 
      * @return bool
      * @throws TransportException
      */
-    public function ping(bool $throwException=false): bool
+    public function ping(bool $throwException = false): bool
     {
-        $result=$this->transport()->ping();
+        $result = $this->transport()->ping();
         if ($throwException && !$result) throw new TransportException('Can`t ping server');
         return $result;
     }
@@ -811,7 +811,7 @@ 
     public function partitions(string $table, int $limit = null, bool $active = null)
     {
         $database = $this->settings()->getDatabase();
-        $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int)$active);
+        $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int) $active);
         $limitClause = $limit !== null ? ' LIMIT ' . $limit : '';
 
         return $this->select(<<<CLICKHOUSE
@@ -877,7 +877,7 @@ 
      */
     public function getServerVersion(): string
     {
-        return (string)$this->select('SELECT version() as version')->fetchOne('version');
+        return (string) $this->select('SELECT version() as version')->fetchOne('version');
     }
 
     /**

Braces +3 added lines, -1 removed lines

@@ -743,7 +743,9 @@
     public function ping(bool $throwException=false): bool
     {
         $result=$this->transport()->ping();
-        if ($throwException && !$result) throw new TransportException('Can`t ping server');
+        if ($throwException && !$result) {
+            throw new TransportException('Can`t ping server');
+        }
         return $result;
     }
 

src/Transport/CurlerRequest.php

Spacing +6 added lines, -6 removed lines

@@ -307,7 +307,7 @@ 
     public function setStdErrOut($stream)
     {
         if (is_resource($stream)) {
-            $this->stdErrOut=$stream;
+            $this->stdErrOut = $stream;
         }
 
     }
@@ -493,7 +493,7 @@ 
      */
     public function connectTimeOut(float $seconds = 1.0)
     {
-        $this->options[CURLOPT_CONNECTTIMEOUT_MS] = (int) ($seconds*1000.0);
+        $this->options[CURLOPT_CONNECTTIMEOUT_MS] = (int) ($seconds * 1000.0);
         return $this;
     }
 
@@ -736,7 +736,7 @@ 
                 $curl_opt[CURLOPT_POSTFIELDS] = $this->parameters;
 
                 if (!is_array($this->parameters)) {
-                    $this->header('Content-Length',  mb_strlen($this->parameters, '8bit'));
+                    $this->header('Content-Length', mb_strlen($this->parameters, '8bit'));
                 }
             }
         }
@@ -767,9 +767,9 @@ 
         }
 
         if ($this->options[CURLOPT_VERBOSE]) {
-            $msg="\n-----------BODY REQUEST----------\n" . $curl_opt[CURLOPT_POSTFIELDS] . "\n------END--------\n";
+            $msg = "\n-----------BODY REQUEST----------\n" . $curl_opt[CURLOPT_POSTFIELDS] . "\n------END--------\n";
             if ($this->stdErrOut && is_resource($this->stdErrOut)) {
-                fwrite($this->stdErrOut,$msg);
+                fwrite($this->stdErrOut, $msg);
             } else {
                 echo $msg;
             }
@@ -777,7 +777,7 @@ 
 
         if ($this->stdErrOut) {
             if (is_resource($this->stdErrOut)) {
-                $curl_opt[CURLOPT_STDERR]=$this->stdErrOut;
+                $curl_opt[CURLOPT_STDERR] = $this->stdErrOut;
             }
         }
 

src/Settings.php

Spacing +1 added lines, -1 removed lines

@@ -180,7 +180,7 @@
      */
     public function max_execution_time(int $time)
     {
-        $this->set('max_execution_time',$time);
+        $this->set('max_execution_time', $time);
         return $this;
     }
 

src/Query/Query.php

Spacing +6 added lines, -6 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);
 
         $this->sql = trim($this->sql);
         if (substr($this->sql, -1) == ';') {
@@ -110,16 +110,16 @@ 
     public function isUseInUrlBindingsParams():bool
     {
         //  'query=select {p1:UInt8} + {p2:UInt8}' -F "param_p1=3" -F "param_p2=4"
-        return preg_match('#{[\w+]+:[\w+()]+}#',$this->sql);
+        return preg_match('#{[\w+]+:[\w+()]+}#', $this->sql);
 
     }
     public function getUrlBindingsParams():array
     {
-        $out=[];
+        $out = [];
         if (sizeof($this->degenerations)) {
             foreach ($this->degenerations as $degeneration) {
                 if ($degeneration instanceof Degeneration) {
-                    $params=$degeneration->getBind();
+                    $params = $degeneration->getBind();
                     break;
                     // need first response
                 }
@@ -128,7 +128,7 @@ 
         if (sizeof($params)) {
             foreach ($params as $key=>$value)
             {
-                $out['param_'.$key]=$value;
+                $out['param_' . $key] = $value;
             }
         }
         return $out;