smi2 / phpClickHouse

src/Client.php

Spacing +11 added lines, -11 removed lines

@@ -589,7 +589,7 @@ 
      * @return mixed
      * @throws Exception\TransportException
      */
-    public function insertBatchTSVFiles($table_name, $file_names, $columns_array=[])
+    public function insertBatchTSVFiles($table_name, $file_names, $columns_array = [])
     {
         return $this->insertBatchFiles($table_name, $file_names, $columns_array, 'TabSeparated');
     }
@@ -604,7 +604,7 @@ 
      * @return array
      * @throws Exception\TransportException
      */
-    public function insertBatchFiles($table_name, $file_names, $columns_array=[], $format = "CSV")
+    public function insertBatchFiles($table_name, $file_names, $columns_array = [], $format = "CSV")
     {
         if (is_string($file_names))
         {
@@ -659,7 +659,7 @@ 
      * @param string $format ['TabSeparated','TabSeparatedWithNames','CSV','CSVWithNames']
      * @return Transport\CurlerRequest
      */
-    public function insertBatchStream($table_name, $columns_array=[], $format = "CSV")
+    public function insertBatchStream($table_name, $columns_array = [], $format = "CSV")
     {
         if ($this->getCountPendingQueue() > 0) {
             throw new QueryException('Queue must be empty, before insertBatch, need executeAsync');
@@ -693,12 +693,12 @@ 
      * @return Statement
      * @throws Exception\TransportException
      */
-    public function streamWrite(Stream $stream,$sql,$bind=[])
+    public function streamWrite(Stream $stream, $sql, $bind = [])
     {
         if ($this->getCountPendingQueue() > 0) {
             throw new QueryException('Queue must be empty, before streamWrite');
         }
-        return $this->transport()->streamWrite($stream,$sql,$bind);
+        return $this->transport()->streamWrite($stream, $sql, $bind);
     }
 
 
@@ -711,12 +711,12 @@ 
      * @return Statement
      * @throws Exception\TransportException
      */
-    public function streamRead(Stream $streamRead,$sql,$bind=[])
+    public function streamRead(Stream $streamRead, $sql, $bind = [])
     {
         if ($this->getCountPendingQueue() > 0) {
             throw new QueryException('Queue must be empty, before streamWrite');
         }
-        return $this->transport()->streamRead($streamRead,$sql,$bind);
+        return $this->transport()->streamRead($streamRead, $sql, $bind);
     }
 
     /**
@@ -910,12 +910,12 @@ 
      * @return array
      * @throws Exception\TransportException
      */
-    public function getServerSystemSettings($like='')
+    public function getServerSystemSettings($like = '')
     {
-        $l=[];
-        $list=$this->select('SELECT * FROM system.settings'.($like ? ' WHERE name LIKE :like':'' ),['like'=>'%'.$like.'%'])->rows();
+        $l = [];
+        $list = $this->select('SELECT * FROM system.settings' . ($like ? ' WHERE name LIKE :like' : ''), ['like'=>'%' . $like . '%'])->rows();
         foreach ($list as $row) {
-            if (isset($row['name'])) {$n=$row['name']; unset($row['name']) ; $l[$n]=$row;}
+            if (isset($row['name'])) {$n = $row['name']; unset($row['name']); $l[$n] = $row; }
         }
         return $l;
     }

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/CurlerRequest.php

Spacing +2 added lines, -2 removed lines

@@ -241,7 +241,7 @@ 
      */
     public function setWriteFunction($callback)
     {
-        $this->options[CURLOPT_WRITEFUNCTION]=$callback;
+        $this->options[CURLOPT_WRITEFUNCTION] = $callback;
     }
     /**
      * @param callable $callback
@@ -715,7 +715,7 @@ 
 
         if (!empty($curl_opt[CURLOPT_WRITEFUNCTION]))
         {
-            $curl_opt[CURLOPT_HEADER]=false;
+            $curl_opt[CURLOPT_HEADER] = false;
         }
 
         if ($this->resultFileHandle) {

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/Statement.php

Spacing +6 added lines, -6 removed lines

@@ -219,15 +219,15 @@ 
             $this->_init = true;
             return false;
         }
-        $data=[];
+        $data = [];
         foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
 
             if (isset($this->_rawData[$key])) {
-                if ($key=='data')
+                if ($key == 'data')
                 {
-                    $data=$this->_rawData[$key];
+                    $data = $this->_rawData[$key];
                 }
-                else{
+                else {
                     $this->{$key} = $this->_rawData[$key];
                 }
 
@@ -238,7 +238,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 = [];
@@ -246,7 +246,7 @@ 
 
             if ($isJSONCompact)
             {
-                $r[]=$rows;
+                $r[] = $rows;
             }
             else {
                 foreach ($this->meta as $meta) {

src/Transport/CurlerRolling.php

Spacing +2 added lines, -2 removed lines

@@ -144,7 +144,7 @@ 
     public function execLoopWait()
     {
         $c = 0;
-        $count=0;
+        $count = 0;
         // add all tasks
         do {
             $this->exec();
@@ -152,7 +152,7 @@ 
             $loop = $this->countActive();
             $pend = $this->countPending();
 
-            $count=$loop+$pend;
+            $count = $loop + $pend;
             $c++;
 
             if ($c > 20000) {

src/Transport/Http.php

Spacing +16 added lines, -16 removed lines

@@ -120,10 +120,10 @@ 
             $proto = 'https';
         }
         $uri = $proto . '://' . $this->_host;
-        if (stripos($this->_host,'/')!==false || stripos($this->_host,':')!==false) {
+        if (stripos($this->_host, '/') !== false || stripos($this->_host, ':') !== false) {
             return $uri;
         }
-        if (intval($this->_port)>0) {
+        if (intval($this->_port) > 0) {
             return $uri . ':' . $this->_port;
         }
         return $uri;
@@ -248,7 +248,7 @@ 
     {
 
         if ($sql instanceof Query) {
-            $query=$sql;
+            $query = $sql;
         } else {
             $query = new Query($sql);
         }
@@ -610,10 +610,10 @@ 
      * @return Statement
      * @throws \ClickHouseDB\Exception\TransportException
      */
-    private function streaming(Stream $streamRW,CurlerRequest $request)
+    private function streaming(Stream $streamRW, CurlerRequest $request)
     {
-        $callable=$streamRW->getClosure();
-        $stream=$streamRW->getStream();
+        $callable = $streamRW->getClosure();
+        $stream = $streamRW->getStream();
 
 
 
@@ -624,11 +624,11 @@ 
                 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);
                     };
                 }
@@ -663,7 +663,7 @@ 
             }
 
 
-            $this->_curler->execOne($request,true);
+            $this->_curler->execOne($request, true);
             $response = new Statement($request);
             if ($response->isError()) {
                 $response->error();
@@ -685,11 +685,11 @@ 
      * @return Statement
      * @throws \ClickHouseDB\Exception\TransportException
      */
-    public function streamRead(Stream $streamRead,$sql,$bindings=[])
+    public function streamRead(Stream $streamRead, $sql, $bindings = [])
     {
-        $sql=$this->prepareQuery($sql,$bindings);
-        $request=$this->getRequestRead($sql);
-        return $this->streaming($streamRead,$request);
+        $sql = $this->prepareQuery($sql, $bindings);
+        $request = $this->getRequestRead($sql);
+        return $this->streaming($streamRead, $request);
 
     }
 
@@ -700,10 +700,10 @@ 
      * @return Statement
      * @throws \ClickHouseDB\Exception\TransportException
      */
-    public function streamWrite(Stream $streamWrite,$sql,$bindings=[])
+    public function streamWrite(Stream $streamWrite, $sql, $bindings = [])
     {
-        $sql=$this->prepareQuery($sql,$bindings);
+        $sql = $this->prepareQuery($sql, $bindings);
         $request = $this->writeStreamData($sql);
-        return $this->streaming($streamWrite,$request);
+        return $this->streaming($streamWrite, $request);
     }
 }