@@ -237,7 +237,7 @@ discard block |
||
237 | 237 | */ |
238 | 238 | public function setWriteFunction($callback) |
239 | 239 | { |
240 | - $this->options[CURLOPT_WRITEFUNCTION]=$callback; |
|
240 | + $this->options[CURLOPT_WRITEFUNCTION] = $callback; |
|
241 | 241 | } |
242 | 242 | /** |
243 | 243 | * @param callable $callback |
@@ -612,7 +612,7 @@ discard block |
||
612 | 612 | */ |
613 | 613 | public function response() |
614 | 614 | { |
615 | - if (! $this->response) { |
|
615 | + if (!$this->response) { |
|
616 | 616 | throw new \ClickHouseDB\Exception\TransportException('Can`t fetch response - is empty'); |
617 | 617 | } |
618 | 618 | |
@@ -708,7 +708,7 @@ discard block |
||
708 | 708 | |
709 | 709 | if (!empty($curl_opt[CURLOPT_WRITEFUNCTION])) |
710 | 710 | { |
711 | - $curl_opt[CURLOPT_HEADER]=false; |
|
711 | + $curl_opt[CURLOPT_HEADER] = false; |
|
712 | 712 | } |
713 | 713 | |
714 | 714 | if ($this->resultFileHandle) { |
@@ -144,22 +144,22 @@ |
||
144 | 144 | public function execLoopWait() |
145 | 145 | { |
146 | 146 | $c = 0; |
147 | - $timeStart=time(); |
|
148 | - $uSleep=1000; // Timer: check response from server, and add new Task/Que to loop |
|
149 | - $PendingAllConnections=$this->countPending(); |
|
147 | + $timeStart = time(); |
|
148 | + $uSleep = 1000; // Timer: check response from server, and add new Task/Que to loop |
|
149 | + $PendingAllConnections = $this->countPending(); |
|
150 | 150 | |
151 | 151 | // Max loop check |
152 | 152 | |
153 | - $count=0; |
|
153 | + $count = 0; |
|
154 | 154 | // add all tasks |
155 | 155 | do { |
156 | 156 | $this->exec(); |
157 | - $timeWork=time()-$timeStart; |
|
157 | + $timeWork = time() - $timeStart; |
|
158 | 158 | // |
159 | 159 | $ActiveNowConnections = $this->countActive(); |
160 | 160 | $PendingNowConnections = $this->countPending(); |
161 | 161 | |
162 | - $count=$ActiveNowConnections+$PendingNowConnections; |
|
162 | + $count = $ActiveNowConnections + $PendingNowConnections; |
|
163 | 163 | $c++; |
164 | 164 | |
165 | 165 | if ($c > 20000) { |
@@ -22,7 +22,7 @@ discard block |
||
22 | 22 | */ |
23 | 23 | private $degenerations = []; |
24 | 24 | |
25 | - private $supportFormats=[ |
|
25 | + private $supportFormats = [ |
|
26 | 26 | "FORMAT\\s+TSVRaw", |
27 | 27 | "FORMAT\\s+TSVWithNamesAndTypes", |
28 | 28 | "FORMAT\\s+TSVWithNames", |
@@ -71,7 +71,7 @@ discard block |
||
71 | 71 | if (null === $this->format) { |
72 | 72 | return false; |
73 | 73 | } |
74 | - $supportFormats = implode("|",$this->supportFormats); |
|
74 | + $supportFormats = implode("|", $this->supportFormats); |
|
75 | 75 | |
76 | 76 | $matches = []; |
77 | 77 | if (preg_match_all('%(' . $supportFormats . ')%ius', $this->sql, $matches)) { |