smi2 / phpClickHouse

example/cluster/cluster_06_truncate_table.php

Spacing +6 added lines, -6 removed lines

@@ -13,27 +13,27 @@
 $cl->setSoftCheck(true);
 if (!$cl->isReplicasIsOk())
 {
-    throw new Exception('Replica state is bad , error='.$cl->getError());
+    throw new Exception('Replica state is bad , error=' . $cl->getError());
 }
 
 
-$tables=$cl->getTables();
+$tables = $cl->getTables();
 
 foreach ($tables as $dbtable=>$tmp)
 {
     echo ">>> $dbtable :";
 
-    $size=$cl->getSizeTable($dbtable);
+    $size = $cl->getSizeTable($dbtable);
 
 
-    echo "\t".\ClickHouseDB\Example\Helper::humanFileSize($size)."\n";
+    echo "\t" . \ClickHouseDB\Example\Helper::humanFileSize($size) . "\n";
 
 }
 
 
-$table_for_truncate='target.events_sharded';
+$table_for_truncate = 'target.events_sharded';
 
-$result=$cl->truncateTable($table_for_truncate);
+$result = $cl->truncateTable($table_for_truncate);
 
 echo "Result:truncate table\n";
 print_r($result);

example/Helper.php

Indentation +4 added lines, -4 removed lines

