smi2 / phpClickHouse

src/Client.php

Spacing +15 added lines, -15 removed lines

@@ -59,19 +59,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');
         }
 
@@ -92,7 +92,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');
         }
 
@@ -266,8 +266,8 @@ 
      */
     public function useSession(bool $useSessionId = false)
     {
-        if (! $this->settings()->getSessionId()) {
-            if (! $useSessionId) {
+        if (!$this->settings()->getSessionId()) {
+            if (!$useSessionId) {
                 $this->settings()->makeSessionId();
             } else {
                 $this->settings()->session_id($useSessionId);
@@ -381,14 +381,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);
         }
 
@@ -567,14 +567,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'));
             }
 
@@ -591,7 +591,7 @@ 
 
         // fetch resutl
         foreach ($fileNames as $fileName) {
-            if (! $result[$fileName]->isError()) {
+            if (!$result[$fileName]->isError()) {
                 continue;
             }
 
@@ -614,7 +614,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/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;
     }