@@ -39,7 +39,9 @@ |
||
39 | 39 | $temp_file_name='/tmp/_test_data.TSV'; |
40 | 40 | |
41 | 41 | |
42 | -if (file_exists($temp_file_name)) unlink('/tmp/_test_data.TSV'); |
|
42 | +if (file_exists($temp_file_name)) { |
|
43 | + unlink('/tmp/_test_data.TSV'); |
|
44 | +} |
|
43 | 45 | foreach ($rows as $row) |
44 | 46 | { |
45 | 47 |
@@ -19,7 +19,9 @@ |
||
19 | 19 | |
20 | 20 | |
21 | 21 | |
22 | -if (!isset($size['size'])) $_flag_create_table=true; |
|
22 | +if (!isset($size['size'])) { |
|
23 | + $_flag_create_table=true; |
|
24 | +} |
|
23 | 25 | |
24 | 26 | |
25 | 27 | if ($_flag_create_table) { |
@@ -13,7 +13,9 @@ |
||
13 | 13 | echo "Site table summing_url_views_cityHash64_site_id : ".(isset($size['size'])?$size['size']:'false')."\n"; |
14 | 14 | |
15 | 15 | |
16 | -if (!isset($size['size'])) $_flag_create_table=true; |
|
16 | +if (!isset($size['size'])) { |
|
17 | + $_flag_create_table=true; |
|
18 | +} |
|
17 | 19 | |
18 | 20 | |
19 | 21 | if ($_flag_create_table) { |
@@ -10,8 +10,7 @@ discard block |
||
10 | 10 | |
11 | 11 | try { |
12 | 12 | $db->ping(); |
13 | -} |
|
14 | -catch (ClickHouseDB\Exception\QueryException $E) { |
|
13 | +} catch (ClickHouseDB\Exception\QueryException $E) { |
|
15 | 14 | echo "ERROR:" . $E->getMessage() . "\nOK\n"; |
16 | 15 | } |
17 | 16 | |
@@ -28,8 +27,7 @@ discard block |
||
28 | 27 | $db->setConnectTimeOut(1); |
29 | 28 | try { |
30 | 29 | $db->ping(); |
31 | -} |
|
32 | -catch (ClickHouseDB\Exception\QueryException $E) { |
|
30 | +} catch (ClickHouseDB\Exception\QueryException $E) { |
|
33 | 31 | echo "ERROR:" . $E->getMessage() . "\nOK\n"; |
34 | 32 | } |
35 | 33 | |
@@ -43,15 +41,13 @@ discard block |
||
43 | 41 | try { |
44 | 42 | $db->ping(); |
45 | 43 | echo "PING : OK!\n"; |
46 | -} |
|
47 | -catch (ClickHouseDB\Exception\QueryException $E) { |
|
44 | +} catch (ClickHouseDB\Exception\QueryException $E) { |
|
48 | 45 | echo "ERROR:" . $E->getMessage() . "\nOK\n"; |
49 | 46 | } |
50 | 47 | |
51 | 48 | try { |
52 | 49 | $db->select("SELECT xxx as PPPP FROM ZZZZZ ")->rows(); |
53 | -} |
|
54 | -catch (ClickHouseDB\Exception\DatabaseException $E) { |
|
50 | +} catch (ClickHouseDB\Exception\DatabaseException $E) { |
|
55 | 51 | echo "ERROR : DatabaseException : " . $E->getMessage() . "\n"; // Table default.ZZZZZ doesn't exist. |
56 | 52 | } |
57 | 53 |
@@ -32,8 +32,7 @@ |
||
32 | 32 | try { |
33 | 33 | $db->insertAssocBulk('testoperation_log',$dataInsert); |
34 | 34 | echo "$z\r"; |
35 | - } |
|
36 | - catch (Exception $exception) |
|
35 | + } catch (Exception $exception) |
|
37 | 36 | { |
38 | 37 | die("Error:".$exception->getMessage()); |
39 | 38 | } |
@@ -29,7 +29,7 @@ |
||
29 | 29 | { |
30 | 30 | try{ |
31 | 31 | $x=$cl->activeClient()->write("DROP TABLE IF EXISTS default.asdasdasd ON CLUSTER cluster2"); |
32 | - }catch (Exception $exception) |
|
32 | + } catch (Exception $exception) |
|
33 | 33 | { |
34 | 34 | |
35 | 35 | } |
@@ -29,8 +29,7 @@ |
||
29 | 29 | if ($else) |
30 | 30 | { |
31 | 31 | list($condition, $preset ,$variable, $content_true, $content_false) = $matches; |
32 | - } |
|
33 | - else |
|
32 | + } else |
|
34 | 33 | { |
35 | 34 | list($condition, $preset ,$variable, $content_true) = $matches; |
36 | 35 | } |
@@ -295,8 +295,7 @@ discard block |
||
295 | 295 | if (!$useSessionId) |
296 | 296 | { |
297 | 297 | $this->settings()->makeSessionId(); |
298 | - } |
|
299 | - else |
|
298 | + } else |
|
300 | 299 | { |
301 | 300 | $this->settings()->session_id($useSessionId); |
302 | 301 | } |
@@ -415,7 +414,9 @@ discard block |
||
415 | 414 | */ |
416 | 415 | public function progressFunction($callback) |
417 | 416 | { |
418 | - if (!is_callable($callback)) throw new \InvalidArgumentException('Not is_callable progressFunction'); |
|
417 | + if (!is_callable($callback)) { |
|
418 | + throw new \InvalidArgumentException('Not is_callable progressFunction'); |
|
419 | + } |
|
419 | 420 | |
420 | 421 | if (!$this->settings()->is('send_progress_in_http_headers')) |
421 | 422 | { |
@@ -540,7 +541,7 @@ discard block |
||
540 | 541 | } |
541 | 542 | $preparedValues[] = array_values($row); |
542 | 543 | } |
543 | - }else{ //одна строка |
|
544 | + } else{ //одна строка |
|
544 | 545 | $preparedFields = array_keys($values); |
545 | 546 | $preparedValues = [array_values($values)]; |
546 | 547 | } |
@@ -609,8 +610,7 @@ discard block |
||
609 | 610 | { |
610 | 611 | $sql = 'INSERT INTO ' . $table_name . ' FORMAT '.$format; |
611 | 612 | |
612 | - } |
|
613 | - else |
|
613 | + } else |
|
614 | 614 | { |
615 | 615 | $sql = 'INSERT INTO ' . $table_name . ' ( ' . implode(',', $columns_array) . ' ) FORMAT '.$format; |
616 | 616 | |
@@ -654,8 +654,7 @@ discard block |
||
654 | 654 | { |
655 | 655 | $sql = 'INSERT INTO ' . $table_name . ' FORMAT '.$format; |
656 | 656 | |
657 | - } |
|
658 | - else |
|
657 | + } else |
|
659 | 658 | { |
660 | 659 | $sql = 'INSERT INTO ' . $table_name . ' ( ' . implode(',', $columns_array) . ' ) FORMAT '.$format; |
661 | 660 |
@@ -353,8 +353,9 @@ discard block |
||
353 | 353 | public function getHeaders() |
354 | 354 | { |
355 | 355 | $head=[]; |
356 | - foreach ($this->headers as $key=>$value) |
|
357 | - $head[]= sprintf("%s: %s", $key, $value); |
|
356 | + foreach ($this->headers as $key=>$value) { |
|
357 | + $head[]= sprintf("%s: %s", $key, $value); |
|
358 | + } |
|
358 | 359 | return $head; |
359 | 360 | } |
360 | 361 | |
@@ -394,8 +395,7 @@ discard block |
||
394 | 395 | if ($flag) { |
395 | 396 | $this->_httpCompression = $flag; |
396 | 397 | $this->options[CURLOPT_ENCODING] = 'gzip'; |
397 | - } |
|
398 | - else |
|
398 | + } else |
|
399 | 399 | { |
400 | 400 | $this->_httpCompression = false; |
401 | 401 | unset($this->options[CURLOPT_ENCODING]); |