smi2 / phpClickHouse

example/exam20_FormatLine_TSV.php

Spacing +10 added lines, -10 removed lines

@@ -23,27 +23,27 @@
 
 // ARRAY TO TABLE
 
-$rows=[
-    ['2017-01-01','XXXXX',123,1],
-    ['2017-01-02','XXXXX',123,1],
-    ['2017-01-03','XXXXX',123,1],
-    ['2017-01-04','XXXXX',123,1],
-    ['2017-01-05','XXXXX',123,1],
-    ['2017-01-06','XXXXX',123,1],
-    ['2017-01-07','XXXXX',123,1]
+$rows = [
+    ['2017-01-01', 'XXXXX', 123, 1],
+    ['2017-01-02', 'XXXXX', 123, 1],
+    ['2017-01-03', 'XXXXX', 123, 1],
+    ['2017-01-04', 'XXXXX', 123, 1],
+    ['2017-01-05', 'XXXXX', 123, 1],
+    ['2017-01-06', 'XXXXX', 123, 1],
+    ['2017-01-07', 'XXXXX', 123, 1]
 ];
 
 
 
 // Write to file array
-$temp_file_name='/tmp/_test_data.TSV';
+$temp_file_name = '/tmp/_test_data.TSV';
 
 
 if (file_exists($temp_file_name)) unlink('/tmp/_test_data.TSV');
 foreach ($rows as $row)
 {
 
-    file_put_contents($temp_file_name,\ClickHouseDB\Quote\FormatLine::TSV($row)."\n",FILE_APPEND);
+    file_put_contents($temp_file_name, \ClickHouseDB\Quote\FormatLine::TSV($row) . "\n", FILE_APPEND);
 
 }
 

Braces +3 added lines, -1 removed lines

@@ -39,7 +39,9 @@
 $temp_file_name='/tmp/_test_data.TSV';
 
 
-if (file_exists($temp_file_name)) unlink('/tmp/_test_data.TSV');
+if (file_exists($temp_file_name)) {
+    unlink('/tmp/_test_data.TSV');
+}
 foreach ($rows as $row)
 {
 

example/exam02_createtable.php

Spacing +6 added lines, -6 removed lines

@@ -62,8 +62,8 @@ 
 
 
 
-echo "Count select rows:".$st->count()."\n";
-echo "Count all rows:".$st->countAll()."\n";
+echo "Count select rows:" . $st->count() . "\n";
+echo "Count all rows:" . $st->countAll() . "\n";
 echo "First row:\n";
 print_r($st->fetchOne());
 
@@ -75,16 +75,16 @@ 
 
 
 
-$st=$db->select('SELECT event_date,url_hash,sum(views),avg(views) FROM summing_url_views WHERE site_id<3333 GROUP BY event_date,url_hash WITH TOTALS');
+$st = $db->select('SELECT event_date,url_hash,sum(views),avg(views) FROM summing_url_views WHERE site_id<3333 GROUP BY event_date,url_hash WITH TOTALS');
 
 
 
 
-echo "Count select rows:".$st->count()."\n";
+echo "Count select rows:" . $st->count() . "\n";
 /*
 2
  */
-echo "Count all rows:".$st->countAll()."\n";
+echo "Count all rows:" . $st->countAll() . "\n";
 /*
 false
  */
@@ -140,7 +140,7 @@ 
 )
  */
 $db->write("DROP TABLE IF EXISTS summing_url_views");
-echo "Tables EXISTS:".json_encode($db->showTables())."\n";
+echo "Tables EXISTS:" . json_encode($db->showTables()) . "\n";
 /*
 Tables EXISTS:[]
  */
\ No newline at end of file

example/exam15_direct_write_result.php

Spacing +9 added lines, -9 removed lines

@@ -51,15 +51,15 @@ 
 echo "use time:" . round(microtime(true) - $time_start, 2) . "\n";
 print_r($db->select('select sum(views) from summing_url_views')->rows());
 // ------------------------------------------------------------------------------------------------
-$WriteToFile=new ClickHouseDB\Query\WriteToFile('/tmp/_1_select.csv');
-$statement=$db->select('select * from summing_url_views',[],null,$WriteToFile);
+$WriteToFile = new ClickHouseDB\Query\WriteToFile('/tmp/_1_select.csv');
+$statement = $db->select('select * from summing_url_views', [], null, $WriteToFile);
 print_r($statement->info());
 
 //
-$db->selectAsync('select * from summing_url_views limit 4',[],null,new ClickHouseDB\Query\WriteToFile('/tmp/_2_select.csv'));
-$db->selectAsync('select * from summing_url_views limit 4',[],null,new ClickHouseDB\Query\WriteToFile('/tmp/_3_select.tab',true,'TabSeparatedWithNames'));
-$db->selectAsync('select * from summing_url_views limit 4',[],null,new ClickHouseDB\Query\WriteToFile('/tmp/_4_select.tab',true,'TabSeparated'));
-$statement=$db->selectAsync('select * from summing_url_views limit 54',[],null,new ClickHouseDB\Query\WriteToFile('/tmp/_5_select.csv',true,ClickHouseDB\Query\WriteToFile::FORMAT_CSV));
+$db->selectAsync('select * from summing_url_views limit 4', [], null, new ClickHouseDB\Query\WriteToFile('/tmp/_2_select.csv'));
+$db->selectAsync('select * from summing_url_views limit 4', [], null, new ClickHouseDB\Query\WriteToFile('/tmp/_3_select.tab', true, 'TabSeparatedWithNames'));
+$db->selectAsync('select * from summing_url_views limit 4', [], null, new ClickHouseDB\Query\WriteToFile('/tmp/_4_select.tab', true, 'TabSeparated'));
+$statement = $db->selectAsync('select * from summing_url_views limit 54', [], null, new ClickHouseDB\Query\WriteToFile('/tmp/_5_select.csv', true, ClickHouseDB\Query\WriteToFile::FORMAT_CSV));
 $db->executeAsync();
 
 print_r($statement->info());
@@ -68,11 +68,11 @@ 
 
 echo "TRY GZIP\n";
 
-$WriteToFile=new ClickHouseDB\Query\WriteToFile('/tmp/_0_select.csv.gz');
+$WriteToFile = new ClickHouseDB\Query\WriteToFile('/tmp/_0_select.csv.gz');
 $WriteToFile->setFormat(ClickHouseDB\Query\WriteToFile::FORMAT_TabSeparatedWithNames);
-$WriteToFile->setGzip(true);// cat /tmp/_0_select.csv.gz | gzip -dc > /tmp/w.result
+$WriteToFile->setGzip(true); // cat /tmp/_0_select.csv.gz | gzip -dc > /tmp/w.result
 
-$statement=$db->select('select * from summing_url_views',[],null,$WriteToFile);
+$statement = $db->select('select * from summing_url_views', [], null, $WriteToFile);
 print_r($statement->info());
 
 echo "OK!\n\n";
\ No newline at end of file

example/exam22_PROGRESSFUNCTION.php

Spacing +6 added lines, -6 removed lines

@@ -9,7 +9,7 @@ 
 class progress {
     public static function printz($data)
     {
-        echo "CALL CLASS:   ".json_encode($data)."\n";
+        echo "CALL CLASS:   " . json_encode($data) . "\n";
     }
 }
 
@@ -22,14 +22,14 @@ 
 
 
 // ----------------------------------------  ----------------------------------------
-$db->progressFunction(function ($data) {
-    echo "CALL FUNCTION:".json_encode($data)."\n";
+$db->progressFunction(function($data) {
+    echo "CALL FUNCTION:" . json_encode($data) . "\n";
 });
-$st=$db->select('SELECT number,sleep(0.2) FROM system.numbers limit 5');
+$st = $db->select('SELECT number,sleep(0.2) FROM system.numbers limit 5');
 
 
 // ----------------------------------------  ----------------------------------------
 $db->settings()->set('http_headers_progress_interval_ms', 15); // change interval
 
-$db->progressFunction(['progress','printz']);
-$st=$db->select('SELECT number,sleep(0.1) FROM system.numbers limit 5');
\ No newline at end of file
+$db->progressFunction(['progress', 'printz']);
+$st = $db->select('SELECT number,sleep(0.1) FROM system.numbers limit 5');
\ No newline at end of file

example/exam21_httpS.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
 
 // --------------------- $config['https']=true; --------------------------------
 
-$config['https']=true;
+$config['https'] = true;
 
 $db = new ClickHouseDB\Client($config);
 $db->verbose();

example/exam17_sample_data_inthash.php

Spacing +13 added lines, -13 removed lines

@@ -7,26 +7,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,
@@ -53,8 +53,8 @@ 
     $c = 0;
     foreach ($file_data_names as $file_name) {
         $c++;
-        $shift_days=( -1* $c*3);
-        makeSomeDataFileBig($file_name, 4 * $c,$shift_days);
+        $shift_days = ( -1 * $c * 3);
+        makeSomeDataFileBig($file_name, 4 * $c, $shift_days);
     }
 
     echo "----------------------------------------------------------------------------------------------------\n";
@@ -80,25 +80,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";
 }
 /*
 

Braces +3 added lines, -1 removed lines

@@ -19,7 +19,9 @@
 
 
 
-if (!isset($size['size'])) $_flag_create_table=true;
+if (!isset($size['size'])) {
+    $_flag_create_table=true;
+}
 
 
 if ($_flag_create_table) {

example/exam16_custom_degeneration.php

Spacing +5 added lines, -5 removed lines

@@ -7,10 +7,10 @@ 
 
 class CustomDegeneration implements \ClickHouseDB\Query\Degeneration
 {
-    private $bindings=[];
+    private $bindings = [];
     public function bindParams(array $bindings)
     {
-        $this->bindings=$bindings;
+        $this->bindings = $bindings;
     }
     public function process($sql)
     {
@@ -18,10 +18,10 @@ 
         {
             foreach ($this->bindings as $key=>$value)
             {
-                $sql=str_ireplace('%'.$key.'%',$value,$sql);
+                $sql = str_ireplace('%' . $key . '%', $value, $sql);
             }
         }
-        return str_ireplace('XXXX','SELECT',$sql);
+        return str_ireplace('XXXX', 'SELECT', $sql);
     }
 }
 
@@ -45,4 +45,4 @@ 
 
 
 // SELECT 1 as ping
-print_r($db->select('XXXX 1 as %ZX%',['ZX'=>'ping'])->fetchOne());
+print_r($db->select('XXXX 1 as %ZX%', ['ZX'=>'ping'])->fetchOne());

example/exam17_sample_data_cityHash64.php

Spacing +29 added lines, -29 removed lines

@@ -7,20 +7,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,
@@ -47,8 +47,8 @@ 
     $c = 0;
     foreach ($file_data_names as $file_name) {
         $c++;
-        $shift_days=( -1* $c*3);
-        makeSomeDataFileBig($file_name, 23 * $c,$shift_days);
+        $shift_days = ( -1 * $c * 3);
+        makeSomeDataFileBig($file_name, 23 * $c, $shift_days);
     }
 
     echo "----------------------------------------------------------------------------------------------------\n";
@@ -74,56 +74,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

Braces +3 added lines, -1 removed lines

@@ -13,7 +13,9 @@
 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) {

example/exam05_error_async.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
     $db->executeAsync();
 
     $stat = $db->insertBatchFiles('summing_url_views', ['/tmp/clickHouseDB_test.1.data'], [
-        'event_time', 'url_hash', 'site_id', 'views', 'v_00',  'v_55'
+        'event_time', 'url_hash', 'site_id', 'views', 'v_00', 'v_55'
     ]);
 
     $statselect1 = $db->selectAsync('SELECT * FROM summing_url_views LIMIT 1');