smi2 / phpClickHouse

src/Transport/StreamWrite.php

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
 class StreamWrite extends Stream
 {
 
-    public function __construct( $source)
+    public function __construct($source)
     {
 
         parent::__construct($source);

src/Transport/StreamInsert.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
      * @param CurlerRequest $request
      * @param CurlerRolling|null $curlerRolling
      */
-    public function __construct($source, CurlerRequest $request, $curlerRolling=null)
+    public function __construct($source, CurlerRequest $request, $curlerRolling = null)
     {
         if (!is_resource($source)) {
             throw new \InvalidArgumentException('Argument $source must be resource');

src/Transport/CurlerResponse.php

Spacing +1 added lines, -1 removed lines

@@ -293,7 +293,7 @@
 
         if (stripos($format, 'json') !== false)
         {
-            if (stripos($format,'JSONEachRow')===false)
+            if (stripos($format, 'JSONEachRow') === false)
             return $this->json();
         }
         return $this->body();

src/Transport/Stream.php

Spacing +4 added lines, -4 removed lines

@@ -15,11 +15,11 @@ 
     /**
      * @var bool
      */
-    private $gzip=false;
+    private $gzip = false;
     /**
      * @var null|callable
      */
-    private $callable=null;
+    private $callable = null;
     /**
      * @param resource $source
      */
@@ -60,7 +60,7 @@ 
      */
     public function closure(callable $callable)
     {
-        $this->callable=$callable;
+        $this->callable = $callable;
     }
 
     /**
@@ -68,7 +68,7 @@ 
      */
     public function enableGzipHeader()
     {
-        $this->gzip=true;
+        $this->gzip = true;
     }
 
 }

src/Query/Degeneration/Bindings.php

Spacing +10 added lines, -10 removed lines

@@ -56,10 +56,10 @@ 
      * @param string $pattern
      * @return string
      */
-    public function compile_binds($sql, $binds,$pattern)
+    public function compile_binds($sql, $binds, $pattern)
     {
         return preg_replace_callback($pattern, function($m) use ($binds){
-            if(isset($binds[$m[1]])){ // If it exists in our array
+            if (isset($binds[$m[1]])) { // If it exists in our array
                 return $binds[$m[1]]; // Then replace it from our array
             }
 
@@ -75,14 +75,14 @@ 
      */
     public function process($sql)
     {
-        $bindFormatted=[];
-        $bindRaw=[];
+        $bindFormatted = [];
+        $bindRaw = [];
         foreach ($this->bindings as $key => $value) {
             if (is_array($value)) {
                 $valueSet = implode(', ', $value);
 
                 $values = array_map(
-                    function ($value) {
+                    function($value) {
                         return ValueFormatter::formatValue($value);
                     },
                     $value
@@ -95,21 +95,21 @@ 
             }
 
             if ($formattedParameter !== null) {
-                $bindFormatted[$key]=$formattedParameter;
+                $bindFormatted[$key] = $formattedParameter;
             }
 
             if ($valueSet !== null) {
-                $bindRaw[$key]=$valueSet;
+                $bindRaw[$key] = $valueSet;
             }
         }
 
-        for ($loop=0;$loop<2;$loop++)
+        for ($loop = 0; $loop < 2; $loop++)
         {
             // dipping in binds
             // example ['A' => '{B}' , 'B'=>':C','C'=>123]
-            $sql=$this->compile_binds($sql,$bindRaw,'#{([\w+]+)}#');
+            $sql = $this->compile_binds($sql, $bindRaw, '#{([\w+]+)}#');
         }
-        $sql=$this->compile_binds($sql,$bindFormatted,'#:([\w+]+)#');
+        $sql = $this->compile_binds($sql, $bindFormatted, '#:([\w+]+)#');
 
         return $sql;
     }

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

src/Quote/FormatLine.php

Spacing +2 added lines, -2 removed lines

@@ -32,9 +32,9 @@
      * @param bool $skipEncode
      * @return string
      */
-    public static function Insert(array $row,bool $skipEncode=false)
+    public static function Insert(array $row, bool $skipEncode = false)
     {
-        return self::strictQuote('Insert')->quoteRow($row,$skipEncode);
+        return self::strictQuote('Insert')->quoteRow($row, $skipEncode);
     }
 
     /**

src/Quote/StrictQuoteLine.php

Spacing +6 added lines, -6 removed lines

@@ -57,9 +57,9 @@ 
      * @param bool $skipEncode
      * @return string
      */
-    public function quoteRow($row,bool $skipEncode=false )
+    public function quoteRow($row, bool $skipEncode = false)
     {
-        return implode($this->settings['Delimiter'], $this->quoteValue($row,$skipEncode));
+        return implode($this->settings['Delimiter'], $this->quoteValue($row, $skipEncode));
     }
 
     /**
@@ -67,7 +67,7 @@ 
      * @param bool $skipEncode
      * @return array
      */
-    public function quoteValue($row,bool $skipEncode=false)
+    public function quoteValue($row, bool $skipEncode = false)
     {
         $enclosure = $this->settings['Enclosure'];
         $delimiter = $this->settings['Delimiter'];
@@ -97,13 +97,13 @@ 
                 // single quotation marks with the same screening rules as above.
                 // as in the TabSeparated format, and then the resulting string is output in InsertRow in double quotes.
 
-                $value       = array_map(
-                    function ($v) use ($enclosure_esc, $encode_esc) {
+                $value = array_map(
+                    function($v) use ($enclosure_esc, $encode_esc) {
                         return is_string($v) ? $this->encodeString($v, $enclosure_esc, $encode_esc) : $v;
                     },
                     $value
                 );
-                $resultArray = FormatLine::Insert($value,($encodeEnclosure==='\\'?true:false));
+                $resultArray = FormatLine::Insert($value, ($encodeEnclosure === '\\' ?true:false));
                 return $encodeArray . '[' . $resultArray . ']' . $encodeArray;
             }
 

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;