<?php  //引入配置文件  include "./config.php";  class Model  {    public $link;//存儲連接對象    public $tableName = "";//存儲表名    public $field = "*";//存儲字段    public $allFields = [];//存儲當前表所有字段    public $where = "";//存儲where條件    public $order = "";//存儲order條件    public $limit = "";//存儲limit條件    /**     * 構造方法 初始化     * @param string $tableName 要操作的表名     */    public function __construct($tableName)    {      //1.存儲操作的表名      $this->tableName = PRE.$tableName;      //2.初始化連接數據庫      $this->getConnect();      //3.獲得當前表的所有字段      $this->getFields();    }    /**     * 初始化連接數據庫操作     */    public function getConnect()    {      //1.連接數據庫      $this->link = mysqli_connect(HOST,USER,PWD,DB,PORT);      //2.判斷連接      if (mysqli_connect_errno($this->link)>0){        echo mysqli_connect_error($this->link);        exit;      }    }    /**     * 執行并發送SQL(查詢)     * @param string $sql 要查詢的SQL語句     * @return array 返回查詢出來的二維數組     */    public function query($sql)    {      $result = mysqli_query($this->link,$sql);      if ($result && mysqli_num_rows($result)>0) {       $arr = [];       while($row = mysqli_fetch_assoc($result)){          $arr[] = $row;       }      }    return $arr;    }    /**     * 獲取當前表的所有字段     */    public function getFields()    {      //查看表結構      $sql = "desc {$this->tableName}";      //執行并發送SQL      $result = $this->query($sql);      $fields = [];      foreach ($result as $k => $v){        $fields[] = $v['Field'];      }      $this->allFields = $fields;    }    /**     * 執行并發送SQL語句(增刪改)     * @param string $sql 要執行的SQL語句     * @return bool|int|string 添加成功則返回上一次操作id,刪除修改操作則返回true,失敗則返回false     */    public function exec($sql)    {      $result = mysqli_query($this->link,$sql);      //處理結果集      if ($result && mysqli_affected_rows($this->link)>0){        //判斷是否為添加操作，是則返回上一次執行的id        if (mysqli_insert_id($this->link)){          return mysqli_insert_id($this->link);        }        //刪除修改操作成功則返回true        return true;      }else{        //未執行成功則返回false        return false;      }    }    /**     * 查詢多條數據     */    public function select()    {      $sql = "select {$this->field} from {$this->tableName} {$this->where} {$this->order} {$this->limit}";      //執行并發送SQL      return $this->query($sql);    }    /**     * 查詢一條數據     * @param string $id 要查詢的id     * @return array 返回一條數據     */    public function find($id="")    {      //判斷id是否存在      if (empty($id)){        $where = $this->where;      }else{        $where = "where id={$id}";      }      $sql = "select {$this->field} from {$this->tableName} {$where} limit 1";      //執行并發送sql      $result = $this->query($sql);      //返回一條數據      return $result[0];    }    /**     * 設置要查詢的字段信息     * @param string $field 要查詢的字段     * @return object 返回自己，保證連貫操作     */    public function field($field)    {      //判斷字段是否存在      if (empty($field)){        return $this;      }      $this->field = $field;      return $this;    }    /**     * 統計總條數     * @return int 返回總數     */    public function count()    {      //準備SQL語句      $sql = "select count(*) as total from {$this->tableName} limit 1";      $result = $this->query($sql);      //返回總數      return $result[0]['total'];    }    /**     * 添加操作     * @param array $data 要添加的數組     * @return bool|int|string 添加成功則返回上一次操作的id,失敗則返回false     */    public function add($data){      //判斷是否是數組      if (!is_array($data)){        return $this;      }      //判斷是否全是非法字段      if (empty($data)){        die("非法數據");      }      //過濾非法字段      foreach ($data as $k => $v){        if (!in_array($k,$this->allFields)){          unset($data[$k]);        }      }      //將數組中的鍵取出      $keys = array_keys($data);      //將數組中取出的鍵轉為字符串拼接      $key = implode(",",$keys);      //將數組中的值轉化為字符串拼接      $value = implode("','",$data);      //準備SQL語句      $sql = "insert into {$this->tableName} ({$key}) values('{$value}')";      //執行并發送SQL      return $this->exec($sql);    }    /**     * 刪除操作     * @param string $id 要刪除的id     * @return bool 刪除成功則返回true,失敗則返回false     */    public function delete($id="")    {      //判斷id是否存在      if (empty($id)){        $where = $this->where;      }else{        $where = "where id={$id}";      }      $sql = "delete from {$this->tableName} {$where}";      echo $sql;      //執行并發送      return $this->exec($sql);    }    /**     * 修改操作     * @param array $data 要修改的數組     * @return bool 修改成功返回true，失敗返回false     */    public function update($data){      //判斷是否是數組      if (!is_array($data)){        return $this;      }      //判斷是否是全是非法字段      if(empty($data)){        die("非法數據");      }      $str = "";      //過濾非法字段      foreach ($data as $k => $v){        if ($k == "id"){          $where = "where id={$v}";          unset($data[$k]);        }        if (in_array($k,$this->allFields)){          $str .= "{$k}='{$v}',";        }else{          unset($data[$k]);        }      }      //判斷是否有條件      if (empty($this->where)){        die("請輸入條件");      }      //去掉最右側的逗號      $str = rtrim($str,",");      $sql = "update {$this->tableName} set {$str} {$this->where}";      return $this->exec($sql);    }    /**     * where條件     * @param string $where 輸入的where條件     * @return $this 返回自己，保證連貫操作     */    public function where($where)    {      $this->where = "where ".$where;      return $this;    }    /**     * order排序條件     * @param string $order 以此為基準進行排序     * @return $this 返回自己，保證連貫操作     */    public function order($order)    {      $this->order = "order by ".$order;      return $this;    }    /**     * limit條件     * @param string $limit 輸入的limit條件     * @return $this 返回自己，保證連貫操作     */    public function limit($limit)    {      $this->limit = "limit ".$limit;      return $this;    }    /**     * 析構方法     * 關閉數據庫連接     */    public function __destruct()    {      mysqli_close($this->link);    }  } //自行調試 $a = new Model("表名"); // var_dump($a->find(3)); // var_dump($a->select());  // var_dump($a->count());  // $res = $a->select();  //var_dump($res);?>