GitHub Access Token became invalid

It seems like the GitHub access token used for retrieving details about this repository from GitHub became invalid. This might prevent certain types of inspections from being run (in particular, everything related to pull requests).
Please ask an admin of your repository to re-new the access token on this website.
Passed
Push — master ( 17036d...efc942 )
by cao
03:02
created
src/DB/impls.php 1 patch
Spacing   +163 added lines, -163 removed lines patch added patch discarded remove patch
@@ -7,14 +7,14 @@  discard block
 block discarded – undo
7 7
 use PhpBoot\DB\rules\basic\BasicRule;
8 8
 use PhpBoot\DB\Context;
9 9
 
10
-class ExecResult{
11
-    public function __construct($success, $pdo, $st){
10
+class ExecResult {
11
+    public function __construct($success, $pdo, $st) {
12 12
         $this->pdo = $pdo;
13 13
         $this->st = $st;
14 14
         $this->success = $success;
15 15
         $this->rows = $this->st->rowCount();
16 16
     }
17
-    public function lastInsertId($name=null){
17
+    public function lastInsertId($name = null) {
18 18
         return $this->pdo->lastInsertId($name);
19 19
     }
20 20
     /**
@@ -41,21 +41,21 @@  discard block
 block discarded – undo
41 41
 
42 42
 class SelectImpl
43 43
 {
44
-    static  public function select($context, $columns){
44
+    static  public function select($context, $columns) {
45 45
         $context->appendSql("SELECT $columns");
46 46
     }
47 47
 }
48 48
 
49 49
 class FromImpl
50 50
 {
51
-    static public function from($context, $tables,$as=null){
52
-        if($tables instanceof BasicRule){
51
+    static public function from($context, $tables, $as = null) {
52
+        if ($tables instanceof BasicRule) {
53 53
             $context->appendSql("FROM (".$tables->context->sql.')');
54
-            $context->params = array_merge($context->params,$tables->context->params);
54
+            $context->params = array_merge($context->params, $tables->context->params);
55 55
         }else {
56 56
             $context->appendSql("FROM ".DB::wrap($tables));
57 57
         }
58
-        if($as){
58
+        if ($as) {
59 59
             $context->appendSql("AS ".DB::wrap($as));
60 60
         }
61 61
     }
@@ -73,9 +73,9 @@  discard block
 block discarded – undo
73 73
 {
74 74
     static public function join($context, $type, $table) {
75 75
         $table = DB::wrap($table);
76
-        if($type){
76
+        if ($type) {
77 77
             $context->appendSql("$type JOIN $table");
78
-        }else{
78
+        }else {
79 79
             $context->appendSql("JOIN $table");
80 80
         }
81 81
     }
@@ -90,14 +90,14 @@  discard block
 block discarded – undo
90 90
 
91 91
 class ForUpdateImpl
92 92
 {
93
-    static public function forUpdate($context){
93
+    static public function forUpdate($context) {
94 94
         $context->appendSql("FOR UPDATE");
95 95
     }
96 96
 }
97 97
 
98 98
 class ForUpdateOfImpl
99 99
 {
100
-    static public function of($context, $column){
100
+    static public function of($context, $column) {
101 101
         $column = DB::wrap($column);
102 102
         $context->appendSql("OF $column");
103 103
     }
@@ -119,57 +119,57 @@  discard block
 block discarded – undo
119 119
 }
120 120
 class ValuesImpl
121 121
 {
122
-     static public function values(Context $context, array $values){
122
+     static public function values(Context $context, array $values) {
123 123
         $params = [];
124 124
         $stubs = [];
125
-        foreach ($values as $v){
126
-            if(is_a($v, Raw::class)){//直接拼接sql,不需要转义
127
-                $stubs[]=$v->get();
128
-            }else{
129
-                $stubs[]='?';
125
+        foreach ($values as $v) {
126
+            if (is_a($v, Raw::class)) {//直接拼接sql,不需要转义
127
+                $stubs[] = $v->get();
128
+            }else {
129
+                $stubs[] = '?';
130 130
                 $params[] = $v;
131 131
             }
132 132
         }
133 133
         $stubs = implode(',', $stubs);
134 134
 
135
-        if(array_keys($values) === range(0, count($values) - 1)){
135
+        if (array_keys($values) === range(0, count($values) - 1)) {
136 136
             //VALUES(val0, val1, val2)
137 137
             $context->appendSql("VALUES($stubs)");
138 138
 
139
-        }else{
139
+        }else {
140 140
             //(col0, col1, col2) VALUES(val0, val1, val2)
141
-            $columns = implode(',', array_map(function($k){return DB::wrap($k);}, array_keys($values)));
142
-            $context->appendSql("($columns) VALUES($stubs)",false);
141
+            $columns = implode(',', array_map(function($k) {return DB::wrap($k); }, array_keys($values)));
142
+            $context->appendSql("($columns) VALUES($stubs)", false);
143 143
         }
144 144
         $context->appendParams($params);
145 145
     }
146 146
     static public function batchValues(Context $context, array $values)
147 147
     {
148 148
         $count = count($values);
149
-        if($count == 0){
149
+        if ($count == 0) {
150 150
             return;
151 151
         }
152 152
         $keys = array_keys($values[0]);
153 153
         $row = implode(',', self::toSql(array_values($values[0])));
154
-        if($keys === range(0, count($keys) - 1)){
154
+        if ($keys === range(0, count($keys) - 1)) {
155 155
             //VALUES(val0, val1, val2)
156 156
             $context->appendSql("VALUES($row)");
157
-        }else{
157
+        }else {
158 158
             //(col0, col1, col2) VALUES(val0, val1, val2)
159
-            $columns = implode(',', array_map(function($k){return DB::wrap($k);}, $keys));
160
-            $context->appendSql("($columns) VALUES($row)",false);
159
+            $columns = implode(',', array_map(function($k) {return DB::wrap($k); }, $keys));
160
+            $context->appendSql("($columns) VALUES($row)", false);
161 161
         }
162
-        for($i=1; $i<$count; $i++){
162
+        for ($i = 1; $i<$count; $i++) {
163 163
             $value = self::pick($keys, $values[$i]);
164 164
             $row = implode(',', self::toSql($value));
165
-            $context->appendSql(", ($row)",false);
165
+            $context->appendSql(", ($row)", false);
166 166
         }
167 167
     }
168 168
 
169 169
     static protected function pick(array $keys, array $values)
170 170
     {
171 171
         $res = [];
172
-        foreach ($keys as $key){
172
+        foreach ($keys as $key) {
173 173
             array_key_exists($key, $values) or \PhpBoot\abort("key $key not exist from the given array");
174 174
             $res[$key] = $values[$key];
175 175
         }
@@ -177,12 +177,12 @@  discard block
 block discarded – undo
177 177
     }
178 178
     static protected function toSql(array $values)
179 179
     {
180
-        foreach ($values as &$v){
181
-            if($v instanceof Raw){
180
+        foreach ($values as &$v) {
181
+            if ($v instanceof Raw) {
182 182
                 $v = $v->get();
183
-            }elseif(is_bool($v)){
184
-                $v = $v?'true':'false';
185
-            }elseif(!in_array(gettype($v), ['integer', 'boolean', 'double', 'float'])){
183
+            }elseif (is_bool($v)) {
184
+                $v = $v ? 'true' : 'false';
185
+            }elseif (!in_array(gettype($v), ['integer', 'boolean', 'double', 'float'])) {
186 186
                 $v = (string)$v;
187 187
                 $v = str_replace("\\", "\\\\", $v);
188 188
                 $v = str_replace("'", "\\'", $v);
@@ -195,7 +195,7 @@  discard block
 block discarded – undo
195 195
 
196 196
 class UpdateImpl
197 197
 {
198
-    static public function update($context, $table){
198
+    static public function update($context, $table) {
199 199
         $table = DB::wrap($table);
200 200
         $context->appendSql("UPDATE $table");
201 201
     }
@@ -203,81 +203,81 @@  discard block
 block discarded – undo
203 203
 
204 204
 class UpdateSetImpl
205 205
 {
206
-    public function set(Context $context, $expr, $args){
207
-        if(is_string($expr)){
206
+    public function set(Context $context, $expr, $args) {
207
+        if (is_string($expr)) {
208 208
             return $this->setExpr($context, $expr, $args);
209
-        }else{
209
+        }else {
210 210
             return $this->setArgs($context, $expr);
211 211
         }
212 212
     }
213 213
 
214
-    public function setExpr(Context $context, $expr, $args){
215
-        if($this->first){
214
+    public function setExpr(Context $context, $expr, $args) {
215
+        if ($this->first) {
216 216
             $this->first = false;
217 217
             $prefix = 'SET ';
218
-        }else{
218
+        }else {
219 219
             $prefix = ',';
220 220
         }
221 221
 
222
-        $context->appendSql("$prefix$expr",$prefix == 'SET ');
222
+        $context->appendSql("$prefix$expr", $prefix == 'SET ');
223 223
         $context->appendParams($args);
224 224
 
225 225
     }
226
-    public function setArgs(Context $context, $values){
226
+    public function setArgs(Context $context, $values) {
227 227
         $set = [];
228 228
         $params = [];
229
-        foreach ($values as $k=>$v){
229
+        foreach ($values as $k=>$v) {
230 230
             $k = DB::wrap($k);
231
-            if(is_a($v, Raw::class)){//直接拼接sql,不需要转义
232
-                $set[]= "$k=".$v->get();
233
-            }else{
234
-                $set[]= "$k=?";
235
-                $params[]=$v;
231
+            if (is_a($v, Raw::class)) {//直接拼接sql,不需要转义
232
+                $set[] = "$k=".$v->get();
233
+            }else {
234
+                $set[] = "$k=?";
235
+                $params[] = $v;
236 236
             }
237 237
         }
238
-        if($this->first){
238
+        if ($this->first) {
239 239
             $this->first = false;
240 240
             $context->appendSql('SET '.implode(',', $set));
241 241
             $context->appendParams($params);
242
-        }else{
243
-            $context->appendSql(','.implode(',', $set),false);
242
+        }else {
243
+            $context->appendSql(','.implode(',', $set), false);
244 244
             $context->appendParams($params);
245 245
         }
246 246
     }
247
-    private $first=true;
247
+    private $first = true;
248 248
 }
249 249
 class OrderByImpl
250 250
 {
251
-    public function orderByArgs(Context $context, $orders){
252
-        if(empty($orders)){
251
+    public function orderByArgs(Context $context, $orders) {
252
+        if (empty($orders)) {
253 253
             return $this;
254 254
         }
255 255
         $params = array();
256
-        foreach ($orders as $k=>$v){
257
-            if(is_integer($k)){
256
+        foreach ($orders as $k=>$v) {
257
+            if (is_integer($k)) {
258 258
                 $params[] = DB::wrap($v);
259
-            }else{
259
+            }else {
260 260
                 $k = DB::wrap($k);
261 261
 
262 262
                 $v = strtoupper($v);
263
-                ($v =='DESC' || $v =='ASC') or \PhpBoot\abort( new \InvalidArgumentException("invalid params for orderBy(".json_encode($orders).")"));
263
+                ($v == 'DESC' || $v == 'ASC') or \PhpBoot\abort(new \InvalidArgumentException("invalid params for orderBy(".json_encode($orders).")"));
264 264
 
265 265
                 $params[] = "$k $v";
266 266
             }
267 267
         }
268
-        if($this->first){
268
+        if ($this->first) {
269 269
             $this->first = false;
270 270
             $context->appendSql('ORDER BY '.implode(',', $params));
271
-        }else{
272
-            $context->appendSql(','.implode(',', $params),false);
271
+        }else {
272
+            $context->appendSql(','.implode(',', $params), false);
273 273
         }
274 274
         return $this;
275 275
     }
276
-    public function orderBy(Context $context, $column, $order=null){
277
-        if(is_string($column)){
278
-            if($order === null){
276
+    public function orderBy(Context $context, $column, $order = null) {
277
+        if (is_string($column)) {
278
+            if ($order === null) {
279 279
                 $column = [$column];
280
-            }else{
280
+            }else {
281 281
                 $column = [$column=>$order];
282 282
             }
283 283
         }
@@ -285,18 +285,18 @@  discard block
 block discarded – undo
285 285
 
286 286
 
287 287
     }
288
-    private $first=true;
288
+    private $first = true;
289 289
 }
290 290
 
291 291
 class LimitImpl
292 292
 {
293
-    static public function limit(Context $context, $size){
293
+    static public function limit(Context $context, $size) {
294 294
         $intSize = intval($size);
295 295
         strval($intSize) == $size or \PhpBoot\abort(
296 296
             new \InvalidArgumentException("invalid params for limit($size)"));
297 297
         $context->appendSql("LIMIT $size");
298 298
     }
299
-    static public function limitWithOffset(Context $context, $start, $size){
299
+    static public function limitWithOffset(Context $context, $start, $size) {
300 300
         $intStart = intval($start);
301 301
         $intSize = intval($size);
302 302
         strval($intStart) == $start && strval($intSize) == $size or \PhpBoot\abort(
@@ -305,31 +305,31 @@  discard block
 block discarded – undo
305 305
     }
306 306
 }
307 307
 
308
-class WhereImpl{
308
+class WhereImpl {
309 309
 
310
-    static private function findQ($str,$offset = 0,$no=0){
310
+    static private function findQ($str, $offset = 0, $no = 0) {
311 311
         $found = strpos($str, '?', $offset);
312
-        if($no == 0 || $found === false){
312
+        if ($no == 0 || $found === false) {
313 313
             return $found;
314 314
         }
315
-        return self::findQ($str, $found+1, $no-1);
315
+        return self::findQ($str, $found + 1, $no - 1);
316 316
     }
317 317
 
318
-    static public function where(Context $context, $prefix, $expr, $args){
319
-        if(empty($expr)){
318
+    static public function where(Context $context, $prefix, $expr, $args) {
319
+        if (empty($expr)) {
320 320
             return;
321 321
         }
322
-        if(is_callable($expr)){
323
-            self::conditionClosure($context,$prefix, $expr);
324
-        }elseif (is_string($expr)){
322
+        if (is_callable($expr)) {
323
+            self::conditionClosure($context, $prefix, $expr);
324
+        }elseif (is_string($expr)) {
325 325
             self::condition($context, $prefix, $expr, $args);
326
-        }else{
326
+        }else {
327 327
             self::conditionArgs($context, $prefix, $expr);
328 328
         }
329 329
 
330 330
     }
331 331
 
332
-    static public function conditionClosure(Context $context, $prefix, callable $callback){
332
+    static public function conditionClosure(Context $context, $prefix, callable $callback) {
333 333
         $context->appendSql($prefix.' (');
334 334
         $callback($context);
335 335
         $context->appendSql(')');
@@ -355,15 +355,15 @@  discard block
 block discarded – undo
355 355
      * NOT IN   'id'=>['NOT IN' => [1,2,3]]
356 356
      * @return void
357 357
      */
358
-    static public function conditionArgs(Context $context, $prefix, $args=[]){
359
-        if($args ===null){
360
-            return ;
358
+    static public function conditionArgs(Context $context, $prefix, $args = []) {
359
+        if ($args === null) {
360
+            return;
361 361
         }
362 362
         $exprs = array();
363 363
         $params = array();
364
-        foreach ($args as $k => $v){
364
+        foreach ($args as $k => $v) {
365 365
             $k = DB::wrap($k);
366
-            if(!is_array($v)){
366
+            if (!is_array($v)) {
367 367
                 $v = ['='=>$v];
368 368
             }
369 369
 
@@ -375,56 +375,56 @@  discard block
 block discarded – undo
375 375
                 new \InvalidArgumentException("invalid param $op for whereArgs"));
376 376
 
377 377
             $var = array_values($v)[0];
378
-            if($op == 'IN' || $op == 'NOT IN'){
378
+            if ($op == 'IN' || $op == 'NOT IN') {
379 379
                 $stubs = [];
380 380
 
381
-                if($var instanceof BasicRule){
381
+                if ($var instanceof BasicRule) {
382 382
                     $stubs = "({$var->context->sql})";
383 383
                     $params = array_merge($params, $var->context->params);
384 384
                     $exprs[] = "$k $op $stubs";
385
-                }else{
386
-                    foreach ($var as $i){
387
-                        if(is_a($i, Raw::class)){
388
-                            $stubs[]=strval($i);
389
-                        }elseif($i instanceof BasicRule){
385
+                }else {
386
+                    foreach ($var as $i) {
387
+                        if (is_a($i, Raw::class)) {
388
+                            $stubs[] = strval($i);
389
+                        }elseif ($i instanceof BasicRule) {
390 390
                             $stubs = "({$i->context->sql})";
391 391
                             $params = array_merge($params, $i->context->params);
392
-                        }else{
393
-                            $stubs[]='?';
392
+                        }else {
393
+                            $stubs[] = '?';
394 394
                             $params[] = $i;
395 395
                         }
396 396
                     }
397 397
                     $stubs = implode(',', $stubs);
398 398
                     $exprs[] = "$k $op ($stubs)";
399 399
                 }
400
-            }else if($op == 'BETWEEN'){
400
+            }else if ($op == 'BETWEEN') {
401 401
                 $cond = "$k BETWEEN";
402
-                if(is_a($var[0], Raw::class)){
402
+                if (is_a($var[0], Raw::class)) {
403 403
                     $cond = "$cond ".strval($var[0]);
404
-                }elseif($var[0] instanceof BasicRule){
404
+                }elseif ($var[0] instanceof BasicRule) {
405 405
                     $cond = "$cond ({$var[0]->context->sql})";
406 406
                     $params = array_merge($params, $var[0]->context->params);
407
-                }else{
407
+                }else {
408 408
                     $cond = "$cond ?";
409 409
                     $params[] = $var[0];
410 410
                 }
411
-                if(is_a($var[1], Raw::class)){
411
+                if (is_a($var[1], Raw::class)) {
412 412
                     $cond = "$cond AND ".strval($var[1]);
413
-                }elseif($var[1] instanceof BasicRule){
413
+                }elseif ($var[1] instanceof BasicRule) {
414 414
                     $cond = "$cond AND ({$var[1]->context->sql})";
415 415
                     $params = array_merge($params, $var[1]->context->params);
416
-                }else{
416
+                }else {
417 417
                     $cond = "$cond AND ?";
418 418
                     $params[] = $var[1];
419 419
                 }
420 420
                 $exprs[] = $cond;
421
-            }else{
422
-                if(is_a($var, Raw::class)){
421
+            }else {
422
+                if (is_a($var, Raw::class)) {
423 423
                     $exprs[] = "$k $op ".strval($var);
424
-                }elseif($var instanceof BasicRule){
424
+                }elseif ($var instanceof BasicRule) {
425 425
                     $exprs[] = "$k $op {$var->context->sql}";
426 426
                     $params = array_merge($params, $var->context->params);
427
-                }else{
427
+                }else {
428 428
                     $exprs[] = "$k $op ?";
429 429
                     $params[] = $var;
430 430
                 }
@@ -433,22 +433,22 @@  discard block
 block discarded – undo
433 433
 
434 434
         self::condition($context, $prefix, implode(' AND ', $exprs), $params);
435 435
     }
436
-    static public function condition(Context $context, $prefix, $expr, $args){
437
-        if(!empty($expr)){
436
+    static public function condition(Context $context, $prefix, $expr, $args) {
437
+        if (!empty($expr)) {
438 438
             $expr = "($expr)";
439
-            if($args){
439
+            if ($args) {
440 440
                 //因为PDO不支持绑定数组变量, 这里需要手动展开数组
441 441
                 //也就是说把 where("id IN(?)", [1,2])  展开成 where("id IN(?,?)", 1,2)
442 442
                 $cutted = null;
443 443
                 $cut = null;
444 444
                 $toReplace = array();
445 445
 
446
-                $newArgs=array();
446
+                $newArgs = array();
447 447
                 //找到所有数组对应的?符位置
448
-                foreach ($args as $k =>$arg){
449
-                    if(is_array($arg) || is_a($arg, Raw::class) || is_a($arg, BasicRule::class)){
448
+                foreach ($args as $k =>$arg) {
449
+                    if (is_array($arg) || is_a($arg, Raw::class) || is_a($arg, BasicRule::class)) {
450 450
 
451
-                        if(!$cutted){
451
+                        if (!$cutted) {
452 452
                             $cut = new NestedStringCut($expr);
453 453
                             $cutted = $cut->getText();
454 454
                         }
@@ -458,54 +458,54 @@  discard block
 block discarded – undo
458 458
                         $pos !== false or \PhpBoot\abort(
459 459
                             new \InvalidArgumentException("unmatched params and ? @ $expr"));
460 460
 
461
-                        if(is_array($arg)){
461
+                        if (is_array($arg)) {
462 462
                             $stubs = [];
463
-                            foreach ($arg as $i){
464
-                                if(is_a($i, Raw::class)){
463
+                            foreach ($arg as $i) {
464
+                                if (is_a($i, Raw::class)) {
465 465
                                     $stubs[] = strval($i);
466
-                                }else{
466
+                                }else {
467 467
                                     $stubs[] = '?';
468 468
                                     $newArgs[] = $i;
469 469
                                 }
470 470
                             }
471 471
                             $stubs = implode(',', $stubs);
472
-                        }elseif($arg instanceof BasicRule){
472
+                        }elseif ($arg instanceof BasicRule) {
473 473
                             $stubs = "({$arg->context->sql})";
474 474
                             $newArgs = array_merge($newArgs, $arg->context->params);
475
-                        }else{
475
+                        }else {
476 476
                             $stubs = strval($arg);
477 477
                         }
478 478
                         $toReplace[] = [$pos, $stubs];
479 479
 
480
-                    }else{
481
-                        $newArgs[]=$arg;
480
+                    }else {
481
+                        $newArgs[] = $arg;
482 482
                     }
483 483
                 }
484 484
 
485
-                if(count($toReplace)){
485
+                if (count($toReplace)) {
486 486
                     $toReplace = array_reverse($toReplace);
487
-                    foreach ($toReplace as $i){
487
+                    foreach ($toReplace as $i) {
488 488
                         list($pos, $v) = $i;
489
-                        $expr = substr($expr, 0, $pos).$v.substr($expr, $pos+1);
489
+                        $expr = substr($expr, 0, $pos).$v.substr($expr, $pos + 1);
490 490
                     }
491 491
                     $args = $newArgs;
492 492
                 }
493 493
             }
494
-            if($prefix){
494
+            if ($prefix) {
495 495
                 $context->appendSql($prefix.' '.$expr);
496
-            }else{
496
+            }else {
497 497
                 $context->appendSql($expr);
498 498
             }
499 499
 
500
-            if($args){
500
+            if ($args) {
501 501
                 $context->appendParams($args);
502 502
             }
503 503
         }
504 504
     }
505 505
 }
506 506
 
507
-class GroupByImpl{
508
-    static public function groupBy(Context $context, $column){
507
+class GroupByImpl {
508
+    static public function groupBy(Context $context, $column) {
509 509
         $column = DB::wrap($column);
510 510
         $context->appendSql("GROUP BY $column");
511 511
     }
@@ -530,20 +530,20 @@  discard block
 block discarded – undo
530 530
      * @param string|false $asDict return  as dict or array
531 531
      * @return false|array
532 532
      */
533
-    static public function get($context, $dictAs=false){
533
+    static public function get($context, $dictAs = false) {
534 534
 
535 535
         $st = $context->connection->prepare($context->sql);
536
-        if($st->execute($context->params)){
536
+        if ($st->execute($context->params)) {
537 537
             $res = $st->fetchAll(\PDO::FETCH_ASSOC);
538
-            if ($dictAs){
539
-                $dict= [];
540
-                foreach ($res as $i){
541
-                    $dict[$i[$dictAs]]=$i;
538
+            if ($dictAs) {
539
+                $dict = [];
540
+                foreach ($res as $i) {
541
+                    $dict[$i[$dictAs]] = $i;
542 542
                 }
543 543
                 return $context->handleResult($dict);
544 544
             }
545 545
             return $context->handleResult($res);
546
-        }else{
546
+        }else {
547 547
             return false;
548 548
         }
549 549
     }
@@ -552,22 +552,22 @@  discard block
 block discarded – undo
552 552
      * @param Context $context
553 553
      * @return int|false
554 554
      */
555
-    static public function count($context){
555
+    static public function count($context) {
556 556
 
557 557
         $found = [];
558
-        if(!preg_match('/\bselect\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
559
-            count($found)==0){
558
+        if (!preg_match('/\bselect\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
559
+            count($found) == 0) {
560 560
             \PhpBoot\abort(new \PDOException("can not use count(*) without select"));
561 561
         }
562 562
         list($chars, $columnBegin) = $found[0];
563
-        $columnBegin = $columnBegin + strlen('select')+1;
563
+        $columnBegin = $columnBegin + strlen('select') + 1;
564 564
 
565 565
         $columnEnd = 0;
566 566
         $found = [];
567
-        if(!preg_match('/\bfrom\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
568
-            count($found)==0){
567
+        if (!preg_match('/\bfrom\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
568
+            count($found) == 0) {
569 569
             $columnEnd = strlen($context->sql);
570
-        }else{
570
+        }else {
571 571
             list($chars, $columnEnd) = $found[0];
572 572
         }
573 573
         $sql = substr($context->sql, 0, $columnBegin);
@@ -575,10 +575,10 @@  discard block
 block discarded – undo
575 575
         $sql .= substr($context->sql, $columnEnd);
576 576
 
577 577
         $st = $context->connection->prepare($sql);
578
-        if($st->execute($context->params)){
578
+        if ($st->execute($context->params)) {
579 579
             $res = $st->fetchAll(\PDO::FETCH_ASSOC);
580 580
             return intval($res[0]['count']);
581
-        }else{
581
+        }else {
582 582
             return false;
583 583
         }
584 584
 
@@ -586,47 +586,47 @@  discard block
 block discarded – undo
586 586
 }
587 587
 class OnDuplicateKeyUpdateImpl
588 588
 {
589
-    public function set($context, $column, $value){
590
-        if(is_string($column)){
589
+    public function set($context, $column, $value) {
590
+        if (is_string($column)) {
591 591
             $this->setExpr($context, $column, $value);
592
-        }else{
592
+        }else {
593 593
             $this->setArgs($context, $column);
594 594
         }
595 595
     }
596 596
 
597
-    public function setExpr($context, $expr, $args){
597
+    public function setExpr($context, $expr, $args) {
598 598
         $prefix = '';
599
-        if($this->first){
599
+        if ($this->first) {
600 600
             $this->first = false;
601 601
             $prefix = 'ON DUPLICATE KEY UPDATE ';
602
-        }else{
602
+        }else {
603 603
             $prefix = ',';
604 604
         }
605 605
 
606
-        $context->appendSql("$prefix$expr",$prefix == 'ON DUPLICATE KEY UPDATE ');
606
+        $context->appendSql("$prefix$expr", $prefix == 'ON DUPLICATE KEY UPDATE ');
607 607
         $context->appendParams($args);
608 608
 
609 609
     }
610
-    public function setArgs($context, $values){
610
+    public function setArgs($context, $values) {
611 611
         $set = [];
612 612
         $params = [];
613
-        foreach ($values as $k=>$v){
613
+        foreach ($values as $k=>$v) {
614 614
             $k = DB::wrap($k);
615
-            if(is_a($v, Raw::class)){//直接拼接sql,不需要转义
616
-                $set[]= "$k=".$v->get();
617
-            }else{
618
-                $set[]= "$k=?";
619
-                $params[]=$v;
615
+            if (is_a($v, Raw::class)) {//直接拼接sql,不需要转义
616
+                $set[] = "$k=".$v->get();
617
+            }else {
618
+                $set[] = "$k=?";
619
+                $params[] = $v;
620 620
             }
621 621
         }
622
-        if($this->first){
622
+        if ($this->first) {
623 623
             $this->first = false;
624 624
             $context->appendSql('ON DUPLICATE KEY UPDATE '.implode(',', $set));
625 625
             $context->appendParams($params);
626
-        }else{
627
-            $context->appendSql(','.implode(',', $set),false);
626
+        }else {
627
+            $context->appendSql(','.implode(',', $set), false);
628 628
             $context->appendParams($params);
629 629
         }
630 630
     }
631
-    private $first=true;
631
+    private $first = true;
632 632
 }
Please login to merge, or discard this patch.
src/DB/rules/update.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -25,7 +25,7 @@  discard block
 block discarded – undo
25 25
 
26 26
 class UpdateSetRule extends BasicRule
27 27
 {
28
-    public function __construct($context){
28
+    public function __construct($context) {
29 29
         parent::__construct($context);
30 30
         $this->impl = new UpdateSetImpl();
31 31
     }
@@ -37,7 +37,7 @@  discard block
 block discarded – undo
37 37
      * @param mixed $_
38 38
      * @return UpdateSetWhereRule
39 39
      */
40
-    public function set($expr, $_=null) {
40
+    public function set($expr, $_ = null) {
41 41
         $this->impl->set($this->context, $expr, array_slice(func_get_args(), 1));
42 42
         return new UpdateSetWhereRule($this->context, $this->impl);
43 43
     }
@@ -46,7 +46,7 @@  discard block
 block discarded – undo
46 46
 
47 47
 class UpdateSetWhereRule extends WhereRule
48 48
 {
49
-    public function __construct(Context $context, UpdateSetImpl $impl){
49
+    public function __construct(Context $context, UpdateSetImpl $impl) {
50 50
         parent::__construct($context);
51 51
         $this->impl = $impl;
52 52
     }
@@ -57,7 +57,7 @@  discard block
 block discarded – undo
57 57
      * @param mixed $_
58 58
      * @return UpdateSetWhereRule
59 59
      */
60
-    public function set($expr, $_=null) {
60
+    public function set($expr, $_ = null) {
61 61
         $this->impl->set($this->context, $expr, array_slice(func_get_args(), 1));
62 62
         return new UpdateSetWhereRule($this->context, $this->impl);
63 63
     }
Please login to merge, or discard this patch.
src/DB/rules/insert.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -44,7 +44,7 @@  discard block
 block discarded – undo
44 44
      * @param array $values
45 45
      * @return \PhpBoot\DB\rules\insert\OnDuplicateKeyUpdateRule
46 46
      */
47
-    public function batchValues(array $values){
47
+    public function batchValues(array $values) {
48 48
         ValuesImpl::batchValues($this->context, $values);
49 49
         return new OnDuplicateKeyUpdateRule($this->context);
50 50
     }
@@ -106,7 +106,7 @@  discard block
 block discarded – undo
106 106
      * @param mixed $value
107 107
      * @return \PhpBoot\DB\rules\basic\ExecRule
108 108
      */
109
-    public function onDuplicateKeyUpdate($expr, $_=null) {
109
+    public function onDuplicateKeyUpdate($expr, $_ = null) {
110 110
         $this->impl->set($this->context, $expr, array_slice(func_get_args(), 1));
111 111
         return new ExecRule($this->context);
112 112
     }
Please login to merge, or discard this patch.