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_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/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");

src/Statement.php

Spacing +4 added lines, -4 removed lines

@@ -148,7 +148,7 @@ 
 
         $body = $this->response()->body();
         $error_no = $this->response()->error_no();
-        $error=$this->response()->error();
+        $error = $this->response()->error();
 
         if (!$error_no && !$error) {
             $parse = $this->parseErrorClickHouse($body);
@@ -158,7 +158,7 @@ 
             }
             else {
                 $code = $this->response()->http_code();
-                $message = "HttpCode:" . $this->response()->http_code() . " ; ".$this->response()->error()." ;" . $body;
+                $message = "HttpCode:" . $this->response()->http_code() . " ; " . $this->response()->error() . " ;" . $body;
             }
         }
         else {
@@ -212,7 +212,7 @@ 
             return false;
         }
 
-        foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least','statistics'] as $key) {
+        foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
             if (isset($this->_rawData[$key])) {
                 $this->{$key} = $this->_rawData[$key];
             }
@@ -325,7 +325,7 @@ 
      * @param bool $key
      * @return array|mixed|null
      */
-    public function statistics($key=false)
+    public function statistics($key = false)
     {
         $this->init();
         if ($key)

Braces +12 added lines, -14 removed lines

@@ -155,13 +155,11 @@ 
 
             if ($parse) {
                 throw new DatabaseException($parse['message'] . "\nIN:" . $this->sql(), $parse['code']);
-            }
-            else {
+            } else {
                 $code = $this->response()->http_code();
                 $message = "HttpCode:" . $this->response()->http_code() . " ; ".$this->response()->error()." ;" . $body;
             }
-        }
-        else {
+        } else {
             $code = $error_no;
             $message = $this->response()->error();
         }
@@ -330,8 +328,12 @@ 
         $this->init();
         if ($key)
         {
-            if (!is_array($this->statistics)) return null;
-            if (!isset($this->statistics[$key])) return null;
+            if (!is_array($this->statistics)) {
+                return null;
+            }
+            if (!isset($this->statistics[$key])) {
+                return null;
+            }
             return $this->statistics[$key];
         }
         return $this->statistics;
@@ -373,8 +375,7 @@ 
             if ($key) {
                 if (isset($this->array_data[0][$key])) {
                     return $this->array_data[0][$key];
-                }
-                else {
+                } else {
                     return null;
                 }
             }
@@ -464,16 +465,14 @@ 
     {
         if (is_array($path)) {
             $keys = $path;
-        }
-        else {
+        } else {
             $args = func_get_args();
             array_shift($args);
 
             if (sizeof($args) < 2) {
                 $separator = '.';
                 $keys = explode($separator, $path);
-            }
-            else {
+            } else {
                 $keys = $args;
             }
         }
@@ -485,8 +484,7 @@ 
 
             if (isset($arr[$key])) {
                 $val = $arr[$key];
-            }
-            else {
+            } else {
                 $val = $key;
             }