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

Spacing +29 added lines, -29 removed lines

@@ -8,20 +8,20 @@ 
 
 
 $db = new ClickHouseDB\Client($config);
-$_flag_create_table=false;
+$_flag_create_table = false;
 
-$size=$db->tableSize('summing_url_views_cityHash64_site_id');
-echo "Site table summing_url_views_cityHash64_site_id : ".(isset($size['size'])?$size['size']:'false')."\n";
+$size = $db->tableSize('summing_url_views_cityHash64_site_id');
+echo "Site table summing_url_views_cityHash64_site_id : " . (isset($size['size']) ? $size['size'] : 'false') . "\n";
 
 
-if (!isset($size['size'])) $_flag_create_table=true;
+if (!isset($size['size'])) $_flag_create_table = true;
 
 
 if ($_flag_create_table) {
 
 
     $db->write("DROP TABLE IF EXISTS summing_url_views_cityHash64_site_id");
-    $re=$db->write('
+    $re = $db->write('
                 CREATE TABLE IF NOT EXISTS summing_url_views_cityHash64_site_id (
                     event_date Date DEFAULT toDate(event_time),
                     event_time DateTime,
@@ -48,8 +48,8 @@ 
     $c = 0;
     foreach ($file_data_names as $file_name) {
         $c++;
-        $shift_days=( -1* $c*3);
-        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 23 * $c,$shift_days);
+        $shift_days = ( -1 * $c * 3);
+        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 23 * $c, $shift_days);
     }
 
     echo "----------------------------------------------------------------------------------------------------\n";
@@ -75,56 +75,56 @@ 
 }
 echo "------------------------------- COMPARE event_date ---------------------------------------------------------------------\n";
 
-$rows=($db->select('select event_date,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
+$rows = ($db->select('select event_date,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
 
-$samp=($db->select('select event_date,(sum(views)*10) as v from summing_url_views_cityHash64_site_id SAMPLE 0.1 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
+$samp = ($db->select('select event_date,(sum(views)*10) as v from summing_url_views_cityHash64_site_id SAMPLE 0.1 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
 
 
 foreach ($rows as $event_date=>$data)
 {
-    echo $event_date."\t".$data['v']."\t".@$samp[$event_date]['v']."\n";
+    echo $event_date . "\t" . $data['v'] . "\t" . @$samp[$event_date]['v'] . "\n";
 }
 
 
-$rows=($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
+$rows = ($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
 
-$samp=($db->select('select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
+$samp = ($db->select('select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
 
 
 foreach ($rows as $event_date=>$data)
 {
-    echo $event_date."\t".$data['v']."\t".intval(@$samp[$event_date]['v'])."\n";
+    echo $event_date . "\t" . $data['v'] . "\t" . intval(@$samp[$event_date]['v']) . "\n";
 }
 
 
 
-for($f=1;$f<=9;$f++)
+for ($f = 1; $f <= 9; $f++)
 {
-    $SAMPLE=$f/10;
+    $SAMPLE = $f / 10;
 
-    $CQL='select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE '.$SAMPLE.' WHERE site_id=34 GROUP BY site_id ORDER BY site_id ';
+    $CQL = 'select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE ' . $SAMPLE . ' WHERE site_id=34 GROUP BY site_id ORDER BY site_id ';
 
-    echo $CQL."\n";
-    $rows=($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id WHERE site_id=34 GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
-    $samp=($db->select($CQL)->rowsAsTree('site_id'));
+    echo $CQL . "\n";
+    $rows = ($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id WHERE site_id=34 GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
+    $samp = ($db->select($CQL)->rowsAsTree('site_id'));
     foreach ($rows as $id=>$data)
     {
-            $s=$samp[$id]['v'];
-            $v=$data['v'];
+            $s = $samp[$id]['v'];
+            $v = $data['v'];
 
 
-            $percent=round( (100*$s) /$v   ,2);
+            $percent = round((100 * $s) / $v, 2);
 
-            $kof=(100/$percent);
-            $norma_views=$s*(100/$percent);
+            $kof = (100 / $percent);
+            $norma_views = $s * (100 / $percent);
 
 
 
-            echo "Сумма показов без SAMPLE  =  " .$v."\n";
-            echo "Сумма показов c   SAMPLE  =  " .$s."\n";
-            echo "Процент                   =  " .$percent."\n";
-            echo "На что домжнож.семлир.данн=  " .$kof."\n";
-            echo "Сумма показов расчитанное =  " .$norma_views."\n";
+            echo "Сумма показов без SAMPLE  =  " . $v . "\n";
+            echo "Сумма показов c   SAMPLE  =  " . $s . "\n";
+            echo "Процент                   =  " . $percent . "\n";
+            echo "На что домжнож.семлир.данн=  " . $kof . "\n";
+            echo "Сумма показов расчитанное =  " . $norma_views . "\n";
 
 /// >> 1/(0.8) = для SAMPLE 0.8
 /// >> 1/(0.5) = для SAMPLE 0.5

example/exam17_sample_data_inthash.php

Spacing +13 added lines, -13 removed lines

@@ -8,26 +8,26 @@ 
 
 
 $db = new ClickHouseDB\Client($config);
-$_flag_create_table=false;
+$_flag_create_table = false;
 
 
 $db->write("DROP TABLE IF EXISTS summing_url_views_intHash32_site_id");
 
 
 
-$size=$db->tableSize('summing_url_views_intHash32_site_id');
-echo "Site table summing_url_views_intHash32_site_id : ".(isset($size['size'])?$size['size']:'false')."\n";
+$size = $db->tableSize('summing_url_views_intHash32_site_id');
+echo "Site table summing_url_views_intHash32_site_id : " . (isset($size['size']) ? $size['size'] : 'false') . "\n";
 
 
 
-if (!isset($size['size'])) $_flag_create_table=true;
+if (!isset($size['size'])) $_flag_create_table = true;
 
 
 if ($_flag_create_table) {
 
 
     $db->write("DROP TABLE IF EXISTS summing_url_views_intHash32_site_id");
-    $re=$db->write('
+    $re = $db->write('
                 CREATE TABLE IF NOT EXISTS summing_url_views_intHash32_site_id (
                     event_date Date DEFAULT toDate(event_time),
                     event_time DateTime,
@@ -54,8 +54,8 @@ 
     $c = 0;
     foreach ($file_data_names as $file_name) {
         $c++;
-        $shift_days=( -1* $c*3);
-        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 4 * $c,$shift_days);
+        $shift_days = ( -1 * $c * 3);
+        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 4 * $c, $shift_days);
     }
 
     echo "----------------------------------------------------------------------------------------------------\n";
@@ -81,25 +81,25 @@ 
 }
 echo "------------------------------- COMPARE event_date ---------------------------------------------------------------------\n";
 
-$rows=($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
+$rows = ($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
 
-$samp=($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
+$samp = ($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
 
 
 foreach ($rows as $event_date=>$data)
 {
-    echo $event_date."\t".$data['v']."\t".(@$samp[$event_date]['v']*(1/0.5))."\n";
+    echo $event_date . "\t" . $data['v'] . "\t" . (@$samp[$event_date]['v'] * (1 / 0.5)) . "\n";
 }
 
 
-$rows=($db->select('select site_id,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
+$rows = ($db->select('select site_id,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
 
-$samp=($db->select('select site_id,(sum(views)) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
+$samp = ($db->select('select site_id,(sum(views)) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
 
 
 foreach ($rows as $event_date=>$data)
 {
-    echo $event_date."\t".$data['v']."\t".intval(@$samp[$event_date]['v'])."\n";
+    echo $event_date . "\t" . $data['v'] . "\t" . intval(@$samp[$event_date]['v']) . "\n";
 }
 /*
 

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

Spacing +8 added lines, -8 removed lines

@@ -20,21 +20,21 @@ 
     /**
      * @var array
      */
-    private $degenerations=[];
+    private $degenerations = [];
 
     /**
      * Query constructor.
      * @param $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);
                 }
             }
         }

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;
         }