Passed
Push — master ( 94ffb8...e27b04 )
by Igor
02:11
created
src/Transport/CurlerRequest.php 1 patch
Spacing   +9 added lines, -9 removed lines patch added patch discarded remove patch
@@ -109,13 +109,13 @@  discard block
 block discarded – undo
109 109
             CURLOPT_SSL_VERIFYHOST => 0,
110 110
             CURLOPT_SSL_VERIFYPEER => false,
111 111
             CURLOPT_TIMEOUT => 10,
112
-            CURLOPT_CONNECTTIMEOUT => 5,    // Количество секунд ожидания при попытке соединения
112
+            CURLOPT_CONNECTTIMEOUT => 5, // Количество секунд ожидания при попытке соединения
113 113
             CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
114 114
             CURLOPT_MAXREDIRS => 10,
115 115
             CURLOPT_HEADER => TRUE,
116 116
             CURLOPT_FOLLOWLOCATION => TRUE,
117
-            CURLOPT_AUTOREFERER => 1,       // при редиректе подставлять в «Referer:» значение из «Location:»
118
-            CURLOPT_BINARYTRANSFER => 1,    // передавать в binary-safe
117
+            CURLOPT_AUTOREFERER => 1, // при редиректе подставлять в «Referer:» значение из «Location:»
118
+            CURLOPT_BINARYTRANSFER => 1, // передавать в binary-safe
119 119
             CURLOPT_RETURNTRANSFER => TRUE,
120 120
             CURLOPT_USERAGENT => 'smi2/PHPClickHouse/client',
121 121
         );
@@ -234,7 +234,7 @@  discard block
 block discarded – undo
234 234
     }
235 235
     public function setReadFunction($callback)
236 236
     {
237
-        $this->options[CURLOPT_READFUNCTION]=$callback;
237
+        $this->options[CURLOPT_READFUNCTION] = $callback;
238 238
     }
239 239
 
240 240
     /**
@@ -352,9 +352,9 @@  discard block
 block discarded – undo
352 352
 
353 353
     public function getHeaders()
354 354
     {
355
-        $head=[];
355
+        $head = [];
356 356
         foreach ($this->headers as $key=>$value)
357
-            $head[]= sprintf("%s: %s", $key, $value);
357
+            $head[] = sprintf("%s: %s", $key, $value);
358 358
         return $head;
359 359
     }
360 360
 
@@ -628,8 +628,8 @@  discard block
 block discarded – undo
628 628
             throw new \Exception('setFunctionProgress not is_callable');
629 629
         }
630 630
 
631
-        $this->option(CURLOPT_NOPROGRESS,false);
632
-        $this->option(CURLOPT_PROGRESSFUNCTION,$callback); // version 5.5.0
631
+        $this->option(CURLOPT_NOPROGRESS, false);
632
+        $this->option(CURLOPT_PROGRESSFUNCTION, $callback); // version 5.5.0
633 633
     }
634 634
 
635 635
 
@@ -692,7 +692,7 @@  discard block
 block discarded – undo
692 692
         }
693 693
 
694 694
         if ($this->options[CURLOPT_VERBOSE]) {
695
-            echo "\n-----------BODY REQUEST----------\n".$curl_opt[CURLOPT_POSTFIELDS]."\n------END--------\n";
695
+            echo "\n-----------BODY REQUEST----------\n" . $curl_opt[CURLOPT_POSTFIELDS] . "\n------END--------\n";
696 696
         }
697 697
         curl_setopt_array($this->handle, $curl_opt);
698 698
         return true;
Please login to merge, or discard this patch.
src/Transport/CurlerResponse.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -70,7 +70,7 @@  discard block
 block discarded – undo
70 70
      */
71 71
     public function total_time()
72 72
     {
73
-        return round($this->_info['total_time'],3);
73
+        return round($this->_info['total_time'], 3);
74 74
     }
75 75
 
76 76
     /**
@@ -78,7 +78,7 @@  discard block
 block discarded – undo
78 78
      */
79 79
     public function starttransfer_time()
