@@ -63,19 +63,19 @@ discard block |
||
| 63 | 63 | */ |
| 64 | 64 | public function __construct(array $connectParams, array $settings = []) |
| 65 | 65 | { |
| 66 | - if (! isset($connectParams['username'])) { |
|
| 66 | + if (!isset($connectParams['username'])) { |
|
| 67 | 67 | throw new \InvalidArgumentException('not set username'); |
| 68 | 68 | } |
| 69 | 69 | |
| 70 | - if (! isset($connectParams['password'])) { |
|
| 70 | + if (!isset($connectParams['password'])) { |
|
| 71 | 71 | throw new \InvalidArgumentException('not set password'); |
| 72 | 72 | } |
| 73 | 73 | |
| 74 | - if (! isset($connectParams['port'])) { |
|
| 74 | + if (!isset($connectParams['port'])) { |
|
| 75 | 75 | throw new \InvalidArgumentException('not set port'); |
| 76 | 76 | } |
| 77 | 77 | |
| 78 | - if (! isset($connectParams['host'])) { |
|
| 78 | + if (!isset($connectParams['host'])) { |
|
| 79 | 79 | throw new \InvalidArgumentException('not set host'); |
| 80 | 80 | } |
| 81 | 81 | |
@@ -96,7 +96,7 @@ discard block |
||
| 96 | 96 | |
| 97 | 97 | // apply settings to transport class |
| 98 | 98 | $this->settings()->database('default'); |
| 99 | - if (! empty($settings)) { |
|
| 99 | + if (!empty($settings)) { |
|
| 100 | 100 | $this->settings()->apply($settings); |
| 101 | 101 | } |
| 102 | 102 | |
@@ -198,7 +198,7 @@ discard block |
||
| 198 | 198 | */ |
| 199 | 199 | public function transport() |
| 200 | 200 | { |
| 201 | - if (! $this->transport) { |
|
| 201 | + if (!$this->transport) { |
|
| 202 | 202 | throw new \InvalidArgumentException('Empty transport class'); |
| 203 | 203 | } |
| 204 | 204 | |
@@ -267,8 +267,8 @@ discard block |
||
| 267 | 267 | */ |
| 268 | 268 | public function useSession(string $useSessionId = null) |
| 269 | 269 | { |
| 270 | - if (! $this->settings()->getSessionId()) { |
|
| 271 | - if (! $useSessionId) { |
|
| 270 | + if (!$this->settings()->getSessionId()) { |
|
| 271 | + if (!$useSessionId) { |
|
| 272 | 272 | $this->settings()->makeSessionId(); |
| 273 | 273 | } else { |
| 274 | 274 | $this->settings()->session_id($useSessionId); |
@@ -386,14 +386,14 @@ discard block |
||
| 386 | 386 | */ |
| 387 | 387 | public function progressFunction(callable $callback) |
| 388 | 388 | { |
| 389 | - if (! is_callable($callback)) { |
|
| 389 | + if (!is_callable($callback)) { |
|
| 390 | 390 | throw new \InvalidArgumentException('Not is_callable progressFunction'); |
| 391 | 391 | } |
| 392 | 392 | |
| 393 | - if (! $this->settings()->is('send_progress_in_http_headers')) { |
|
| 393 | + if (!$this->settings()->is('send_progress_in_http_headers')) { |
|
| 394 | 394 | $this->settings()->set('send_progress_in_http_headers', 1); |
| 395 | 395 | } |
| 396 | - if (! $this->settings()->is('http_headers_progress_interval_ms')) { |
|
| 396 | + if (!$this->settings()->is('http_headers_progress_interval_ms')) { |
|
| 397 | 397 | $this->settings()->set('http_headers_progress_interval_ms', 100); |
| 398 | 398 | } |
| 399 | 399 | |
@@ -574,14 +574,14 @@ discard block |
||
| 574 | 574 | throw new QueryException('Queue must be empty, before insertBatch, need executeAsync'); |
| 575 | 575 | } |
| 576 | 576 | |
| 577 | - if (! in_array($format, self::SUPPORTED_FORMATS, true)) { |
|
| 577 | + if (!in_array($format, self::SUPPORTED_FORMATS, true)) { |
|
| 578 | 578 | throw new QueryException('Format not support in insertBatchFiles'); |
| 579 | 579 | } |
| 580 | 580 | |
| 581 | 581 | $result = []; |
| 582 | 582 | |
| 583 | 583 | foreach ($fileNames as $fileName) { |
| 584 | - if (! is_file($fileName) || ! is_readable($fileName)) { |
|
| 584 | + if (!is_file($fileName) || !is_readable($fileName)) { |
|
| 585 | 585 | throw new QueryException('Cant read file: ' . $fileName . ' ' . (is_file($fileName) ? '' : ' is not file')); |
| 586 | 586 | } |
| 587 | 587 | |
@@ -598,7 +598,7 @@ discard block |
||
| 598 | 598 | |
| 599 | 599 | // fetch resutl |
| 600 | 600 | foreach ($fileNames as $fileName) { |
| 601 | - if (! $result[$fileName]->isError()) { |
|
| 601 | + if (!$result[$fileName]->isError()) { |
|
| 602 | 602 | continue; |
| 603 | 603 | } |
| 604 | 604 | |
@@ -621,7 +621,7 @@ discard block |
||
| 621 | 621 | throw new QueryException('Queue must be empty, before insertBatch, need executeAsync'); |
| 622 | 622 | } |
| 623 | 623 | |
| 624 | - if (! in_array($format, self::SUPPORTED_FORMATS, true)) { |
|
| 624 | + if (!in_array($format, self::SUPPORTED_FORMATS, true)) { |
|
| 625 | 625 | throw new QueryException('Format not support in insertBatchFiles'); |
| 626 | 626 | } |
| 627 | 627 | |
@@ -75,7 +75,7 @@ |
||
| 75 | 75 | $markers = $this->bindings; |
| 76 | 76 | |
| 77 | 77 | // ------ if/else conditions & if[set|int]/else conditions ----- |
| 78 | - $sql = preg_replace_callback('#\{if(.{0,}?)\s+([^\}]+?)\}(.+?)(\{else\}([^\{]+?)?)?\s*\{\/if}#sui', function ($matches) use ($markers) { |
|
| 78 | + $sql = preg_replace_callback('#\{if(.{0,}?)\s+([^\}]+?)\}(.+?)(\{else\}([^\{]+?)?)?\s*\{\/if}#sui', function($matches) use ($markers) { |
|
| 79 | 79 | return self::__ifsets($matches, $markers); |
| 80 | 80 | } |
| 81 | 81 | , $sql); |
@@ -215,15 +215,15 @@ discard block |
||
| 215 | 215 | $this->_init = true; |
| 216 | 216 | return false; |
| 217 | 217 | } |
| 218 | - $data=[]; |
|
| 218 | + $data = []; |
|
| 219 | 219 | foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) { |
| 220 | 220 | |
| 221 | 221 | if (isset($this->_rawData[$key])) { |
| 222 | - if ($key=='data') |
|
| 222 | + if ($key == 'data') |
|
| 223 | 223 | { |
| 224 | - $data=$this->_rawData[$key]; |
|
| 224 | + $data = $this->_rawData[$key]; |
|
| 225 | 225 | } |
| 226 | - else{ |
|
| 226 | + else { |
|
| 227 | 227 | $this->{$key} = $this->_rawData[$key]; |
| 228 | 228 | } |
| 229 | 229 | |
@@ -234,7 +234,7 @@ discard block |
||
| 234 | 234 | throw new QueryException('Can`t find meta'); |
| 235 | 235 | } |
| 236 | 236 | |
| 237 | - $isJSONCompact=(stripos($this->format,'JSONCompact')!==false?true:false); |
|
| 237 | + $isJSONCompact = (stripos($this->format, 'JSONCompact') !== false ?true:false); |
|
| 238 | 238 | $this->array_data = []; |
| 239 | 239 | foreach ($data as $rows) { |
| 240 | 240 | $r = []; |
@@ -242,7 +242,7 @@ discard block |
||
| 242 | 242 | |
| 243 | 243 | if ($isJSONCompact) |
| 244 | 244 | { |
| 245 | - $r[]=$rows; |
|
| 245 | + $r[] = $rows; |
|
| 246 | 246 | } |
| 247 | 247 | else { |
| 248 | 248 | foreach ($this->meta as $meta) { |
@@ -353,15 +353,15 @@ discard block |
||
| 353 | 353 | { |
| 354 | 354 | $this->init(); |
| 355 | 355 | |
| 356 | - if (! $key) { |
|
| 356 | + if (!$key) { |
|
| 357 | 357 | return $this->statistics; |
| 358 | 358 | } |
| 359 | 359 | |
| 360 | - if (! \is_array($this->statistics)) { |
|
| 360 | + if (!\is_array($this->statistics)) { |
|
| 361 | 361 | return null; |
| 362 | 362 | } |
| 363 | 363 | |
| 364 | - if (! isset($this->statistics[$key])) { |
|
| 364 | + if (!isset($this->statistics[$key])) { |
|
| 365 | 365 | return null; |
| 366 | 366 | } |
| 367 | 367 | |
@@ -402,11 +402,11 @@ discard block |
||
| 402 | 402 | { |
| 403 | 403 | $this->init(); |
| 404 | 404 | |
| 405 | - if (! isset($this->array_data[0])) { |
|
| 405 | + if (!isset($this->array_data[0])) { |
|
| 406 | 406 | return null; |
| 407 | 407 | } |
| 408 | 408 | |
| 409 | - if (! $key) { |
|
| 409 | + if (!$key) { |
|
| 410 | 410 | return $this->array_data[0]; |
| 411 | 411 | } |
| 412 | 412 | |