@@ -12,10 +12,10 @@
     }
 
         /**
-     * @param $file_name
-     * @param int $from_id
-     * @param int $to_id
-     */
+         * @param $file_name
+         * @param int $from_id
+         * @param int $to_id
+         */
     public static function makeListSitesKeysDataFile($file_name, $from_id = 1000, $to_id = 20000)
     {
         @unlink($file_name);

Spacing +2 added lines, -2 removed lines

@@ -7,8 +7,8 @@
     public static function init()
     {
         date_default_timezone_set('Europe/Moscow');
-        error_reporting( E_ALL );
-        ini_set('display_errors',1);
+        error_reporting(E_ALL);
+        ini_set('display_errors', 1);
     }
 
         /**

Braces +4 added lines, -2 removed lines

@@ -123,8 +123,10 @@
 
         for ($day_ago = 0; $day_ago < 360; $day_ago++) {
             $date = strtotime('-' . $day_ago . ' day');
-            for ($hash_id = 1; $hash_id < (1 + $size); $hash_id++)
-                for ($site_id = 100; $site_id < 199; $site_id++) {
+            for ($hash_id = 1; $hash_id < (1 + $size); $hash_id++) {
+                            for ($site_id = 100;
+            }
+            $site_id < 199; $site_id++) {
                     $j['event_time'] = date('Y-m-d H:00:00', $date);
                     $j['site_id'] = $site_id;
                     $j['hash_id'] = $hash_id;

src/Query/Query.php

Braces +4 added lines, -3 removed lines

@@ -49,7 +49,9 @@ 
     private function applyFormatQuery()
     {
         // FORMAT\s(\w)*$
-        if (null === $this->format) return false;
+        if (null === $this->format) {
+            return false;
+        }
         $supportFormats=
             "FORMAT\\s+TSV|FORMAT\\s+TSVRaw|FORMAT\\s+TSVWithNames|FORMAT\\s+TSVWithNamesAndTypes|FORMAT\\s+Vertical|FORMAT\\s+JSONCompact|FORMAT\\s+JSONEachRow|FORMAT\\s+TSKV|FORMAT\\s+TabSeparatedWithNames|FORMAT\\s+TabSeparatedWithNamesAndTypes|FORMAT\\s+TabSeparatedRaw|FORMAT\\s+BlockTabSeparated|FORMAT\\s+CSVWithNames|FORMAT\\s+CSV|FORMAT\\s+JSON|FORMAT\\s+TabSeparated";
 
@@ -63,8 +65,7 @@ 
                 $this->format=trim(str_ireplace('format','',$matches[0][0]));
 
             }
-        }
-        else {
+        } else {
             $this->sql = $this->sql . ' FORMAT ' . $this->format;
         }
 

Spacing +8 added lines, -8 removed lines

@@ -20,21 +20,21 @@ 
     /**
      * @var array
      */
-    private $degenerations=[];
+    private $degenerations = [];
 
     /**
      * Query constructor.
      * @param string $sql
      * @param array $degenerations
      */
-    public function __construct($sql,$degenerations=[])
+    public function __construct($sql, $degenerations = [])
     {
         if (!trim($sql))
         {
             throw new QueryException('Empty Query');
         }
         $this->sql = $sql;
-        $this->degenerations=$degenerations;
+        $this->degenerations = $degenerations;
     }
 
     /**
@@ -50,17 +50,17 @@ 
     {
         // FORMAT\s(\w)*$
         if (null === $this->format) return false;
-        $supportFormats=
+        $supportFormats =
             "FORMAT\\s+TSV|FORMAT\\s+TSVRaw|FORMAT\\s+TSVWithNames|FORMAT\\s+TSVWithNamesAndTypes|FORMAT\\s+Vertical|FORMAT\\s+JSONCompact|FORMAT\\s+JSONEachRow|FORMAT\\s+TSKV|FORMAT\\s+TabSeparatedWithNames|FORMAT\\s+TabSeparatedWithNamesAndTypes|FORMAT\\s+TabSeparatedRaw|FORMAT\\s+BlockTabSeparated|FORMAT\\s+CSVWithNames|FORMAT\\s+CSV|FORMAT\\s+JSON|FORMAT\\s+TabSeparated";
 
-        $matches=[];
-        if (preg_match_all('%('.$supportFormats.')%ius',$this->sql,$matches)){
+        $matches = [];
+        if (preg_match_all('%(' . $supportFormats . ')%ius', $this->sql, $matches)) {
 
             // skip add "format json"
             if (isset($matches[0]))
             {
 
-                $this->format=trim(str_ireplace('format','',$matches[0][0]));
+                $this->format = trim(str_ireplace('format', '', $matches[0][0]));
 
             }
         }
@@ -95,7 +95,7 @@ 
             foreach ($this->degenerations as $degeneration)
             {
                 if ($degeneration instanceof Degeneration) {
-                    $this->sql=$degeneration->process($this->sql);
+                    $this->sql = $degeneration->process($this->sql);
                 }
             }
         }

src/Statement.php

Braces +15 added lines, -15 removed lines

@@ -167,13 +167,11 @@ 
 
             if ($parse) {
                 throw new DatabaseException($parse['message'] . "\nIN:" . $this->sql(), $parse['code']);
-            }
-            else {
+            } else {
                 $code = $this->response()->http_code();
                 $message = "HttpCode:" . $this->response()->http_code() . " ; ".$this->response()->error()." ;" . $body;
             }
-        }
-        else {
+        } else {
             $code = $error_no;
             $message = $this->response()->error();
         }
@@ -349,8 +347,12 @@ 
         $this->init();
         if ($key)
         {
-            if (!is_array($this->statistics)) return null;
-            if (!isset($this->statistics[$key])) return null;
+            if (!is_array($this->statistics)) {
+                return null;
+            }
+            if (!isset($this->statistics[$key])) {
+                return null;
+            }
             return $this->statistics[$key];
         }
         return $this->statistics;
@@ -394,8 +396,7 @@ 
             if ($key) {
                 if (isset($this->array_data[0][$key])) {
                     return $this->array_data[0][$key];
-                }
-                else {
+                } else {
                     return null;
                 }
             }
@@ -489,16 +490,14 @@ 
     {
         if (is_array($path)) {
             $keys = $path;
-        }
-        else {
+        } else {
             $args = func_get_args();
             array_shift($args);
 
             if (sizeof($args) < 2) {
                 $separator = '.';
                 $keys = explode($separator, $path);
-            }
-            else {
+            } else {
                 $keys = $args;
             }
         }
@@ -510,14 +509,15 @@ 
 
             if (isset($arr[$key])) {
                 $val = $arr[$key];
-            }
-            else {
+            } else {
                 $val = $key;
             }
 
             $tree = array($val => $tree);
         }
-        if (!is_array($tree)) return [];
+        if (!is_array($tree)) {
+            return [];
+        }
         return $tree;
     }
 }

Spacing +5 added lines, -5 removed lines

@@ -83,7 +83,7 @@ 
     /**
      * @var array|null
      */
-    private $statistics=null;
+    private $statistics = null;
 
 
     public function __construct(CurlerRequest $request)
@@ -160,7 +160,7 @@ 
 
         $body = $this->response()->body();
         $error_no = $this->response()->error_no();
-        $error=$this->response()->error();
+        $error = $this->response()->error();
 
         if (!$error_no && !$error) {
             $parse = $this->parseErrorClickHouse($body);
@@ -170,7 +170,7 @@ 
             }
             else {
                 $code = $this->response()->http_code();
-                $message = "HttpCode:" . $this->response()->http_code() . " ; ".$this->response()->error()." ;" . $body;
+                $message = "HttpCode:" . $this->response()->http_code() . " ; " . $this->response()->error() . " ;" . $body;
             }
         }
         else {
@@ -227,7 +227,7 @@ 
             return false;
         }
 
-        foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least','statistics'] as $key) {
+        foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
             if (isset($this->_rawData[$key])) {
                 $this->{$key} = $this->_rawData[$key];
             }
@@ -344,7 +344,7 @@ 
      * @return array|mixed|null
      * @throws Exception\TransportException
      */
-    public function statistics($key=false)
+    public function statistics($key = false)
     {
         $this->init();
         if ($key)