smi2 / phpClickHouse

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

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 = [];

example/exam14_Statistics_in_JSON.php

Spacing +3 added lines, -3 removed lines

@@ -24,9 +24,9 @@
 
 
 
-echo 'elapsed   :'.$result->statistics('elapsed')."\n";
-echo 'rows_read :'.$result->statistics('rows_read')."\n";
-echo 'bytes_read:'.$result->statistics('bytes_read')."\n";
+echo 'elapsed   :' . $result->statistics('elapsed') . "\n";
+echo 'rows_read :' . $result->statistics('rows_read') . "\n";
+echo 'bytes_read:' . $result->statistics('bytes_read') . "\n";
 
 //
 $result = $db->select("SELECT 12 as ping");