@@ -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)) { |