ci公共模型類

咱們都知道，操做數據庫的方法都寫在模型中。可是通常狀況下，一張表每每至少對應4個操做，也就是所謂crud。那麼若是20張表，所對應的模型方法，就達到了80個，重複的操做顯然這已是一個體力活兒。

那麼就對單表操做時，咱們進行一下簡單的封裝。以下是ci框架的示例：

<?php
/**
 * Created by PhpStorm.
 * User: kangjianrong
 * Date: 16-8-26
 * Time: 上午10:29
 */

class My_model extends CI_Model {
    //數據庫
    public $errors = array();
    const dataBase = 'qndnew';
    
    public function __construct()
    {
        // Call the CI_Model constructor
        parent::__construct();
    }
    /**
     * 查詢分頁數據（使用於簡單的單表操做）
     * @param string $model 模型          例如：User_model
     * @param string $table 表名
     * @param string $select_fields 要顯示字段
     * @param array  $param 查詢條件：
     *     compare（比較）:
     *         array($key => $val) $key爲要操做的字段，$val爲要操做的值
     *         array('name !=' => $name, 'id <' => $id, 'date >' => $date);
     *     like(模糊查詢)
     *         array('title' => $match, 'page1' => $match, 'page2' => $match)
     *     customStr（自定義字符串）:
     *         "name='Joe' AND status='boss' OR status='active'"
     *     in:
     *         array('userName' => array('Frank', 'Todd', 'James'))
     * @param string $page  當前頁數（查詢所有數據時，設置爲空）
     * @param string $limit 查詢條數（查詢所有數據時，設置爲空）
     * @param array $order  排序條件：   
     *     array($key => $val)
     *     $key爲排序依據的字段，
     *     $val爲排序的方式【asc (升序，默認)或 desc(降序), 或 random(隨機)】   
     * @$isReturnCount  boole       是否返回總條數                          
     * @return array|boolean
     * 
     */
    public function pageData($model, $table, $param = array(),$select_fields = '', $page = '1', $limit = '15', $order = array(),$isReturnCount = true){
        if(empty($model) || empty($table)){
            return false;
        }
        $this -> load -> model($model);
        
        $table = $this->db->dbprefix.$table;
        //處理查詢字段
        if(!empty($select_fields)){
            $this->db->select($select_fields)->from($table);
        }elseif(isset($this -> $model -> selectFields)){
            $this->db->select($this -> $model -> selectFields)->from($table);
        }else{
            $this->db->select('*')->from($table);
        }
        //處理查詢條件
        if (is_array($param) && count($param) > 0){
            $this -> parseParam($param);
        } 
        //統計總數
        if($isReturnCount){
            $rs['count']    = $this->db->count_all_results('',false);//不重置查詢構造器
            array_push($this -> errors,$this->db->last_query());
        }
        //分頁數據處理
        if(isset($page) && isset($param['limit'])){
            //分頁邊界值 設置
            $offset = $param['page'] <= 1 ? 0 : ($param['page']-1) * $param['limit'];
            $this->db->limit($param['limit'], $offset);
        }
    
        //排序規則的組合
        if (!empty($order) && is_array($order))
        {
            foreach ($order as $key => $val)
            {
                $this->db->order_by($key, $val);
            }
        }else{ 
            //默認按照此表的主鍵倒序
            $primary = $this->getPrimary();
            if(!empty($primary))
            {
                $this->db->order_by($primary, 'DESC');
            }
        }
        $query = $this->db->get();  
        array_push($this -> errors,$this->db->last_query());
        $rs['list'] = $query->result_array();
        return $rs;
        
    }
    /**
     * 解析參數
     */
    private function parseParam($param){
        if(isset($param['compare'])){
            foreach ($param['compare'] as $key => $val){
                if (!empty($val)) $this->db->where($key, $val);
            }
        }
        if(isset($param['like'])){
            foreach ($param['like'] as $key => $val){
                if (!empty($val)) $this->db->like($key, $val);
            }
        }
        if(isset($param['in'])){
            foreach ($param['in'] as $key => $val){
                if (!empty($val)) $this->db->where_in($key, $val);
            }
        }
        if(isset($param['customStr'])){
            if (!empty($val)) $this->db->where($param['customStr']);
        }
    }
    /**
     * 新增信息
     * @param string $table  表名稱
     * @param array  $param  數據變量
     * @return INT ID 
     */
    public function add($table = '', $param = array())
    {
        if(empty($table) || !is_array($param) || empty ($param)){
            return FALSE;
        }
        
        //寫入數據表        
        $this->db->insert($table, $param);
           array_push($this -> errors,$this->db->last_query());
        //返回記錄ID
        return $this->db->insert_id();
    }

   /**
     * 更新分類信息
     * @param string    $table      表名稱
     * @param string    $primary    表主鍵
     * @param int       $id         分類ID
     * @param array     $param      更新的數據
     * @return type 
     */
    public function update($table = '', $primary = '', $id = 0, $param = array())
    {
        if(empty($table) || empty($primary) || empty($param) || empty($id))
        {
            return FALSE;
        }

        $id = (int)$id;
        $this->db->where($primary, $id)
                 ->limit(1)
                 ->update($table, $param);  
        array_push($this -> errors,$this->db->last_query());      
        return $this->db->affected_rows();        
    }   
  
   /**
     * 刪除指定ID記錄
     * @param string    $table      表名稱
     * @param string    $primary    表主鍵
     * @param array     $id         分類ID
     * @return int
     */
    public function delete($table = '', $primary = '', $id = array()){             
       if(empty($table) || empty($primary) || empty($id)){
            return FALSE;
       }
       $this->db->where_in($primary, $id)
                ->delete($table);
       array_push($this -> errors,$this->db->last_query());
       return $this->db->affected_rows();      
    }
    
    /**
     * 獲取表的主鍵
     * @param string    $database   數據庫名稱
     * @param strting   $table      表名稱
     */
    public  function getPrimary($table = '', $database = self::dataBase)
    {
        if(empty($database) || empty($table))
        {
            return FALSE;
        }
        $sql = "SELECT k.column_name
                FROM information_schema.table_constraints t
                JOIN information_schema.key_column_usage k
                USING (constraint_name,table_schema,table_name)
                WHERE t.constraint_type='PRIMARY KEY'
                  AND t.table_schema='qndnew'
                  AND t.table_name='qnd_user'";
        $query = $this->db->query($sql)->result_array();
        return isset($query[0]['column_name']) ? $query[0]['column_name'] : false;
    }
    /**
     * debug sql語句
     */
    public function debugSql(){
        if(count($this->errors) > 0){
            foreach($this->errors as $val){
                echo $val.'<br>';
            }
        }
    }
}

具體的業務邏輯模型以下：

class User_model extends My_model {

    const USER = 'qnd_user';
    public $selectFields = array(
        'id',
        'guid',
        'phone',
        'userName',
        'password',
        'headPortraits',
        'nickName',
        'createTime',
    );
    const SMS_ROLE = 'qnd_role';
    public function __construct()
    {
       
    }
}

控制器中測試以下：

public function modelTest(){
        $this -> load -> model('User_model'); // 載入 model
        $whereArr = array(
                        'compare'=>array(
                            'userName' => 'Frank',
                        ),
                        
                        
                    );
        $rs = $this -> User_model -> pageData('User_model','user',$whereArr);
        print_r($rs);
        $this -> User_model -> debugSql();
    }