caoym / phpboot

src/RPC/MultiRequestCore.php

Spacing +11 added lines, -11 removed lines

@@ -13,13 +13,13 @@ 
      */
     public function __construct(array $threads, callable $waitAll)
     {
-        foreach ($threads as $thread){
+        foreach ($threads as $thread) {
             $pos = count($this->threadResults);
-            $this->threadResults[] = [null,null];
-            $this->threads[] = function ()use($thread, $pos){
-                try{
+            $this->threadResults[] = [null, null];
+            $this->threads[] = function()use($thread, $pos){
+                try {
                     $this->threadResults[$pos][0] = $thread();
-                }catch (\Exception $e){
+                }catch (\Exception $e) {
                     $this->threadResults[$pos][1] = $e;
                 }
             };
@@ -29,25 +29,25 @@ 
 
     public function run()
     {
-        while ($thread = array_pop($this->threads)){
+        while ($thread = array_pop($this->threads)) {
             $thread();
         };
     }
 
-    public function wait($waitAble){
+    public function wait($waitAble) {
         array_push($this->waits, $waitAble);
         $this->run();
 
-        if(count($this->waits)){
+        if (count($this->waits)) {
             $waitAll = $this->waitAll;
             $this->waitResults = $waitAll($this->waits);
             $this->waits = [];
         }
 
-        $res =  array_pop($this->waitResults);
-        if(isset($res[1])){
+        $res = array_pop($this->waitResults);
+        if (isset($res[1])) {
              \PhpBoot\abort(new RpcException($res['reason']));
-        }else{
+        }else {
             return $res[0];
         }
     }

src/Application.php

Spacing +19 added lines, -19 removed lines

@@ -93,11 +93,11 @@ 
 
             Request::class => \DI\factory([Application::class, 'createRequestFromGlobals']),
         ];
-        if(function_exists('apc_fetch')){
+        if (function_exists('apc_fetch')) {
             $default += [
                 Cache::class => \DI\object(ApcCache::class)
             ];
-        }else{
+        }else {
             $default += [
                 Cache::class => \DI\object(FilesystemCache::class)
                     ->constructorParameter('directory', sys_get_temp_dir())
@@ -139,11 +139,11 @@ 
      * @param string[] $hooks hook class names
      * @return void
      */
-    public function loadRoutesFromClass($className, $hooks=[])
+    public function loadRoutesFromClass($className, $hooks = [])
     {
         $cache = new CheckableCache($this->cache);
 
-        $key = 'loadRoutesFromClass:' . md5(__CLASS__ . ':' . $className);
+        $key = 'loadRoutesFromClass:'.md5(__CLASS__.':'.$className);
         $routes = $cache->get($key, $this);
 
         $controller = null;
@@ -160,9 +160,9 @@ 
             $this->routes[] = [
                 $method,
                 $uri,
-                function (Application $app, Request $request) use ($cache, $className, $actionName, $controller) {
+                function(Application $app, Request $request) use ($cache, $className, $actionName, $controller) {
 
-                    $key = 'loadRoutesFromClass:route:' . md5(__CLASS__ . ':' . $className . ':' . $actionName);
+                    $key = 'loadRoutesFromClass:route:'.md5(__CLASS__.':'.$className.':'.$actionName);
 
                     $routeInstance = $cache->get($key, $this);
                     if ($routeInstance == $this) {
@@ -190,11 +190,11 @@ 
      * @param string[] $hooks
      * @return void
      */
-    public function loadRoutesFromPath($fromPath, $namespace = '', $hooks=[])
+    public function loadRoutesFromPath($fromPath, $namespace = '', $hooks = [])
     {
         $dir = @dir($fromPath) or abort("dir $fromPath not exist");
 
-        $getEach = function () use ($dir) {
+        $getEach = function() use ($dir) {
             $name = $dir->read();
             if (!$name) {
                 return $name;
@@ -206,11 +206,11 @@ 
             if ($entry == '.' || $entry == '..') {
                 continue;
             }
-            $path = $fromPath . '/' . str_replace('\\', '/', $entry);
+            $path = $fromPath.'/'.str_replace('\\', '/', $entry);
             if (is_file($path) && substr_compare($entry, '.php', strlen($entry) - 4, 4, true) == 0) {
-                $class_name = $namespace . '\\' . substr($entry, 0, strlen($entry) - 4);
+                $class_name = $namespace.'\\'.substr($entry, 0, strlen($entry) - 4);
                 $this->loadRoutesFromClass($class_name, $hooks);
-            } else {
+            }else {
                 //\Log::debug($path.' ignored');
             }
         }
@@ -223,7 +223,7 @@ 
      * @param callable $handler function(Application $app, Request $request):Response
      * @param string[] $hooks
      */
-    public function addRoute($method, $uri, callable $handler, $hooks=[])
+    public function addRoute($method, $uri, callable $handler, $hooks = [])
     {
         $this->routes[] = [$method, $uri, $handler, $hooks];
     }
@@ -249,7 +249,7 @@ 
     {
         //  TODO 把 Route里的异常处理 ExceptionRenderer 移到这里更妥?
         $renderer = $this->get(ExceptionRenderer::class);
-        try{
+        try {
             if ($request == null) {
                 $request = $this->make(Request::class);
             }
@@ -259,7 +259,7 @@ 
             }
             $uri = rawurldecode($uri);
 
-            $next = function (Request $request)use($uri){
+            $next = function(Request $request)use($uri){
                 $dispatcher = $this->getDispatcher();
                 $res = $dispatcher->dispatch($request->getMethod(), $uri);
                 if ($res[0] == Dispatcher::FOUND) {
@@ -268,10 +268,10 @@ 
                         $request->attributes->add($res[2]);
                     }
                     list($handler, $hooks) = $res[1];
-                    $next = function (Request $request)use($handler){
+                    $next = function(Request $request)use($handler){
                         return $handler($this, $request);
                     };
-                    foreach (array_reverse($hooks) as $hookName){
+                    foreach (array_reverse($hooks) as $hookName) {
                         $next = function($request)use($hookName, $next){
                             $hook = $this->get($hookName);
                             /**@var $hook HookInterface*/
@@ -284,12 +284,12 @@ 
                     \PhpBoot\abort(new NotFoundHttpException(), [$request->getMethod(), $uri]);
                 } elseif ($res[0] == Dispatcher::METHOD_NOT_ALLOWED) {
                     \PhpBoot\abort(new MethodNotAllowedHttpException($res[1]), [$request->getMethod(), $uri]);
-                } else {
+                }else {
                     \PhpBoot\abort("unknown dispatch return {$res[0]}");
                 }
             };
 
-            foreach (array_reverse($this->getGlobalHooks()) as $hookName){
+            foreach (array_reverse($this->getGlobalHooks()) as $hookName) {
                 $next = function($request)use($hookName, $next){
                     $hook = $this->get($hookName);
                     /**@var $hook HookInterface*/
@@ -304,7 +304,7 @@ 
             }
             return $response;
 
-        }catch (\Exception $e){
+        }catch (\Exception $e) {
             $renderer->render($e);
         }
 

src/Controller/Annotations/ReturnAnnotationHandler.php

Spacing +6 added lines, -6 removed lines

@@ -21,20 +21,20 @@ 
      */
     public function __invoke(ControllerContainer $container, $ann, EntityContainerBuilder $entityBuilder)
     {
-        if(!$ann->parent){
+        if (!$ann->parent) {
             //Logger::debug("The annotation \"@{$ann->name} {$ann->description}\" of {$container->getClassName()} should be used with parent route");
             return;
         }
         $target = $ann->parent->name;
         $route = $container->getRoute($target);
-        if(!$route){
+        if (!$route) {
             //Logger::debug("The annotation \"@{$ann->name} {$ann->description}\" of {$container->getClassName()}::$target should be used with parent route");
-            return ;
+            return;
         }
 
         $params = new AnnotationParams($ann->description, 2);
         $type = $doc = null;
-        if(count($params)>0){
+        if (count($params)>0) {
             $type = TypeHint::normalize($params[0], $container->getClassName());
         }
         $doc = $params->getRawParam(1, '');
@@ -42,10 +42,10 @@ 
         list($_, $meta) = $route
             ->getResponseHandler()
             ->getMappingBySource('return');
-        if($meta){
+        if ($meta) {
             $meta->description = $doc;
             $meta->type = $type;
-            $meta->container = $type == 'void'?null:ContainerFactory::create($entityBuilder, $type);
+            $meta->container = $type == 'void' ?null:ContainerFactory::create($entityBuilder, $type);
         }
     }
 }
\ No newline at end of file

src/Validator/Validator.php

Spacing +3 added lines, -3 removed lines

@@ -55,12 +55,12 @@
      */
     public function rule($rule, $fields)
     {
-        if(is_string($rule)){
+        if (is_string($rule)) {
             $rules = explode('|', $rule);
-            foreach ($rules as $r){
+            foreach ($rules as $r) {
                 $params = explode(':', trim($r));
                 $rule = $params[0];
-                $params = isset($params[1])?explode(',', $params[1]):[];
+                $params = isset($params[1]) ?explode(',', $params[1]) : [];
 
                 call_user_func_array([$this, 'parent::rule'], array_merge([$rule, $fields], $params));
 

src/ORM/ModelWithClass.php

Spacing +11 added lines, -11 removed lines

@@ -29,9 +29,9 @@ 
             ->from($this->entity->getTable())
             ->where("`{$this->entity->getPK()}` = ?", $id)
             ->getFirst();
-        if($row){
+        if ($row) {
             return $this->entity->make($row, false);
-        }else{
+        }else {
             return null;
         }
     }
@@ -53,7 +53,7 @@ 
      * @param mixed|null $_
      * @return \PhpBoot\DB\rules\basic\WhereRule
      */
-    public function deleteWhere($conditions, $_=null)
+    public function deleteWhere($conditions, $_ = null)
     {
         $query = $this->db->deleteFrom($this->entity->getTable());
         return call_user_func_array([$query, 'where'], func_get_args());
@@ -75,12 +75,12 @@ 
      * @param string $_
      * @return \PhpBoot\DB\rules\select\WhereRule
      */
-    public function findWhere($conditions=null, $_=null)
+    public function findWhere($conditions = null, $_ = null)
     {
-        $query =  $this->db->select($this->getColumns())
+        $query = $this->db->select($this->getColumns())
             ->from($this->entity->getTable());
-        $query->context->resultHandler = function ($result){
-            foreach ($result as &$i){
+        $query->context->resultHandler = function($result) {
+            foreach ($result as &$i) {
                 $i = $this->entity->make($i, false);
             }
             return $result;
@@ -107,16 +107,16 @@ 
      * @param string $_
      * @return \PhpBoot\DB\rules\basic\WhereRule
      */
-    public function updateWhere($values, $conditions, $_=null)
+    public function updateWhere($values, $conditions, $_ = null)
     {
-        $query =  $this->db->update($this->entity->getTable())->set($values);
-        return call_user_func_array([$query, 'where'], array_slice(func_get_args(),1));
+        $query = $this->db->update($this->entity->getTable())->set($values);
+        return call_user_func_array([$query, 'where'], array_slice(func_get_args(), 1));
     }
 
     protected function getColumns()
     {
         $columns = [];
-        foreach ($this->entity->getProperties() as $p){
+        foreach ($this->entity->getProperties() as $p) {
             $columns[] = $p->name;
         }
         return $columns;

src/DB/DB.php

Spacing +19 added lines, -19 removed lines

@@ -50,7 +50,7 @@ 
  *      
  * @author caoym <caoyangmin@gmail.com>
  */
-class DB{
+class DB {
 
     /**
      * DB constructor.
@@ -90,18 +90,18 @@ 
      * @param string $column0
      * @return \PhpBoot\DB\rules\select\FromRule
      */
-    function select($column0=null, $_=null){
+    function select($column0 = null, $_ = null) {
         $obj = new SelectRule(new Context($this->connection));
-        if($column0 == null){
+        if ($column0 == null) {
             $args = ['*'];
-        }elseif(is_array($column0)){
+        }elseif (is_array($column0)) {
             $args = $column0;
-        }else{
+        }else {
             $args = func_get_args();
         }
-        foreach ($args as &$arg){
+        foreach ($args as &$arg) {
             $arg = DB::wrap($arg);
-            if($arg == '*'){
+            if ($arg == '*') {
                 continue;
             }
         }
@@ -132,8 +132,8 @@ 
      * @param string $table
      * @return \PhpBoot\DB\rules\basic\WhereRule
      */
-    public function deleteFrom($table){
-        $obj  =  new DeleteRule(new Context($this->connection));
+    public function deleteFrom($table) {
+        $obj = new DeleteRule(new Context($this->connection));
         return $obj->deleteFrom($table);
     }
     /**
@@ -141,8 +141,8 @@ 
      * @param string $table
      * @return \PhpBoot\DB\rules\replace\ValuesRule
      */
-    public function replaceInto($table){
-        $obj  =  new ReplaceIntoRule(new Context($this->connection));
+    public function replaceInto($table) {
+        $obj = new ReplaceIntoRule(new Context($this->connection));
         return $obj->replaceInto($table);
     }
 
@@ -153,16 +153,16 @@ 
      */
     public function transaction(callable $callback)
     {
-        if($this->inTransaction){
+        if ($this->inTransaction) {
             return $callback($this);
         }
         $this->getConnection()->beginTransaction() or \PhpBoot\abort('beginTransaction failed');
         $this->inTransaction = true;
-        try{
+        try {
             $res = $callback($this);
             $this->getConnection()->commit() or \PhpBoot\abort('commit failed');
             return $res;
-        }catch (\Exception $e){
+        }catch (\Exception $e) {
             $this->getConnection()->rollBack();
             Logger::warning('commit failed with '.get_class($e).' '.$e->getMessage());
             throw $e;
@@ -183,12 +183,12 @@ 
      * @param string $str
      * @return Raw
      */
-    static public function raw($str){
+    static public function raw($str) {
         return new Raw($str);
     }
     static public function wrap($value)
     {
-        if($value instanceof Raw){
+        if ($value instanceof Raw) {
             return $value->get();
         }
         $value = trim($value);
@@ -196,7 +196,7 @@ 
             return $value;
         }
 
-        if(strpos($value, '.') !== false && !preg_match('/\\s+/', $value)){
+        if (strpos($value, '.') !== false && !preg_match('/\\s+/', $value)) {
             return $value;
         }
         return '`'.str_replace('`', '``', $value).'`';
@@ -209,8 +209,8 @@ 
     {
         return $this->app;
     }
-    const ORDER_BY_ASC ='ASC';
-    const ORDER_BY_DESC ='DESC';
+    const ORDER_BY_ASC = 'ASC';
+    const ORDER_BY_DESC = 'DESC';
 
     /**
      * @var \PDO

src/DB/rules/select.php

Spacing +33 added lines, -33 removed lines

@@ -39,7 +39,7 @@ 
      * @param string|false $asDict
      * @return array
      */
-    public function get($asDict=false) {
+    public function get($asDict = false) {
         return ExecImpl::get($this->context, $asDict);
     }
 
@@ -53,9 +53,9 @@ 
      * Execute sql and get one response
      * @return null
      */
-    public function getFirst(){
+    public function getFirst() {
         $res = ExecImpl::get($this->context);
-        if(count($res)){
+        if (count($res)) {
             return $res[0];
         }
         return null;
@@ -68,8 +68,8 @@ 
      * @param string $table
      * @return \PhpBoot\DB\rules\select\JoinRule
      */
-    public function from($table, $as=null){
-        FromImpl::from($this->context, $table,$as);
+    public function from($table, $as = null) {
+        FromImpl::from($this->context, $table, $as);
         return new JoinRule($this->context);
     }
 }
@@ -80,7 +80,7 @@ 
      * @param string $column
      * @return \PhpBoot\DB\rules\select\GetRule
      */
-    public function of($column){
+    public function of($column) {
         ForUpdateOfImpl::of($this->context, $column);
         return new GetRule($this->context);
     }
@@ -91,7 +91,7 @@ 
      * forUpdate() => 'FOR UPDATE'
      * @return \PhpBoot\DB\rules\select\ForUpdateOfRule
      */
-    public function forUpdate(){
+    public function forUpdate() {
         ForUpdateImpl::forUpdate($this->context);
         return new ForUpdateOfRule($this->context);
     }
@@ -113,7 +113,7 @@ 
 
 class OrderByRule extends LimitRule
 {
-    public function __construct($context){
+    public function __construct($context) {
         parent::__construct($context);
         $this->order = new OrderByImpl();
     }
@@ -128,7 +128,7 @@ 
      * @param string $order Sql::ORDER_BY_ASC or Sql::ORDER_BY_DESC
      * @return \PhpBoot\DB\rules\select\OrderByRule
      */
-    public function orderBy($column, $order=null) {
+    public function orderBy($column, $order = null) {
         $this->order->orderBy($this->context, $column, $order);
         return $this;
     }
@@ -174,17 +174,17 @@ 
      * @param string $_
      * @return \PhpBoot\DB\rules\select\HavingRule
      */
-    public function having($expr, $_=null) {
-        if(is_callable($expr)){
-            $callback = function ($context)use($expr){
+    public function having($expr, $_ = null) {
+        if (is_callable($expr)) {
+            $callback = function($context)use($expr){
                 $rule = new ScopedQuery($context);
                 $expr($rule);
             };
             $expr = $callback;
         }
-        if($this->isTheFirst){
+        if ($this->isTheFirst) {
             WhereImpl::where($this->context, 'HAVING', $expr, array_slice(func_get_args(), 1));
-        }else{
+        }else {
             WhereImpl::where($this->context, 'AND', $expr, array_slice(func_get_args(), 1));
         }
 
@@ -211,9 +211,9 @@ 
      * @param string $_
      * @return \PhpBoot\DB\rules\select\HavingRule
      */
-    public function orHaving($expr, $_=null) {
-        if(is_callable($expr)){
-            $callback = function ($context)use($expr){
+    public function orHaving($expr, $_ = null) {
+        if (is_callable($expr)) {
+            $callback = function($context)use($expr){
                 $rule = new ScopedQuery($context);
                 $expr($rule);
             };
@@ -263,17 +263,17 @@ 
      * @param mixed $_
      * @return \PhpBoot\DB\rules\select\NextWhereRule
      */
-    public function where($conditions=null, $_=null) {
-        if(is_callable($conditions)){
-            $callback = function ($context)use($conditions){
+    public function where($conditions = null, $_ = null) {
+        if (is_callable($conditions)) {
+            $callback = function($context)use($conditions){
                 $rule = new ScopedQuery($context);
                 $conditions($rule);
             };
             $conditions = $callback;
         }
-        if($this->isTheFirst){
-            WhereImpl::where($this->context, 'WHERE' ,$conditions, array_slice(func_get_args(), 1));
-        }else{
+        if ($this->isTheFirst) {
+            WhereImpl::where($this->context, 'WHERE', $conditions, array_slice(func_get_args(), 1));
+        }else {
             WhereImpl::where($this->context, 'AND', $conditions, array_slice(func_get_args(), 1));
         }
         return new NextWhereRule($this->context, false);
@@ -304,9 +304,9 @@ 
      *
      * @TODO orWhere 只能跟在 Where 后
      */
-    public function orWhere($conditions=null, $_=null) {
-        if(is_callable($conditions)){
-            $callback = function ($context)use($conditions){
+    public function orWhere($conditions = null, $_ = null) {
+        if (is_callable($conditions)) {
+            $callback = function($context)use($conditions){
                 $rule = new ScopedQuery($context);
                 $conditions($rule);
             };
@@ -325,8 +325,8 @@ 
      * @param string $table
      * @return \PhpBoot\DB\rules\select\JoinOnRule
      */
-    public function join($table){
-        JoinImpl::join($this->context,null, $table);
+    public function join($table) {
+        JoinImpl::join($this->context, null, $table);
         return new JoinOnRule($this->context);
     }
     /**
@@ -334,8 +334,8 @@ 
      * @param string $table
      * @return \PhpBoot\DB\rules\select\JoinOnRule
      */
-    public function leftJoin($table){
-        JoinImpl::join($this->context,'LEFT', $table);
+    public function leftJoin($table) {
+        JoinImpl::join($this->context, 'LEFT', $table);
         return new JoinOnRule($this->context);
     }
     /**
@@ -344,7 +344,7 @@ 
      * @return \PhpBoot\DB\rules\select\JoinOnRule
      */
     public function rightJoin($table) {
-        JoinImpl::join($this->context,'RIGHT', $table);
+        JoinImpl::join($this->context, 'RIGHT', $table);
         return new JoinOnRule($this->context);
     }
     /**
@@ -353,7 +353,7 @@ 
      * @return \PhpBoot\DB\rules\select\JoinOnRule
      */
     public function innerJoin($table) {
-        JoinImpl::join($this->context,'INNER', $table);
+        JoinImpl::join($this->context, 'INNER', $table);
         return new JoinOnRule($this->context);
     }
 }
@@ -365,7 +365,7 @@ 
      * @param string $condition
      * @return \PhpBoot\DB\rules\select\JoinRule
      */
-    public function on($condition){
+    public function on($condition) {
         JoinOnImpl::on($this->context, $condition);
         return new JoinRule($this->context);
     }

src/DB/rules/basic.php

Spacing +20 added lines, -20 removed lines

@@ -11,7 +11,7 @@ 
 
 class BasicRule
 {
-    public function __construct(Context $context){
+    public function __construct(Context $context) {
         $this->context = $context;
     }
 
@@ -48,7 +48,7 @@ 
 
 class OrderByRule extends LimitRule
 {
-    public function __construct($context){
+    public function __construct($context) {
         parent::__construct($context);
         $this->impl = new OrderByImpl();
     }
@@ -63,7 +63,7 @@ 
      * 
      * @return \PhpBoot\DB\rules\basic\LimitRule
      */
-    public function orderBy($column, $order=null) {
+    public function orderBy($column, $order = null) {
         $this->impl->orderBy($this->context, $column, $order);
         return new LimitRule($this->context);
     }
@@ -95,17 +95,17 @@ 
      * @param mixed $_
      * @return NextWhereRule
      */
-    public function where($conditions=null, $_=null) {
-        if(is_callable($conditions)){
-            $callback = function ($context)use($conditions){
+    public function where($conditions = null, $_ = null) {
+        if (is_callable($conditions)) {
+            $callback = function($context)use($conditions){
                 $rule = new ScopedQuery($context);
                 $conditions($rule);
             };
             $conditions = $callback;
         }
-        if($this->isTheFirst){
-            WhereImpl::where($this->context, 'WHERE' ,$conditions, array_slice(func_get_args(), 1));
-        }else{
+        if ($this->isTheFirst) {
+            WhereImpl::where($this->context, 'WHERE', $conditions, array_slice(func_get_args(), 1));
+        }else {
             WhereImpl::where($this->context, 'AND', $conditions, array_slice(func_get_args(), 1));
         }
         return new NextWhereRule($this->context, false);
@@ -133,9 +133,9 @@ 
      * @param mixed $_
      * @return WhereRule
      */
-    public function orWhere($conditions=null, $_=null) {
-        if(is_callable($conditions)){
-            $callback = function ($context)use($conditions){
+    public function orWhere($conditions = null, $_ = null) {
+        if (is_callable($conditions)) {
+            $callback = function($context)use($conditions){
                 $rule = new ScopedQuery($context);
                 $conditions($rule);
             };
@@ -160,17 +160,17 @@ 
      * @param null $_
      * @return NextScopedQuery
      */
-    public function where($expr, $_= null){
-        if(is_callable($expr)){
-            $callback = function ($context)use($expr){
+    public function where($expr, $_ = null) {
+        if (is_callable($expr)) {
+            $callback = function($context)use($expr){
                 $rule = new ScopedQuery($context, true);
                 $expr($rule);
             };
             $expr = $callback;
         }
-        if($this->isTheFirst){
+        if ($this->isTheFirst) {
             WhereImpl::where($this->context, '', $expr, array_slice(func_get_args(), 1));
-        }else{
+        }else {
             WhereImpl::where($this->context, 'AND', $expr, array_slice(func_get_args(), 1));
         }
         return new NextScopedQuery($this->context, false);
@@ -186,9 +186,9 @@ 
      * @param null $_
      * @return ScopedQuery
      */
-    public function orWhere($expr, $_= null){
-        if(is_callable($expr)){
-            $callback = function ($context)use($expr){
+    public function orWhere($expr, $_ = null) {
+        if (is_callable($expr)) {
+            $callback = function($context)use($expr){
                 $rule = new ScopedQuery($context, true);
                 $expr($rule);
             };

src/DB/impls.php

Spacing +163 added lines, -163 removed lines

@@ -7,14 +7,14 @@ 
 use PhpBoot\DB\rules\basic\BasicRule;
 use PhpBoot\DB\Context;
 
-class ExecResult{
-    public function __construct($success, $pdo, $st){
+class ExecResult {
+    public function __construct($success, $pdo, $st) {
         $this->pdo = $pdo;
         $this->st = $st;
         $this->success = $success;
         $this->rows = $this->st->rowCount();
     }
-    public function lastInsertId($name=null){
+    public function lastInsertId($name = null) {
         return $this->pdo->lastInsertId($name);
     }
     /**
@@ -41,21 +41,21 @@ 
 
 class SelectImpl
 {
-    static  public function select($context, $columns){
+    static  public function select($context, $columns) {
         $context->appendSql("SELECT $columns");
     }
 }
 
 class FromImpl
 {
-    static public function from($context, $tables,$as=null){
-        if($tables instanceof BasicRule){
+    static public function from($context, $tables, $as = null) {
+        if ($tables instanceof BasicRule) {
             $context->appendSql("FROM (".$tables->context->sql.')');
-            $context->params = array_merge($context->params,$tables->context->params);
+            $context->params = array_merge($context->params, $tables->context->params);
         }else {
             $context->appendSql("FROM ".DB::wrap($tables));
         }
-        if($as){
+        if ($as) {
             $context->appendSql("AS ".DB::wrap($as));
         }
     }
@@ -73,9 +73,9 @@ 
 {
     static public function join($context, $type, $table) {
         $table = DB::wrap($table);
-        if($type){
+        if ($type) {
             $context->appendSql("$type JOIN $table");
-        }else{
+        }else {
             $context->appendSql("JOIN $table");
         }
     }
@@ -90,14 +90,14 @@ 
 
 class ForUpdateImpl
 {
-    static public function forUpdate($context){
+    static public function forUpdate($context) {
         $context->appendSql("FOR UPDATE");
     }
 }
 
 class ForUpdateOfImpl
 {
-    static public function of($context, $column){
+    static public function of($context, $column) {
         $column = DB::wrap($column);
         $context->appendSql("OF $column");
     }
@@ -119,57 +119,57 @@ 
 }
 class ValuesImpl
 {
-     static public function values(Context $context, array $values){
+     static public function values(Context $context, array $values) {
         $params = [];
         $stubs = [];
-        foreach ($values as $v){
-            if(is_a($v, Raw::class)){//直接拼接sql，不需要转义
-                $stubs[]=$v->get();
-            }else{
-                $stubs[]='?';
+        foreach ($values as $v) {
+            if (is_a($v, Raw::class)) {//直接拼接sql，不需要转义
+                $stubs[] = $v->get();
+            }else {
+                $stubs[] = '?';
                 $params[] = $v;
             }
         }
         $stubs = implode(',', $stubs);
 
-        if(array_keys($values) === range(0, count($values) - 1)){
+        if (array_keys($values) === range(0, count($values) - 1)) {
             //VALUES(val0, val1, val2)
             $context->appendSql("VALUES($stubs)");
 
-        }else{
+        }else {
             //(col0, col1, col2) VALUES(val0, val1, val2)
-            $columns = implode(',', array_map(function($k){return DB::wrap($k);}, array_keys($values)));
-            $context->appendSql("($columns) VALUES($stubs)",false);
+            $columns = implode(',', array_map(function($k) {return DB::wrap($k); }, array_keys($values)));
+            $context->appendSql("($columns) VALUES($stubs)", false);
         }
         $context->appendParams($params);
     }
     static public function batchValues(Context $context, array $values)
     {
         $count = count($values);
-        if($count == 0){
+        if ($count == 0) {
             return;
         }
         $keys = array_keys($values[0]);
         $row = implode(',', self::toSql(array_values($values[0])));
-        if($keys === range(0, count($keys) - 1)){
+        if ($keys === range(0, count($keys) - 1)) {
             //VALUES(val0, val1, val2)
             $context->appendSql("VALUES($row)");
-        }else{
+        }else {
             //(col0, col1, col2) VALUES(val0, val1, val2)
-            $columns = implode(',', array_map(function($k){return DB::wrap($k);}, $keys));
-            $context->appendSql("($columns) VALUES($row)",false);
+            $columns = implode(',', array_map(function($k) {return DB::wrap($k); }, $keys));
+            $context->appendSql("($columns) VALUES($row)", false);
         }
-        for($i=1; $i<$count; $i++){
+        for ($i = 1; $i<$count; $i++) {
             $value = self::pick($keys, $values[$i]);
             $row = implode(',', self::toSql($value));
-            $context->appendSql(", ($row)",false);
+            $context->appendSql(", ($row)", false);
         }
     }
 
     static protected function pick(array $keys, array $values)
     {
         $res = [];
-        foreach ($keys as $key){
+        foreach ($keys as $key) {
             array_key_exists($key, $values) or \PhpBoot\abort("key $key not exist from the given array");
             $res[$key] = $values[$key];
         }
@@ -177,12 +177,12 @@ 
     }
     static protected function toSql(array $values)
     {
-        foreach ($values as &$v){
-            if($v instanceof Raw){
+        foreach ($values as &$v) {
+            if ($v instanceof Raw) {
                 $v = $v->get();
-            }elseif(is_bool($v)){
-                $v = $v?'true':'false';
-            }elseif(!in_array(gettype($v), ['integer', 'boolean', 'double', 'float'])){
+            }elseif (is_bool($v)) {
+                $v = $v ? 'true' : 'false';
+            }elseif (!in_array(gettype($v), ['integer', 'boolean', 'double', 'float'])) {
                 $v = (string)$v;
                 $v = str_replace("\\", "\\\\", $v);
                 $v = str_replace("'", "\\'", $v);
@@ -195,7 +195,7 @@ 
 
 class UpdateImpl
 {
-    static public function update($context, $table){
+    static public function update($context, $table) {
         $table = DB::wrap($table);
         $context->appendSql("UPDATE $table");
     }
@@ -203,81 +203,81 @@ 
 
 class UpdateSetImpl
 {
-    public function set(Context $context, $expr, $args){
-        if(is_string($expr)){
+    public function set(Context $context, $expr, $args) {
+        if (is_string($expr)) {
             return $this->setExpr($context, $expr, $args);
-        }else{
+        }else {
             return $this->setArgs($context, $expr);
         }
     }
 
-    public function setExpr(Context $context, $expr, $args){
-        if($this->first){
+    public function setExpr(Context $context, $expr, $args) {
+        if ($this->first) {
             $this->first = false;
             $prefix = 'SET ';
-        }else{
+        }else {
             $prefix = ',';
         }
 
-        $context->appendSql("$prefix$expr",$prefix == 'SET ');
+        $context->appendSql("$prefix$expr", $prefix == 'SET ');
         $context->appendParams($args);
 
     }
-    public function setArgs(Context $context, $values){
+    public function setArgs(Context $context, $values) {
         $set = [];
         $params = [];
-        foreach ($values as $k=>$v){
+        foreach ($values as $k=>$v) {
             $k = DB::wrap($k);
-            if(is_a($v, Raw::class)){//直接拼接sql，不需要转义
-                $set[]= "$k=".$v->get();
-            }else{
-                $set[]= "$k=?";
-                $params[]=$v;
+            if (is_a($v, Raw::class)) {//直接拼接sql，不需要转义
+                $set[] = "$k=".$v->get();
+            }else {
+                $set[] = "$k=?";
+                $params[] = $v;
             }
         }
-        if($this->first){
+        if ($this->first) {
             $this->first = false;
             $context->appendSql('SET '.implode(',', $set));
             $context->appendParams($params);
-        }else{
-            $context->appendSql(','.implode(',', $set),false);
+        }else {
+            $context->appendSql(','.implode(',', $set), false);
             $context->appendParams($params);
         }
     }
-    private $first=true;
+    private $first = true;
 }
 class OrderByImpl
 {
-    public function orderByArgs(Context $context, $orders){
-        if(empty($orders)){
+    public function orderByArgs(Context $context, $orders) {
+        if (empty($orders)) {
             return $this;
         }
         $params = array();
-        foreach ($orders as $k=>$v){
-            if(is_integer($k)){
+        foreach ($orders as $k=>$v) {
+            if (is_integer($k)) {
                 $params[] = DB::wrap($v);
-            }else{
+            }else {
                 $k = DB::wrap($k);
 
                 $v = strtoupper($v);
-                ($v =='DESC' || $v =='ASC') or \PhpBoot\abort( new \InvalidArgumentException("invalid params for orderBy(".json_encode($orders).")"));
+                ($v == 'DESC' || $v == 'ASC') or \PhpBoot\abort(new \InvalidArgumentException("invalid params for orderBy(".json_encode($orders).")"));
 
                 $params[] = "$k $v";
             }
         }
-        if($this->first){
+        if ($this->first) {
             $this->first = false;
             $context->appendSql('ORDER BY '.implode(',', $params));
-        }else{
-            $context->appendSql(','.implode(',', $params),false);
+        }else {
+            $context->appendSql(','.implode(',', $params), false);
         }
         return $this;
     }
-    public function orderBy(Context $context, $column, $order=null){
-        if(is_string($column)){
-            if($order === null){
+    public function orderBy(Context $context, $column, $order = null) {
+        if (is_string($column)) {
+            if ($order === null) {
                 $column = [$column];
-            }else{
+            }else {
                 $column = [$column=>$order];
             }
         }
@@ -285,18 +285,18 @@ 
 
 
     }
-    private $first=true;
+    private $first = true;
 }
 
 class LimitImpl
 {
-    static public function limit(Context $context, $size){
+    static public function limit(Context $context, $size) {
         $intSize = intval($size);
         strval($intSize) == $size or \PhpBoot\abort(
             new \InvalidArgumentException("invalid params for limit($size)"));
         $context->appendSql("LIMIT $size");
     }
-    static public function limitWithOffset(Context $context, $start, $size){
+    static public function limitWithOffset(Context $context, $start, $size) {
         $intStart = intval($start);
         $intSize = intval($size);
         strval($intStart) == $start && strval($intSize) == $size or \PhpBoot\abort(
@@ -305,31 +305,31 @@ 
     }
 }
 
-class WhereImpl{
+class WhereImpl {
 
-    static private function findQ($str,$offset = 0,$no=0){
+    static private function findQ($str, $offset = 0, $no = 0) {
         $found = strpos($str, '?', $offset);
-        if($no == 0 || $found === false){
+        if ($no == 0 || $found === false) {
             return $found;
         }
-        return self::findQ($str, $found+1, $no-1);
+        return self::findQ($str, $found + 1, $no - 1);
     }
 
-    static public function where(Context $context, $prefix, $expr, $args){
-        if(empty($expr)){
+    static public function where(Context $context, $prefix, $expr, $args) {
+        if (empty($expr)) {
             return;
         }
-        if(is_callable($expr)){
-            self::conditionClosure($context,$prefix, $expr);
-        }elseif (is_string($expr)){
+        if (is_callable($expr)) {
+            self::conditionClosure($context, $prefix, $expr);
+        }elseif (is_string($expr)) {
             self::condition($context, $prefix, $expr, $args);
-        }else{
+        }else {
             self::conditionArgs($context, $prefix, $expr);
         }
 
     }
 
-    static public function conditionClosure(Context $context, $prefix, callable $callback){
+    static public function conditionClosure(Context $context, $prefix, callable $callback) {
         $context->appendSql($prefix.' (');
         $callback($context);
         $context->appendSql(')');
@@ -355,15 +355,15 @@ 
      * NOT IN   'id'=>['NOT IN' => [1,2,3]]
      * @return void
      */
-    static public function conditionArgs(Context $context, $prefix, $args=[]){
-        if($args ===null){
-            return ;
+    static public function conditionArgs(Context $context, $prefix, $args = []) {
+        if ($args === null) {
+            return;
         }
         $exprs = array();
         $params = array();
-        foreach ($args as $k => $v){
+        foreach ($args as $k => $v) {
             $k = DB::wrap($k);
-            if(!is_array($v)){
+            if (!is_array($v)) {
                 $v = ['='=>$v];
             }
 
@@ -375,56 +375,56 @@ 
                 new \InvalidArgumentException("invalid param $op for whereArgs"));
 
             $var = array_values($v)[0];
-            if($op == 'IN' || $op == 'NOT IN'){
+            if ($op == 'IN' || $op == 'NOT IN') {
                 $stubs = [];
 
-                if($var instanceof BasicRule){
+                if ($var instanceof BasicRule) {
                     $stubs = "({$var->context->sql})";
                     $params = array_merge($params, $var->context->params);
                     $exprs[] = "$k $op $stubs";
-                }else{
-                    foreach ($var as $i){
-                        if(is_a($i, Raw::class)){
-                            $stubs[]=strval($i);
-                        }elseif($i instanceof BasicRule){
+                }else {
+                    foreach ($var as $i) {
+                        if (is_a($i, Raw::class)) {
+                            $stubs[] = strval($i);
+                        }elseif ($i instanceof BasicRule) {
                             $stubs = "({$i->context->sql})";
                             $params = array_merge($params, $i->context->params);
-                        }else{
-                            $stubs[]='?';
+                        }else {
+                            $stubs[] = '?';
                             $params[] = $i;
                         }
                     }
                     $stubs = implode(',', $stubs);
                     $exprs[] = "$k $op ($stubs)";
                 }
-            }else if($op == 'BETWEEN'){
+            }else if ($op == 'BETWEEN') {
                 $cond = "$k BETWEEN";
-                if(is_a($var[0], Raw::class)){
+                if (is_a($var[0], Raw::class)) {
                     $cond = "$cond ".strval($var[0]);
-                }elseif($var[0] instanceof BasicRule){
+                }elseif ($var[0] instanceof BasicRule) {
                     $cond = "$cond ({$var[0]->context->sql})";
                     $params = array_merge($params, $var[0]->context->params);
-                }else{
+                }else {
                     $cond = "$cond ?";
                     $params[] = $var[0];
                 }
-                if(is_a($var[1], Raw::class)){
+                if (is_a($var[1], Raw::class)) {
                     $cond = "$cond AND ".strval($var[1]);
-                }elseif($var[1] instanceof BasicRule){
+                }elseif ($var[1] instanceof BasicRule) {
                     $cond = "$cond AND ({$var[1]->context->sql})";
                     $params = array_merge($params, $var[1]->context->params);
-                }else{
+                }else {
                     $cond = "$cond AND ?";
                     $params[] = $var[1];
                 }
                 $exprs[] = $cond;
-            }else{
-                if(is_a($var, Raw::class)){
+            }else {
+                if (is_a($var, Raw::class)) {
                     $exprs[] = "$k $op ".strval($var);
-                }elseif($var instanceof BasicRule){
+                }elseif ($var instanceof BasicRule) {
                     $exprs[] = "$k $op {$var->context->sql}";
                     $params = array_merge($params, $var->context->params);
-                }else{
+                }else {
                     $exprs[] = "$k $op ?";
                     $params[] = $var;
                 }
@@ -433,22 +433,22 @@ 
 
         self::condition($context, $prefix, implode(' AND ', $exprs), $params);
     }
-    static public function condition(Context $context, $prefix, $expr, $args){
-        if(!empty($expr)){
+    static public function condition(Context $context, $prefix, $expr, $args) {
+        if (!empty($expr)) {
             $expr = "($expr)";
-            if($args){
+            if ($args) {
                 //因为PDO不支持绑定数组变量, 这里需要手动展开数组
                 //也就是说把 where("id IN(?)", [1,2])  展开成 where("id IN(?,?)", 1,2)
                 $cutted = null;
                 $cut = null;
                 $toReplace = array();
 
-                $newArgs=array();
+                $newArgs = array();
                 //找到所有数组对应的?符位置
-                foreach ($args as $k =>$arg){
-                    if(is_array($arg) || is_a($arg, Raw::class) || is_a($arg, BasicRule::class)){
+                foreach ($args as $k =>$arg) {
+                    if (is_array($arg) || is_a($arg, Raw::class) || is_a($arg, BasicRule::class)) {
 
-                        if(!$cutted){
+                        if (!$cutted) {
                             $cut = new NestedStringCut($expr);
                             $cutted = $cut->getText();
                         }
@@ -458,54 +458,54 @@ 
                         $pos !== false or \PhpBoot\abort(
                             new \InvalidArgumentException("unmatched params and ? @ $expr"));
 
-                        if(is_array($arg)){
+                        if (is_array($arg)) {
                             $stubs = [];
-                            foreach ($arg as $i){
-                                if(is_a($i, Raw::class)){
+                            foreach ($arg as $i) {
+                                if (is_a($i, Raw::class)) {
                                     $stubs[] = strval($i);
-                                }else{
+                                }else {
                                     $stubs[] = '?';
                                     $newArgs[] = $i;
                                 }
                             }
                             $stubs = implode(',', $stubs);
-                        }elseif($arg instanceof BasicRule){
+                        }elseif ($arg instanceof BasicRule) {
                             $stubs = "({$arg->context->sql})";
                             $newArgs = array_merge($newArgs, $arg->context->params);
-                        }else{
+                        }else {
                             $stubs = strval($arg);
                         }
                         $toReplace[] = [$pos, $stubs];
 
-                    }else{
-                        $newArgs[]=$arg;
+                    }else {
+                        $newArgs[] = $arg;
                     }
                 }
 
-                if(count($toReplace)){
+                if (count($toReplace)) {
                     $toReplace = array_reverse($toReplace);
-                    foreach ($toReplace as $i){
+                    foreach ($toReplace as $i) {
                         list($pos, $v) = $i;
-                        $expr = substr($expr, 0, $pos).$v.substr($expr, $pos+1);
+                        $expr = substr($expr, 0, $pos).$v.substr($expr, $pos + 1);
                     }
                     $args = $newArgs;
                 }
             }
-            if($prefix){
+            if ($prefix) {
                 $context->appendSql($prefix.' '.$expr);
-            }else{
+            }else {
                 $context->appendSql($expr);
             }
 
-            if($args){
+            if ($args) {
                 $context->appendParams($args);
             }
         }
     }
 }
 
-class GroupByImpl{
-    static public function groupBy(Context $context, $column){
+class GroupByImpl {
+    static public function groupBy(Context $context, $column) {
         $column = DB::wrap($column);
         $context->appendSql("GROUP BY $column");
     }
@@ -530,20 +530,20 @@ 
      * @param string|false $asDict return  as dict or array
      * @return false|array
      */
-    static public function get($context, $dictAs=false){
+    static public function get($context, $dictAs = false) {
 
         $st = $context->connection->prepare($context->sql);
-        if($st->execute($context->params)){
+        if ($st->execute($context->params)) {
             $res = $st->fetchAll(\PDO::FETCH_ASSOC);
-            if ($dictAs){
-                $dict= [];
-                foreach ($res as $i){
-                    $dict[$i[$dictAs]]=$i;
+            if ($dictAs) {
+                $dict = [];
+                foreach ($res as $i) {
+                    $dict[$i[$dictAs]] = $i;
                 }
                 return $context->handleResult($dict);
             }
             return $context->handleResult($res);
-        }else{
+        }else {
             return false;
         }
     }
@@ -552,22 +552,22 @@ 
      * @param Context $context
      * @return int|false
      */
-    static public function count($context){
+    static public function count($context) {
 
         $found = [];
-        if(!preg_match('/\bselect\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
-            count($found)==0){
+        if (!preg_match('/\bselect\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
+            count($found) == 0) {
             \PhpBoot\abort(new \PDOException("can not use count(*) without select"));
         }
         list($chars, $columnBegin) = $found[0];
-        $columnBegin = $columnBegin + strlen('select')+1;
+        $columnBegin = $columnBegin + strlen('select') + 1;
 
         $columnEnd = 0;
         $found = [];
-        if(!preg_match('/\bfrom\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
-            count($found)==0){
+        if (!preg_match('/\bfrom\b/i', $context->sql, $found, PREG_OFFSET_CAPTURE) ||
+            count($found) == 0) {
             $columnEnd = strlen($context->sql);
-        }else{
+        }else {
             list($chars, $columnEnd) = $found[0];
         }
         $sql = substr($context->sql, 0, $columnBegin);
@@ -575,10 +575,10 @@ 
         $sql .= substr($context->sql, $columnEnd);
 
         $st = $context->connection->prepare($sql);
-        if($st->execute($context->params)){
+        if ($st->execute($context->params)) {
             $res = $st->fetchAll(\PDO::FETCH_ASSOC);
             return intval($res[0]['count']);
-        }else{
+        }else {
             return false;
         }
 
@@ -586,47 +586,47 @@ 
 }
 class OnDuplicateKeyUpdateImpl
 {
-    public function set($context, $column, $value){
-        if(is_string($column)){
+    public function set($context, $column, $value) {
+        if (is_string($column)) {
             $this->setExpr($context, $column, $value);
-        }else{
+        }else {
             $this->setArgs($context, $column);
         }
     }
 
-    public function setExpr($context, $expr, $args){
+    public function setExpr($context, $expr, $args) {
         $prefix = '';
-        if($this->first){
+        if ($this->first) {
             $this->first = false;
             $prefix = 'ON DUPLICATE KEY UPDATE ';
-        }else{
+        }else {
             $prefix = ',';
         }
 
-        $context->appendSql("$prefix$expr",$prefix == 'ON DUPLICATE KEY UPDATE ');
+        $context->appendSql("$prefix$expr", $prefix == 'ON DUPLICATE KEY UPDATE ');
         $context->appendParams($args);
 
     }
-    public function setArgs($context, $values){
+    public function setArgs($context, $values) {
         $set = [];
         $params = [];
-        foreach ($values as $k=>$v){
+        foreach ($values as $k=>$v) {
             $k = DB::wrap($k);
-            if(is_a($v, Raw::class)){//直接拼接sql，不需要转义
-                $set[]= "$k=".$v->get();
-            }else{
-                $set[]= "$k=?";
-                $params[]=$v;
+            if (is_a($v, Raw::class)) {//直接拼接sql，不需要转义
+                $set[] = "$k=".$v->get();
+            }else {
+                $set[] = "$k=?";
+                $params[] = $v;
             }
         }
-        if($this->first){
+        if ($this->first) {
             $this->first = false;
             $context->appendSql('ON DUPLICATE KEY UPDATE '.implode(',', $set));
             $context->appendParams($params);
-        }else{
-            $context->appendSql(','.implode(',', $set),false);
+        }else {
+            $context->appendSql(','.implode(',', $set), false);
             $context->appendParams($params);
         }
     }
-    private $first=true;
+    private $first = true;
 }