smi2 / phpClickHouse

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

src/Quote/StrictQuoteLine.php

Spacing +10 added lines, -10 removed lines

@@ -6,7 +6,7 @@ 
 class StrictQuoteLine
 {
 
-    private $preset=[
+    private $preset = [
         'CSV'=>[
             'EnclosureArray'=>'"',
             'EncodeEnclosure'=>'"',
@@ -32,19 +32,19 @@ 
             'TabEncode'=>true,
         ],
     ];
-    private $settings=[];
+    private $settings = [];
 
     public function __construct($format)
     {
         if (empty($this->preset[$format]))
         {
-            throw new QueryException("Unsupport format encode line:".$format);
+            throw new QueryException("Unsupport format encode line:" . $format);
         }
-        $this->settings=$this->preset[$format];
+        $this->settings = $this->preset[$format];
     }
     public function quoteRow($row)
     {
-        return implode($this->settings['Delimiter'],$this->quoteValue($row));
+        return implode($this->settings['Delimiter'], $this->quoteValue($row));
     }
     public function quoteValue($row)
     {
@@ -53,10 +53,10 @@ 
         $encode = $this->settings['EncodeEnclosure'];
         $encodeArray = $this->settings['EnclosureArray'];
         $null = $this->settings['Null'];
-        $tabEncode=$this->settings['TabEncode'];
+        $tabEncode = $this->settings['TabEncode'];
 
 
-        $quote = function ($value) use ($enclosure,$delimiter,$encode,$encodeArray,$null,$tabEncode) {
+        $quote = function($value) use ($enclosure, $delimiter, $encode, $encodeArray, $null, $tabEncode) {
 
 
 
@@ -75,11 +75,11 @@ 
             if (is_string($value)) {
                 if ($tabEncode)
                 {
-                    return str_replace(["\t","\n"],['\\t','\\n'],$value);
+                    return str_replace(["\t", "\n"], ['\\t', '\\n'], $value);
                 }
 
                 $value = strval($value);
-                $value = preg_replace('/('.$enclosure_esc.'|'.$encode_esc.')/',$encode_esc.'\1', $value);
+                $value = preg_replace('/(' . $enclosure_esc . '|' . $encode_esc . ')/', $encode_esc . '\1', $value);
                 return $enclosure . $value . $enclosure;
             }
 
@@ -90,7 +90,7 @@ 
                 // as in the TabSeparated format, and then the resulting string is output in InsertRow in double quotes.
                 $result_array = FormatLine::Insert($value);
 
-                return $encodeArray . '[' . $result_array . ']' .$encodeArray;
+                return $encodeArray . '[' . $result_array . ']' . $encodeArray;
             }
 
             if (null === $value) {

src/Quote/FormatLine.php

Spacing +2 added lines, -2 removed lines

@@ -8,7 +8,7 @@ 
      *
      * @var array
      */
-    private static $strict=[];
+    private static $strict = [];
 
     /**
      * Format
@@ -20,7 +20,7 @@ 
     {
         if (empty(self::$strict[$format]))
         {
-            self::$strict[$format]=new StrictQuoteLine($format);
+            self::$strict[$format] = new StrictQuoteLine($format);
         }
         return self::$strict[$format];
     }

src/Query/Degeneration/Bindings.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function bindParams(array $bindings)
     {
-        $this->bindings=[];
+        $this->bindings = [];
         foreach ($bindings as $column => $value) {
             $this->bindParam($column, $value);
         }