@@ -109,13 +109,13 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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; |
@@ -70,7 +70,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 | } |
@@ -42,7 +42,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 | } |
@@ -16,12 +16,12 @@ discard block |
||
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 |
||
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 |
||
201 | 201 | */ |
202 | 202 | public function setReadOnlyUser($flag) |
203 | 203 | { |
204 | - $this->_ReadOnlyUser=$flag; |
|
204 | + $this->_ReadOnlyUser = $flag; |
|
205 | 205 | } |
206 | 206 | |
207 | 207 | /** |
@@ -61,7 +61,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 | /** |
@@ -13,27 +13,27 @@ |
||
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); |
@@ -8,20 +8,20 @@ discard block |
||
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 |
||
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 |
||
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 |
@@ -8,26 +8,26 @@ discard block |
||
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 |
||
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 |
||
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 |
@@ -7,8 +7,8 @@ |
||
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 | /** |