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

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/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/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');

example/cluster/cluster_08_drop_partitions.php

Spacing +11 added lines, -11 removed lines

@@ -8,11 +8,11 @@ 
 
 
 $db = new ClickHouseDB\Client($config);
-$db->settings()->set('replication_alter_partitions_sync',2);
-$db->settings()->set('experimental_allow_extended_storage_definition_syntax',1);
+$db->settings()->set('replication_alter_partitions_sync', 2);
+$db->settings()->set('experimental_allow_extended_storage_definition_syntax', 1);
 
 
-for ( $looop=1;$looop<100;$looop++)
+for ($looop = 1; $looop < 100; $looop++)
 {
 
     $db->write("DROP TABLE IF EXISTS testoperation_log");
@@ -26,29 +26,29 @@ 
 ");
 
     echo "INSERT DATA....\n";
-    for ($z=0;$z<1000;$z++)
+    for ($z = 0; $z < 1000; $z++)
     {
-        $dataInsert=['time'=>strtotime('-'.mt_rand(0,4000).' day'),'event'=>strval($z)];
+        $dataInsert = ['time'=>strtotime('-' . mt_rand(0, 4000) . ' day'), 'event'=>strval($z)];
         try {
-            $db->insertAssocBulk('testoperation_log',$dataInsert);
+            $db->insertAssocBulk('testoperation_log', $dataInsert);
             echo "$z\r";
         }
         catch (Exception $exception)
         {
-            die("Error:".$exception->getMessage());
+            die("Error:" . $exception->getMessage());
         }
 
     }
     echo "INSER OK\n DROP PARTITION...\n";
 
-    $partitons=($db->partitions('testoperation_log'));
+    $partitons = ($db->partitions('testoperation_log'));
     foreach ($partitons as $part)
     {
-        echo "$looop\t\t".$part['partition']."\t".$part['name']."\t".$part['active']."\r";
+        echo "$looop\t\t" . $part['partition'] . "\t" . $part['name'] . "\t" . $part['active'] . "\r";
 
-        $db->dropPartition('default.testoperation_log',$part['partition']);
+        $db->dropPartition('default.testoperation_log', $part['partition']);
     }
-    echo "SELECT count() ...".str_repeat(" ",300)."\n";
+    echo "SELECT count() ..." . str_repeat(" ", 300) . "\n";
     print_r($db->select('SELECT count() FROM default.testoperation_log')->rows());
 }
 

example/cluster/cluster_02_create.php

Spacing +3 added lines, -3 removed lines

@@ -11,12 +11,12 @@
 $cl->setScanTimeOut(2.5); // 2500 ms
 if (!$cl->isReplicasIsOk())
 {
-    throw new Exception('Replica state is bad , error='.$cl->getError());
+    throw new Exception('Replica state is bad , error=' . $cl->getError());
 }
 //
-$cluster_name='sharovara';
+$cluster_name = 'sharovara';
 //
-echo "> $cluster_name , count shard   = ".$cl->getClusterCountShard($cluster_name)." ; count replica = ".$cl->getClusterCountReplica($cluster_name)."\n";
+echo "> $cluster_name , count shard   = " . $cl->getClusterCountShard($cluster_name) . " ; count replica = " . $cl->getClusterCountReplica($cluster_name) . "\n";