smi2 / phpClickHouse

src/Client.php

Spacing +13 added lines, -13 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);
     }
 
     /**
@@ -838,8 +838,8 @@ 
     public function partitions(string $table, int $limit = null, bool $active = null)
     {
         $database = $this->settings()->getDatabase();
-        $whereActiveClause = $active===null ? '' : sprintf(' AND active = %s', (int) $active);
-        $limitClause=$limit !== null ? ' LIMIT ' . $limit : '';
+        $whereActiveClause = $active === null ? '' : sprintf(' AND active = %s', (int) $active);
+        $limitClause = $limit !== null ? ' LIMIT ' . $limit : '';
 
         return $this->select(<<<CLICKHOUSE
 SELECT *
@@ -919,12 +919,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;
     }