smi2 / phpClickHouse

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

Braces +1 added lines, -2 removed lines

@@ -32,8 +32,7 @@
         try {
             $db->insertAssocBulk('testoperation_log',$dataInsert);
             echo "$z\r";
-        }
-        catch (Exception $exception)
+        } catch (Exception $exception)
         {
             die("Error:".$exception->getMessage());
         }

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

example/cluster/cluster_03_list.php

Spacing +4 added lines, -4 removed lines

@@ -10,15 +10,15 @@
 
 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";
 
 
 // ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-$nodes=$cl->getNodesByTable('shara.adpreview_body_views_sharded');
+$nodes = $cl->getNodesByTable('shara.adpreview_body_views_sharded');
 
 foreach ($nodes as $node)
 {

example/cluster/cluster_06_truncate_table.php

Spacing +6 added lines, -6 removed lines

@@ -12,27 +12,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".humanFileSize($size)."\n";
+    echo "\t" . 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/cluster/cluster_07_test_ddl.php

Spacing +6 added lines, -6 removed lines

@@ -7,13 +7,13 @@ 
 
 
 
-$cl = new ClickHouseDB\Cluster(['host'=>'172.18.0.8','username'=>'default','password'=>'','port'=>8123]);
+$cl = new ClickHouseDB\Cluster(['host'=>'172.18.0.8', 'username'=>'default', 'password'=>'', 'port'=>8123]);
 
 $cl->setScanTimeOut(2.5); // 2500 ms
 $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());
 }
 
 print_r($cl->getClusterList());
@@ -25,10 +25,10 @@ 
 
 
 $cl->activeClient()->setTimeout(0.01);
-for ($z=0;$z<50;$z++)
+for ($z = 0; $z < 50; $z++)
 {
-    try{
-        $x=$cl->activeClient()->write("DROP TABLE IF EXISTS default.asdasdasd ON CLUSTER cluster2");
+    try {
+        $x = $cl->activeClient()->write("DROP TABLE IF EXISTS default.asdasdasd ON CLUSTER cluster2");
     }catch (Exception $exception)
     {
 
@@ -36,7 +36,7 @@ 
 }
 
 $cl->activeClient()->setTimeout(22);
-$x=$cl->activeClient()->write("DROP TABLE IF EXISTS default.asdasdasd ON CLUSTER cluster2");
+$x = $cl->activeClient()->write("DROP TABLE IF EXISTS default.asdasdasd ON CLUSTER cluster2");
 $x->dump();
 
 

Braces +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
 {
     try{
         $x=$cl->activeClient()->write("DROP TABLE IF EXISTS default.asdasdasd ON CLUSTER cluster2");
-    }catch (Exception $exception)
+    } catch (Exception $exception)
     {
 
     }

example/cluster/cluster_05_select_node.php

Spacing +4 added lines, -4 removed lines

@@ -12,16 +12,16 @@
 $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());
 }
 //
-$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";
 
 
 // Выбрать IP содержащий строку ".248" типа 123.123.123.248, разделитель ; - если не найдена первая берется
-$cli=$cl->clientLike($cluster_name,'.298;.964');
+$cli = $cl->clientLike($cluster_name, '.298;.964');
 $cli->ping();
 echo "\n----\nEND\n";
 // ----------------------------------------------------------------------

example/cluster/cluster_01_start.php

Spacing +4 added lines, -4 removed lines

@@ -10,7 +10,7 @@ 
 $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());
 }
 
 echo "Ips:\n";
@@ -19,13 +19,13 @@ 
 print_r($cl->getClusterList());
 
 //
-foreach (['pulse','repikator','sharovara','repikator3x','sharovara3x'] as $name)
+foreach (['pulse', 'repikator', 'sharovara', 'repikator3x', 'sharovara3x'] as $name)
 {
     echo "-------------------- $name ---------------------------\n";
     print_r($cl->getClusterNodes($name));
 
-    echo "> Count Shard   = ".$cl->getClusterCountShard($name)."\n";
-    echo "> Count Replica = ".$cl->getClusterCountReplica($name)."\n";
+    echo "> Count Shard   = " . $cl->getClusterCountShard($name) . "\n";
+    echo "> Count Replica = " . $cl->getClusterCountReplica($name) . "\n";
 }
 // ----------------------------------------------------------------------
 echo "\n----\nEND\n";

example/exam12_array.php

Spacing +22 added lines, -22 removed lines

@@ -51,7 +51,7 @@ 
 
 
 echo "\ntestRFCCSVWrite>>>>\n";
