smi2 / phpClickHouse

src/Client.php

Spacing +12 added lines, -12 removed lines

@@ -524,7 +524,7 @@ 
      */
     public function insert($table, $values, $columns = [])
     {
-        if (stripos($table,'`')===false &&  stripos($table,'.')===false) {
+        if (stripos($table, '`') === false && stripos($table, '.') === false) {
             $table = '`' . $table . "`"; //quote table name for dot names
         }
         $sql = 'INSERT INTO ' . $table;
@@ -593,7 +593,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');
     }
@@ -608,7 +608,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))
         {
@@ -663,7 +663,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');
@@ -697,12 +697,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);
     }
 
 
@@ -715,12 +715,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);
     }
 
     /**
@@ -923,12 +923,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;
     }