80 80
     {
81
-        return round($this->_info['starttransfer_time'],3);
81
+        return round($this->_info['starttransfer_time'], 3);
82 82
     }
83 83
 
84 84
     /**
@@ -86,7 +86,7 @@  discard block
 block discarded – undo
86 86
      */
87 87
     public function connect_time()
88 88
     {
89
-        return round($this->_info['connect_time'],3);
89
+        return round($this->_info['connect_time'], 3);
90 90
     }
91 91
 
92 92
     /**
@@ -94,7 +94,7 @@  discard block
 block discarded – undo
94 94
      */
95 95
     public function pretransfer_time()
96 96
     {
97
-        return round($this->_info['pretransfer_time'],3);
97
+        return round($this->_info['pretransfer_time'], 3);
98 98
     }
99 99
 
100 100
     /**
@@ -289,7 +289,7 @@  discard block
 block discarded – undo
289 289
      */
290 290
     public function rawDataOrJson($format)
291 291
     {
292
-        if (stripos($format,'json')!==false)
292
+        if (stripos($format, 'json') !== false)
293 293
         {
294 294
             return $this->json();
295 295
         }
Please login to merge, or discard this patch.
src/Cluster.php 1 patch
Spacing   +39 added lines, -39 removed lines patch added patch discarded remove patch
@@ -42,7 +42,7 @@  discard block
 block discarded – undo
42 42
     /**
43 43
      * @var int
44 44
      */
45
-    private $scanTimeOut=10;
45
+    private $scanTimeOut = 10;
46 46
 
47 47
     /**
48 48
      * @var array
@@ -77,7 +77,7 @@  discard block
 block discarded – undo
77 77
      *
78 78
      * @var array
79 79
      */
80
-    private $_table_size_cache=[];
80
+    private $_table_size_cache = [];
81 81
 
82 82
     /**
83 83
      * Cluster constructor.
@@ -191,7 +191,7 @@  discard block
 block discarded – undo
191 191
 
192 192
             // @todo : rewrite total_replicas=1 если кластер без реплики , нужно проверять какой класте и сколько в нем реплик
193 193
 //            if ($replica['total_replicas']<2) {$ok=false;$this->error[]='total_replicas : '.json_encode($replica);}
194
-            if ($this->softCheck )
194
+            if ($this->softCheck)
195 195
             {
196 196
                 if (!$ok) break;
197 197
                 continue;
@@ -262,7 +262,7 @@  discard block
 block discarded – undo
262 262
             $statementsClusters[$node]->getRequest()->setDnsCache(0)->timeOut($this->scanTimeOut)->connectTimeOut($this->scanTimeOut);
263 263
         }
264 264
         $this->defaultClient()->executeAsync();
265
-        $tables=[];
265
+        $tables = [];
266 266
 
267 267
         foreach ($this->nodes as $node) {
268 268
 
@@ -270,16 +270,16 @@  discard block
 block discarded – undo
270 270
             try {
271 271
                 $r = $statementsReplicas[$node]->rows();
272 272
                 foreach ($r as $row) {
273
-                    $tables[$row['database']][$row['table']][$node] =$row;
273
+                    $tables[$row['database']][$row['table']][$node] = $row;
274 274
                 }
275 275
                 $result['replicas'][$node] = $r;
276
-            } catch (\Exception $E) {
276
+            }catch (\Exception $E) {
277 277
                 $result['replicas'][$node] = false;
278 278
                 $badNodes[$node] = $E->getMessage();
279 279
                 $this->error[] = 'statementsReplicas:' . $E->getMessage();
280 280
             }
281 281
             // ---------------------------------------------------------------------------------------------------
282
-            $hosts=[];
282
+            $hosts = [];
283 283
 
284 284
             try {
285 285
                 $c = $statementsClusters[$node]->rows();
@@ -295,7 +295,7 @@  discard block
 block discarded – undo
295 295
                         ];
296 296
                 }
297 297
 
298
-            } catch (\Exception $E) {
298
+            }catch (\Exception $E) {
299 299
                 $result['clusters'][$node] = false;
300 300
 
301 301
                 $this->error[] = 'clusters:' . $E->getMessage();
@@ -360,22 +360,22 @@  discard block
 block discarded – undo
360 360
     /**
361 361
      * @return Client
362 362
      */
363
-    public function clientLike($cluster,$ip_addr_like)
363
+    public function clientLike($cluster, $ip_addr_like)
364 364
     {
365
-        $nodes_check=$this->nodes;
366
-        $nodes=$this->getClusterNodes($cluster);
367
-        $list_ips_need=explode(';',$ip_addr_like);
368
-        $find=false;
369
-        foreach($list_ips_need as $like)
365
+        $nodes_check = $this->nodes;
366
+        $nodes = $this->getClusterNodes($cluster);
367
+        $list_ips_need = explode(';', $ip_addr_like);
368
+        $find = false;
369
+        foreach ($list_ips_need as $like)
370 370
         {
371 371
             foreach ($nodes as $node)
372 372
             {
373 373
 
374
-                if (stripos($node,$like)!==false)
374
+                if (stripos($node, $like) !== false)
375 375
                 {
376
-                    if (in_array($node,$nodes_check))
376
+                    if (in_array($node, $nodes_check))
377 377
                     {
378
-                        $find=$node;
378
+                        $find = $node;
379 379
                     }
380 380
                     else
381 381
                     {
@@ -387,8 +387,8 @@  discard block
 block discarded – undo
387 387
             }
388 388
             if ($find) break;
389 389
         }
390
-        if (!$find){
391
-            $find=$nodes[0];
390
+        if (!$find) {
391
+            $find = $nodes[0];
392 392
         }
393 393
         return $this->client($find);
394 394
     }
@@ -462,10 +462,10 @@  discard block
 block discarded – undo
462 462
      *
463 463
      * @return array
464 464
      */
465
-    public function getTables($resultDetail=false)
465
+    public function getTables($resultDetail = false)
466 466
     {
467 467
         $this->connect();
468
-        $list=[];
468
+        $list = [];
469 469
         foreach ($this->tables as $db_name=>$tables)
470 470
         {
471 471
             foreach ($tables as $table_name=>$nodes)
@@ -473,11 +473,11 @@  discard block
 block discarded – undo
473 473
 
474 474
                 if ($resultDetail)
475 475
                 {
476
-                    $list[$db_name.'.'.$table_name]=$nodes;
476
+                    $list[$db_name . '.' . $table_name] = $nodes;
477 477
                 }
478 478
                 else
479 479
                 {
480
-                    $list[$db_name.'.'.$table_name]=array_keys($nodes);
480
+                    $list[$db_name . '.' . $table_name] = array_keys($nodes);
481 481
                 }
482 482
             }
483 483
         }
@@ -493,24 +493,24 @@  discard block
 block discarded – undo
493 493
      */
494 494
     public function getSizeTable($database_table)
495 495
     {
496
-       $list=[];
497
-       $nodes=$this->getNodesByTable($database_table);
496
+       $list = [];
497
+       $nodes = $this->getNodesByTable($database_table);
498 498
         // scan need node`s
499 499
         foreach ($nodes as $node)
500 500
         {
501 501
             if (empty($this->_table_size_cache[$node]))
502 502
             {
503
-                $this->_table_size_cache[$node]=$this->client($node)->tablesSize(true);
503
+                $this->_table_size_cache[$node] = $this->client($node)->tablesSize(true);
504 504
             }
505 505
         }
506 506
 
507
-        $sizes=[];
507
+        $sizes = [];
508 508
         foreach ($this->_table_size_cache as $node=>$rows)
509 509
         {
510 510
             foreach ($rows as $row)
511 511
             {
512
-                $sizes[$row['database'].'.'.$row['table']][$node]=$row;
513
-                @$sizes[$row['database'].'.'.$row['table']]['total']['sizebytes']+=$row['sizebytes'];
512
+                $sizes[$row['database'] . '.' . $row['table']][$node] = $row;
513
+                @$sizes[$row['database'] . '.' . $row['table']]['total']['sizebytes'] += $row['sizebytes'];
514 514
 
515 515
 
516 516
 
@@ -531,17 +531,17 @@  discard block
 block discarded – undo
531 531
      * @param $database_table
532 532
      * @return array
533 533
      */
534
-    public function truncateTable($database_table,$timeOut=2000)
534
+    public function truncateTable($database_table, $timeOut = 2000)
535 535
     {
536
-        $out=[];
537
-        list($db,$table)=explode('.',$database_table);
538
-        $nodes=$this->getMasterNodeForTable($database_table);
536
+        $out = [];
537
+        list($db, $table) = explode('.', $database_table);
538
+        $nodes = $this->getMasterNodeForTable($database_table);
539 539
         // scan need node`s
540 540
         foreach ($nodes as $node)
541 541
         {
542
-            $def=$this->client($node)->getTimeout();
542
+            $def = $this->client($node)->getTimeout();
543 543
             $this->client($node)->database($db)->setTimeout($timeOut);
544
-            $out[$node]=$this->client($node)->truncateTable($table);
544
+            $out[$node] = $this->client($node)->truncateTable($table);
545 545
             $this->client($node)->setTimeout($def);
546 546
         }
547 547
         return $out;
@@ -555,15 +555,15 @@  discard block
 block discarded – undo
555 555
      */
556 556
     public function getMasterNodeForTable($database_table)
557 557
     {
558
-        $list=$this->getTables(true);
558
+        $list = $this->getTables(true);
559 559
 
560 560
         if (empty($list[$database_table])) return [];
561 561
 
562 562
 
563
-        $result=[];
563
+        $result = [];
564 564
         foreach ($list[$database_table] as $node=>$row)
565 565
         {
566
-            if ($row['is_leader']) $result[]=$node;
566
+            if ($row['is_leader']) $result[] = $node;
567 567
         }
568 568
         return $result;
569 569
     }
@@ -575,7 +575,7 @@  discard block
 block discarded – undo
575 575
      */
576 576
     public function getNodesByTable($database_table)
577 577
     {
578
-        $list=$this->getTables();
578
+        $list = $this->getTables();
579 579
         if (empty($list[$database_table])) {
580 580
             throw new QueryException('Not find :' . $database_table);
581 581
         }
Please login to merge, or discard this patch.
src/Settings.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -16,12 +16,12 @@  discard block
 block discarded – undo
16 16
      */
17 17
     private $settings = [];
18 18
 
19
-    private $_ReadOnlyUser=false;
19
+    private $_ReadOnlyUser = false;
20 20
 
21 21
     /**
22 22
      * @var bool
23 23
      */
24
-    private $_isHttps=false;
24
+    private $_isHttps = false;
25 25
 
26 26
     /**
27 27
      * Settings constructor.
@@ -116,7 +116,7 @@  discard block
 block discarded – undo
116 116
     }
117 117
 
118 118
 
119
-    public function https($flag=true)
119
+    public function https($flag = true)
120 120
     {
121 121
         $this->set('https', $flag);
122 122
         return $this;
@@ -201,7 +201,7 @@  discard block
 block discarded – undo
201 201
      */
202 202
     public function setReadOnlyUser($flag)
203 203
     {
204
-        $this->_ReadOnlyUser=$flag;
204
+        $this->_ReadOnlyUser = $flag;
205 205
     }
206 206
 
207 207
     /**
Please login to merge, or discard this patch.
src/Transport/Http.php 1 patch
Spacing   +17 added lines, -17 removed lines patch added patch discarded remove patch
@@ -61,7 +61,7 @@  discard block
 block discarded – undo
61 61
     /**
62 62
      * @var bool
63 63
      */
64
-    private $xClickHouseProgress=false;
64
+    private $xClickHouseProgress = false;
65 65
 
66 66
     /**
67 67
      * Http constructor.
@@ -113,10 +113,10 @@  discard block
 block discarded – undo
113 113
      */
114 114
     public function getUri()
115 115
     {
116
-        $proto='http';
117
-        if ($this->settings()->isHttps()) $proto='https';
116
+        $proto = 'http';
117
+        if ($this->settings()->isHttps()) $proto = 'https';
118 118
 
119
-        return $proto.'://' . $this->_host . ':' . $this->_port;
119
+        return $proto . '://' . $this->_host . ':' . $this->_port;
120 120
     }
121 121
 
122 122
     /**
@@ -185,7 +185,7 @@  discard block
 block discarded – undo
185 185
         }
186 186
 
187 187
         $new->timeOut($this->settings()->getTimeOut());
188
-        $new->connectTimeOut($this->_connectTimeOut)->keepAlive();// one sec
188
+        $new->connectTimeOut($this->_connectTimeOut)->keepAlive(); // one sec
189 189
         $new->verbose($this->_verbose);
190 190
 
191 191
         return $new;
@@ -279,7 +279,7 @@  discard block
 block discarded – undo
279 279
         $request = $this->newRequest($extendinfo);
280 280
         $request->url($url);
281 281
 
282
-        $request->setCallbackFunction(function (CurlerRequest $request) {
282
+        $request->setCallbackFunction(function(CurlerRequest $request) {
283 283
             fclose($request->getInfileHandle());
284 284
         });
285 285
 
@@ -322,29 +322,29 @@  discard block
 block discarded – undo
322 322
 
323 323
     public function __findXClickHouseProgress($handle)
324 324
     {
325
-        $code=curl_getinfo($handle,CURLINFO_HTTP_CODE);
325
+        $code = curl_getinfo($handle, CURLINFO_HTTP_CODE);
326 326
 
327 327
         // Search X-ClickHouse-Progress
328
-        if ($code==200) {
328
+        if ($code == 200) {
329 329
             $response = curl_multi_getcontent($handle);
330 330
             $header_size = curl_getinfo($handle, CURLINFO_HEADER_SIZE);
331 331
             if (!$header_size) return false;
332 332
 
333 333
             $header = substr($response, 0, $header_size);
334 334
             if (!$header_size) return false;
335
-            $pos=strrpos($header,'X-ClickHouse-Progress');
335
+            $pos = strrpos($header, 'X-ClickHouse-Progress');
336 336
 
337 337
             if (!$pos) return false;
338 338
 
339
-            $last=substr($header,$pos);
340
-            $data=@json_decode(str_ireplace('X-ClickHouse-Progress:','',$last),true);
339
+            $last = substr($header, $pos);
340
+            $data = @json_decode(str_ireplace('X-ClickHouse-Progress:', '', $last), true);
341 341
 
342 342
             if ($data && is_callable($this->xClickHouseProgress)) {
343 343
 
344
-                if (is_array($this->xClickHouseProgress)){
345
-                    call_user_func_array($this->xClickHouseProgress,[$data]);
344
+                if (is_array($this->xClickHouseProgress)) {
345
+                    call_user_func_array($this->xClickHouseProgress, [$data]);
346 346
                 } else {
347
-                    call_user_func($this->xClickHouseProgress,$data);
347
+                    call_user_func($this->xClickHouseProgress, $data);
348 348
                 }
349 349
 
350 350
 
@@ -407,13 +407,13 @@  discard block
 block discarded – undo
407 407
             }
408 408
 
409 409
 
410
-            $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function (CurlerRequest $request) {
410
+            $request->setResultFileHandle($fout, $isGz)->setCallbackFunction(function(CurlerRequest $request) {
411 411
                 fclose($request->getResultFileHandle());
412 412
             });
413 413
         }
414 414
         if ($this->xClickHouseProgress)
415 415
         {
416
-            $request->setFunctionProgress([$this,'__findXClickHouseProgress']);
416
+            $request->setFunctionProgress([$this, '__findXClickHouseProgress']);
417 417
         }
418 418
         // ---------------------------------------------------------------------------------
419 419
         return $request;
@@ -541,7 +541,7 @@  discard block
 block discarded – undo
541 541
      */
542 542
     public function setProgressFunction(callable $callback)
543 543
     {
544
-        $this->xClickHouseProgress=$callback;
544
+        $this->xClickHouseProgress = $callback;
545 545
     }
546 546
 
547 547
     /**
Please login to merge, or discard this patch.
example/cluster/cluster_06_truncate_table.php 1 patch
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -13,27 +13,27 @@
 block discarded – undo
13 13
 $cl->setSoftCheck(true);
14 14
 if (!$cl->isReplicasIsOk())
15 15
 {
16
-    throw new Exception('Replica state is bad , error='.$cl->getError());
16
+    throw new Exception('Replica state is bad , error=' . $cl->getError());
17 17
 }
18 18
 
19 19
 
20
-$tables=$cl->getTables();
20
+$tables = $cl->getTables();
21 21
 
22 22
 foreach ($tables as $dbtable=>$tmp)
23 23
 {
24 24
     echo ">>> $dbtable :";
25 25
 
26
-    $size=$cl->getSizeTable($dbtable);
26
+    $size = $cl->getSizeTable($dbtable);
27 27
 
28 28
 
29
-    echo "\t".\ClickHouseDB\Example\Helper::humanFileSize($size)."\n";
29
+    echo "\t" . \ClickHouseDB\Example\Helper::humanFileSize($size) . "\n";
30 30
 
31 31
 }
32 32
 
33 33
 
34
-$table_for_truncate='target.events_sharded';
34
+$table_for_truncate = 'target.events_sharded';
35 35
 
36
-$result=$cl->truncateTable($table_for_truncate);
36
+$result = $cl->truncateTable($table_for_truncate);
37 37
 
38 38
 echo "Result:truncate table\n";
39 39
 print_r($result);
Please login to merge, or discard this patch.
example/exam17_sample_data_cityHash64.php 1 patch
Spacing   +29 added lines, -29 removed lines patch added patch discarded remove patch
@@ -8,20 +8,20 @@  discard block
 block discarded – undo
8 8
 
9 9
 
10 10
 $db = new ClickHouseDB\Client($config);
11
-$_flag_create_table=false;
11
+$_flag_create_table = false;
12 12
 
13
-$size=$db->tableSize('summing_url_views_cityHash64_site_id');
14
-echo "Site table summing_url_views_cityHash64_site_id : ".(isset($size['size'])?$size['size']:'false')."\n";
13
+$size = $db->tableSize('summing_url_views_cityHash64_site_id');
14
+echo "Site table summing_url_views_cityHash64_site_id : " . (isset($size['size']) ? $size['size'] : 'false') . "\n";
15 15
 
16 16
 
17
-if (!isset($size['size'])) $_flag_create_table=true;
17
+if (!isset($size['size'])) $_flag_create_table = true;
18 18
 
19 19
 
20 20
 if ($_flag_create_table) {
21 21
 
22 22
 
23 23
     $db->write("DROP TABLE IF EXISTS summing_url_views_cityHash64_site_id");
24
-    $re=$db->write('
24
+    $re = $db->write('
25 25
                 CREATE TABLE IF NOT EXISTS summing_url_views_cityHash64_site_id (
26 26
                     event_date Date DEFAULT toDate(event_time),
27 27
                     event_time DateTime,
@@ -48,8 +48,8 @@  discard block
 block discarded – undo
48 48
     $c = 0;
49 49
     foreach ($file_data_names as $file_name) {
50 50
         $c++;
51
-        $shift_days=( -1* $c*3);
52
-        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 23 * $c,$shift_days);
51
+        $shift_days = ( -1 * $c * 3);
52
+        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 23 * $c, $shift_days);
53 53
     }
54 54
 
55 55
     echo "----------------------------------------------------------------------------------------------------\n";
@@ -75,56 +75,56 @@  discard block
 block discarded – undo
75 75
 }
76 76
 echo "------------------------------- COMPARE event_date ---------------------------------------------------------------------\n";
77 77
 
78
-$rows=($db->select('select event_date,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
78
+$rows = ($db->select('select event_date,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
79 79
 
80
-$samp=($db->select('select event_date,(sum(views)*10) as v from summing_url_views_cityHash64_site_id SAMPLE 0.1 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
80
+$samp = ($db->select('select event_date,(sum(views)*10) as v from summing_url_views_cityHash64_site_id SAMPLE 0.1 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
81 81
 
82 82
 
83 83
 foreach ($rows as $event_date=>$data)
84 84
 {
85
-    echo $event_date."\t".$data['v']."\t".@$samp[$event_date]['v']."\n";
85
+    echo $event_date . "\t" . $data['v'] . "\t" . @$samp[$event_date]['v'] . "\n";
86 86
 }
87 87
 
88 88
 
89
-$rows=($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
89
+$rows = ($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
90 90
 
91
-$samp=($db->select('select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
91
+$samp = ($db->select('select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
92 92
 
93 93
 
94 94
 foreach ($rows as $event_date=>$data)
95 95
 {
96
-    echo $event_date."\t".$data['v']."\t".intval(@$samp[$event_date]['v'])."\n";
96
+    echo $event_date . "\t" . $data['v'] . "\t" . intval(@$samp[$event_date]['v']) . "\n";
97 97
 }
98 98
 
99 99
 
100 100
 
101
-for($f=1;$f<=9;$f++)
101
+for ($f = 1; $f <= 9; $f++)
102 102
 {
103
-    $SAMPLE=$f/10;
103
+    $SAMPLE = $f / 10;
104 104
 
105
-    $CQL='select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE '.$SAMPLE.' WHERE site_id=34 GROUP BY site_id ORDER BY site_id ';
105
+    $CQL = 'select site_id,(sum(views)) as v from summing_url_views_cityHash64_site_id SAMPLE ' . $SAMPLE . ' WHERE site_id=34 GROUP BY site_id ORDER BY site_id ';
106 106
 
107
-    echo $CQL."\n";
108
-    $rows=($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id WHERE site_id=34 GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
109
-    $samp=($db->select($CQL)->rowsAsTree('site_id'));
107
+    echo $CQL . "\n";
108
+    $rows = ($db->select('select site_id,sum(views) as v from summing_url_views_cityHash64_site_id WHERE site_id=34 GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
109
+    $samp = ($db->select($CQL)->rowsAsTree('site_id'));
110 110
     foreach ($rows as $id=>$data)
111 111
     {
112
-            $s=$samp[$id]['v'];
113
-            $v=$data['v'];
112
+            $s = $samp[$id]['v'];
113
+            $v = $data['v'];
114 114
 
115 115
 
116
-            $percent=round( (100*$s) /$v   ,2);
116
+            $percent = round((100 * $s) / $v, 2);
117 117
 
118
-            $kof=(100/$percent);
119
-            $norma_views=$s*(100/$percent);
118
+            $kof = (100 / $percent);
119
+            $norma_views = $s * (100 / $percent);
120 120
 
121 121
 
122 122
 
123
-            echo "Сумма показов без SAMPLE  =  " .$v."\n";
124
-            echo "Сумма показов c   SAMPLE  =  " .$s."\n";
125
-            echo "Процент                   =  " .$percent."\n";
126
-            echo "На что домжнож.семлир.данн=  " .$kof."\n";
127
-            echo "Сумма показов расчитанное =  " .$norma_views."\n";
123
+            echo "Сумма показов без SAMPLE  =  " . $v . "\n";
124
+            echo "Сумма показов c   SAMPLE  =  " . $s . "\n";
125
+            echo "Процент                   =  " . $percent . "\n";
126
+            echo "На что домжнож.семлир.данн=  " . $kof . "\n";
127
+            echo "Сумма показов расчитанное =  " . $norma_views . "\n";
128 128
 
129 129
 /// >> 1/(0.8) = для SAMPLE 0.8
130 130
 /// >> 1/(0.5) = для SAMPLE 0.5
Please login to merge, or discard this patch.
example/exam17_sample_data_inthash.php 1 patch
Spacing   +13 added lines, -13 removed lines patch added patch discarded remove patch
@@ -8,26 +8,26 @@  discard block
 block discarded – undo
8 8
 
9 9
 
10 10
 $db = new ClickHouseDB\Client($config);
11
-$_flag_create_table=false;
11
+$_flag_create_table = false;
12 12
 
13 13
 
14 14
 $db->write("DROP TABLE IF EXISTS summing_url_views_intHash32_site_id");
15 15
 
16 16
 
17 17
 
18
-$size=$db->tableSize('summing_url_views_intHash32_site_id');
19
-echo "Site table summing_url_views_intHash32_site_id : ".(isset($size['size'])?$size['size']:'false')."\n";
18
+$size = $db->tableSize('summing_url_views_intHash32_site_id');
19
+echo "Site table summing_url_views_intHash32_site_id : " . (isset($size['size']) ? $size['size'] : 'false') . "\n";
20 20
 
21 21
 
22 22
 
23
-if (!isset($size['size'])) $_flag_create_table=true;
23
+if (!isset($size['size'])) $_flag_create_table = true;
24 24
 
25 25
 
26 26
 if ($_flag_create_table) {
27 27
 
28 28
 
29 29
     $db->write("DROP TABLE IF EXISTS summing_url_views_intHash32_site_id");
30
-    $re=$db->write('
30
+    $re = $db->write('
31 31
                 CREATE TABLE IF NOT EXISTS summing_url_views_intHash32_site_id (
32 32
                     event_date Date DEFAULT toDate(event_time),
33 33
                     event_time DateTime,
@@ -54,8 +54,8 @@  discard block
 block discarded – undo
54 54
     $c = 0;
55 55
     foreach ($file_data_names as $file_name) {
56 56
         $c++;
57
-        $shift_days=( -1* $c*3);
58
-        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 4 * $c,$shift_days);
57
+        $shift_days = ( -1 * $c * 3);
58
+        \ClickHouseDB\Example\Helper::makeSomeDataFileBig($file_name, 4 * $c, $shift_days);
59 59
     }
60 60
 
61 61
     echo "----------------------------------------------------------------------------------------------------\n";
@@ -81,25 +81,25 @@  discard block
 block discarded – undo
81 81
 }
82 82
 echo "------------------------------- COMPARE event_date ---------------------------------------------------------------------\n";
83 83
 
84
-$rows=($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
84
+$rows = ($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY event_date ORDER BY event_date')->rowsAsTree('event_date'));
85 85
 
86
-$samp=($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
86
+$samp = ($db->select('select event_date,sum(views) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY event_date ORDER BY event_date ')->rowsAsTree('event_date'));
87 87
 
88 88
 
89 89
 foreach ($rows as $event_date=>$data)
90 90
 {
91
-    echo $event_date."\t".$data['v']."\t".(@$samp[$event_date]['v']*(1/0.5))."\n";
91
+    echo $event_date . "\t" . $data['v'] . "\t" . (@$samp[$event_date]['v'] * (1 / 0.5)) . "\n";
92 92
 }
93 93
 
94 94
 
95
-$rows=($db->select('select site_id,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
95
+$rows = ($db->select('select site_id,sum(views) as v from summing_url_views_intHash32_site_id GROUP BY site_id ORDER BY site_id')->rowsAsTree('site_id'));
96 96
 
97
-$samp=($db->select('select site_id,(sum(views)) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
97
+$samp = ($db->select('select site_id,(sum(views)) as v from summing_url_views_intHash32_site_id SAMPLE 0.5 GROUP BY site_id ORDER BY site_id ')->rowsAsTree('site_id'));
98 98
 
99 99
 
100 100
 foreach ($rows as $event_date=>$data)
101 101
 {
102
-    echo $event_date."\t".$data['v']."\t".intval(@$samp[$event_date]['v'])."\n";
102
+    echo $event_date . "\t" . $data['v'] . "\t" . intval(@$samp[$event_date]['v']) . "\n";
103 103
 }
104 104
 /*
105 105
 
Please login to merge, or discard this patch.
example/Helper.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -7,8 +7,8 @@
 block discarded – undo
7 7
     public static function init()
8 8
     {
9 9
         date_default_timezone_set('Europe/Moscow');
10
-        error_reporting( E_ALL );
11
-        ini_set('display_errors',1);
10
+        error_reporting(E_ALL);
11
+        ini_set('display_errors', 1);
12 12
     }
13 13
 
14 14
         /**
Please login to merge, or discard this patch.