-$fileName='/tmp/testRFCCSVWrite.CSV';
+$fileName = '/tmp/testRFCCSVWrite.CSV';
 date_default_timezone_set('Europe/Moscow');
 $db->write("DROP TABLE IF EXISTS testRFCCSVWrite");
 $db->write('CREATE TABLE testRFCCSVWrite (
@@ -66,24 +66,24 @@ 
 
 @unlink($fileName);
 
-$data=[
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>'SOME STRING','flos'=>1.1,'ints'=>1,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>'SOME STRING','flos'=>2.3,'ints'=>2,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>'SOME\'STRING','flos'=>0,'ints'=>0,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>'SOME\'"TRING','flos'=>0,'ints'=>0,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>"SOMET\nRI\n\"N\"G\\XX_ABCDEFG",'flos'=>0,'ints'=>0,'arr1'=>[1,2,3],'arrs'=>["A","B\nD\nC"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>"ID_ARRAY",'flos'=>0,'ints'=>0,'arr1'=>[1,2,3],'arrs'=>["A","B\nD\nC"]]
+$data = [
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>'SOME STRING', 'flos'=>1.1, 'ints'=>1, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>'SOME STRING', 'flos'=>2.3, 'ints'=>2, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>'SOME\'STRING', 'flos'=>0, 'ints'=>0, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>'SOME\'"TRING', 'flos'=>0, 'ints'=>0, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>"SOMET\nRI\n\"N\"G\\XX_ABCDEFG", 'flos'=>0, 'ints'=>0, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B\nD\nC"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>"ID_ARRAY", 'flos'=>0, 'ints'=>0, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B\nD\nC"]]
 ];
 
 //// 1.1 + 2.3 = 3.3999999761581
 //
 foreach ($data as $row)
 {
-    file_put_contents($fileName,\ClickHouseDB\Quote\FormatLine::CSV($row)."\n",FILE_APPEND);
+    file_put_contents($fileName, \ClickHouseDB\Quote\FormatLine::CSV($row) . "\n", FILE_APPEND);
 }
 //
 echo "FILE:\n\n";
-echo file_get_contents($fileName)."\n\n----\n";
+echo file_get_contents($fileName) . "\n\n----\n";
 
 //
 $db->insertBatchFiles('testRFCCSVWrite', [$fileName], [
@@ -95,13 +95,13 @@ 
     'arrs',
 ]);
 
-$st=$db->select('SELECT * FROM testRFCCSVWrite');
+$st = $db->select('SELECT * FROM testRFCCSVWrite');
 print_r($st->rows());
 //
 
 
 echo "\n<<<<< TAB >>>>\n";
-$fileName='/tmp/testRFCCSVWrite.TAB';@unlink($fileName);
+$fileName = '/tmp/testRFCCSVWrite.TAB'; @unlink($fileName);
 
 
 $db->write("DROP TABLE IF EXISTS testTABWrite");
@@ -117,22 +117,22 @@ 
 
 
 
