caoym / phpboot

src/DB/impls.php

Doc Comments +81 added lines, -1 removed lines

@@ -8,6 +8,11 @@ 
 use PhpBoot\DB\Context;
 
 class ExecResult{
+
+    /**
+     * @param \PDO $pdo
+     * @param \PDOStatement $st
+     */
     public function __construct($success, $pdo, $st){
         $this->pdo = $pdo;
         $this->st = $st;
@@ -41,6 +46,10 @@ 
 
 class SelectImpl
 {
+    /**
+     * @param Context $context
+     * @param string $columns
+     */
     static  public function select($context, $columns){
         $context->appendSql("SELECT $columns");
     }
@@ -48,6 +57,10 @@ 
 
 class FromImpl
 {
+    /**
+     * @param Context $context
+     * @param string $tables
+     */
     static public function from($context, $tables,$as=null){
         if($tables instanceof BasicRule){
             $context->appendSql("FROM (".$tables->context->sql.')');
@@ -63,6 +76,10 @@ 
 
 class DeleteImpl
 {
+    /**
+     * @param Context $context
+     * @param string $from
+     */
     static public function deleteFrom($context, $from)
     {
         $context->appendSql("DELETE FROM ".DB::wrap($from));
@@ -71,6 +88,11 @@ 
 
 class JoinImpl
 {
+    /**
+     * @param Context $context
+     * @param null|string $type
+     * @param string $table
+     */
     static public function join($context, $type, $table) {
         $table = DB::wrap($table);
         if($type){
@@ -83,6 +105,10 @@ 
 
 class JoinOnImpl
 {
+    /**
+     * @param Context $context
+     * @param string $condition
+     */
     static public function on($context, $condition) {
         $context->appendSql("ON $condition");
     }
@@ -90,6 +116,9 @@ 
 
 class ForUpdateImpl
 {
+    /**
+     * @param Context $context
+     */
     static public function forUpdate($context){
         $context->appendSql("FOR UPDATE");
     }
@@ -97,6 +126,10 @@ 
 
 class ForUpdateOfImpl
 {
+    /**
+     * @param Context $context
+     * @param string $column
+     */
     static public function of($context, $column){
         $column = DB::wrap($column);
         $context->appendSql("OF $column");
@@ -105,6 +138,10 @@ 
 
 class InsertImpl
 {
+    /**
+     * @param Context $context
+     * @param string $table
+     */
     static public function insertInto($context, $table) {
         $table = DB::wrap($table);
         $context->appendSql("INSERT INTO $table");
@@ -112,6 +149,10 @@ 
 }
 class ReplaceImpl
 {
+    /**
+     * @param Context $context
+     * @param string $table
+     */
     static public function replaceInto($context, $table) {
         $table = DB::wrap($table);
         $context->appendSql("REPLACE INTO $table");
@@ -195,6 +236,10 @@ 
 
 class UpdateImpl
 {
+    /**
+     * @param Context $context
+     * @param string $table
+     */
     static public function update($context, $table){
         $table = DB::wrap($table);
         $context->appendSql("UPDATE $table");
@@ -211,6 +256,9 @@ 
         }
     }
 
+    /**
+     * @param string $expr
+     */
     public function setExpr(Context $context, $expr, $args){
         if($this->first){
             $this->first = false;
@@ -273,6 +321,11 @@ 
         }
         return $this;
     }
+
+    /**
+     * @param string $column
+     * @param string $order
+     */
     public function orderBy(Context $context, $column, $order=null){
         if(is_string($column)){
             if($order === null){
@@ -290,12 +343,20 @@ 
 
 class LimitImpl
 {
+    /**
+     * @param integer $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");
     }
+
+    /**
+     * @param integer $start
+     * @param integer $size
+     */
     static public function limitWithOffset(Context $context, $start, $size){
         $intStart = intval($start);
         $intSize = intval($size);
@@ -307,6 +368,9 @@ 
 
 class WhereImpl{
 
+    /**
+     * @param string $str
+     */
     static private function findQ($str,$offset = 0,$no=0){
         $found = strpos($str, '?', $offset);
         if($no == 0 || $found === false){
@@ -315,6 +379,9 @@ 
         return self::findQ($str, $found+1, $no-1);
     }
 
+    /**
+     * @param string $prefix
+     */
     static public function where(Context $context, $prefix, $expr, $args){
         if(empty($expr)){
             return;
@@ -433,6 +500,10 @@ 
 
         self::condition($context, $prefix, implode(' AND ', $exprs), $params);
     }
+
+    /**
+     * @param string $expr
+     */
     static public function condition(Context $context, $prefix, $expr, $args){
         if(!empty($expr)){
             $expr = "($expr)";
@@ -505,6 +576,10 @@ 
 }
 
 class GroupByImpl{
+
+    /**
+     * @param string $column
+     */
     static public function groupBy(Context $context, $column){
         $column = DB::wrap($column);
         $context->appendSql("GROUP BY $column");
@@ -527,7 +602,6 @@ 
     /**
      *
      * @param Context $context
-     * @param string|false $asDict return  as dict or array
      * @return false|array
      */
     static public function get($context, $dictAs=false){
@@ -586,6 +660,9 @@ 
 }
 class OnDuplicateKeyUpdateImpl
 {
+    /**
+     * @param Context $context
+     */
     public function set($context, $column, $value){
         if(is_string($column)){
             $this->setExpr($context, $column, $value);
@@ -594,6 +671,9 @@ 
         }
     }
 
+    /**
+     * @param string $expr
+     */
     public function setExpr($context, $expr, $args){
         $prefix = '';
         if($this->first){