-$data=[
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>"STING\t\tSD!\"\nFCD\tSAD\t\nDSF",'flos'=>-2.3,'ints'=>123,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>'SOME\'STRING','flos'=>0,'ints'=>12123,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>'SOME\'"TR\tING','flos'=>0,'ints'=>0,'arr1'=>[1,2,3],'arrs'=>["A","B"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>"SOMET\nRI\n\"N\"G\\XX_ABCDEFG",'flos'=>0,'ints'=>1,'arr1'=>[1,2,3],'arrs'=>["A","B\nD\ns\tC"]],
-    ['event_time'=>date('Y-m-d H:i:s'),'strs'=>"ID_ARRAY",'flos'=>-2.3,'ints'=>-12123,'arr1'=>[1,2,3],'arrs'=>["A","B\nD\nC\n\t\n\tTABARRAYS"]]
+$data = [
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>"STING\t\tSD!\"\nFCD\tSAD\t\nDSF", 'flos'=>-2.3, 'ints'=>123, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>'SOME\'STRING', 'flos'=>0, 'ints'=>12123, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>'SOME\'"TR\tING', 'flos'=>0, 'ints'=>0, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>"SOMET\nRI\n\"N\"G\\XX_ABCDEFG", 'flos'=>0, 'ints'=>1, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B\nD\ns\tC"]],
+    ['event_time'=>date('Y-m-d H:i:s'), 'strs'=>"ID_ARRAY", 'flos'=>-2.3, 'ints'=>-12123, 'arr1'=>[1, 2, 3], 'arrs'=>["A", "B\nD\nC\n\t\n\tTABARRAYS"]]
 ];
 
 
 foreach ($data as $row)
 {
-    file_put_contents($fileName,\ClickHouseDB\Quote\FormatLine::TSV($row)."\n",FILE_APPEND);
+    file_put_contents($fileName, \ClickHouseDB\Quote\FormatLine::TSV($row) . "\n", FILE_APPEND);
 }
 //
 echo "FILE:\n\n";
-echo file_get_contents($fileName)."\n\n----\n";
+echo file_get_contents($fileName) . "\n\n----\n";
 
 //
 $db->insertBatchTSVFiles('testTABWrite', [$fileName], [
@@ -144,9 +144,9 @@ 
     'arrs',
 ]);
 
-$st=$db->select('SELECT * FROM testTABWrite');
+$st = $db->select('SELECT * FROM testTABWrite');
 print_r($st->rows());
-$st=$db->select('SELECT round(sum(flos),5),sum(ints) FROM testTABWrite');
+$st = $db->select('SELECT round(sum(flos),5),sum(ints) FROM testTABWrite');
 print_r($st->rows());
 
 //
\ No newline at end of file

example/lib_example.php

Spacing +17 added lines, -17 removed lines

@@ -1,8 +1,8 @@ 
 <?php
 
 date_default_timezone_set('Europe/Moscow');
-error_reporting( E_ALL );
-ini_set('display_errors',1);
+error_reporting(E_ALL);
+ini_set('display_errors', 1);
 
 /**
  * @param $file_name
@@ -53,38 +53,38 @@ 
 
 class memoryUsage
 {
-    private static $last=[];
+    private static $last = [];
     /**
      * @return array
      */
     public static function memoryGetUsage()
     {
-        return ['mem'=>memory_get_usage(),'peak'=>memory_get_peak_usage()];
+        return ['mem'=>memory_get_usage(), 'peak'=>memory_get_peak_usage()];
 
     }
 
     public static function showPeak()
     {
-        echo "Peak        : \t".chr(27) ."[32m".humanFileSize(memory_get_peak_usage())."\033[0m "."\n";
+        echo "Peak        : \t" . chr(27) . "[32m" . humanFileSize(memory_get_peak_usage()) . "\033[0m " . "\n";
     }
-    public static function show($msg='')
+    public static function show($msg = '')
     {
-        $pre=false;
+        $pre = false;
         if (self::$last)
         {
-            $pre=self::$last;
+            $pre = self::$last;
         }
-        self::$last=self::memoryGetUsage();
-        $data=self::$last;
-        $txt=humanFileSize($data['mem']);
+        self::$last = self::memoryGetUsage();
+        $data = self::$last;
+        $txt = humanFileSize($data['mem']);
 
         if ($pre)
         {
-            $mem=$data['mem']-$pre['mem'];
-            $mem=($mem<0?'-':'+').humanFileSize(abs($mem));
-            $txt.= "\t\t\t Delta : ".$mem;
+            $mem = $data['mem'] - $pre['mem'];
+            $mem = ($mem < 0 ? '-' : '+') . humanFileSize(abs($mem));
+            $txt .= "\t\t\t Delta : " . $mem;
         }
-        echo "MemoryUsage : \t".chr(27) ."[33m".$txt."\033[0m ".($msg?' <<< '.$msg:'')."\n";
+        echo "MemoryUsage : \t" . chr(27) . "[33m" . $txt . "\033[0m " . ($msg ? ' <<< ' . $msg : '') . "\n";
     }
 }
 
@@ -180,7 +180,7 @@ 
  * @param int $size
  * @return bool
  */
-function makeSomeDataFileBig($file_name, $size = 10,$shift=0)
+function makeSomeDataFileBig($file_name, $size = 10, $shift = 0)
 {
     if (is_file($file_name)) {
         echo "Exist file  [$file_name]: ± rows... size = " . humanFileSize(filesize($file_name)) . " \n";
@@ -201,7 +201,7 @@ 
                 for ($hours = 0; $hours < 24; $hours++) {
                     $z++;
 
-                    $dt = strtotime('-' . ($dates+$shift) . ' day');
+                    $dt = strtotime('-' . ($dates + $shift) . ' day');
                     $dt = strtotime('-' . $hours . ' hour', $dt);
 
                     $j = [];

Braces +4 added lines, -2 removed lines

@@ -157,8 +157,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;