本文实例讲述了[php]封装的数据库模型Model类。仅供参考： ~~~ <?php //引入配置文件 include "../config.php"; class Model extends PDO { protected $tableName = "";//存储表名 protected $sql = "";//存储最后执行的SQL语句 protected $limit = "";//存储limit条件 protected $order = "";//存储order排序条件 protected $field = "*";//存储要查询的字段 protected $where = "";//存储where条件 protected $allFields = [];//存储当前表的所有字段 /** * 构造方法 初始化 * @param string $tableName 要操作的表名 */ public function __construct($tableName) { //连接数据库 parent::__construct('mysql:host='.HOST.';dbname='.DB.';charset=utf8;port='.PORT,USER,PWD); //存储表名 $this->tableName = PRE.$tableName; //获取当前数据表中有哪些字段 $this->getFields(); } /** * 获取当前表的所有字段 * @return array 成功则返回一维数组字段 */ public function getFields() { //查看当前表结构 $sql = "desc {$this->tableName}"; $res = $this->query($sql);//返回pdo对象 //var_dump($res); if ($res) { $arr = $res->fetchAll(2); //var_dump($arr); //从二维数组中取出指定下标的列 $this->allFields = array_column($arr,"Field"); return $this->allFields; } else { die("表名错误"); } } /** * 添加操作 * @param array $data 要添加的数组 * @return int 返回受影响行数 */ 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}')"; $this->sql = $sql; //执行并发送SQL，返回受影响行数 return (int)$this->exec($sql); } /** * 删除操作 * @param string $id 要删除的id * @return int 返回受影响行数 */ public function delete($id="") { //判断id是否存在 if (empty($id)) { $where = $this->where; }else{ $where = "where id={$id}"; } $sql = "delete from {$this->tableName} {$where}"; $this->sql = $sql; //执行并发送SQL,返回受影响行数 return (int)$this->exec($sql); } /** * 修改操作 * @param array $data 要修改的数组 * @return int 返回受影响行数 */ public function update($data) { //判断是否是数组 if (!is_array($data)){ return $this; } //判断是否全是非法字段 if (empty($data)) { die('全是非法字段'); } $str = ""; //过滤非法字段 foreach ($data as $k=>$v) { //字段为id时，判断id是否存在的 if ($k == "id"){ $this->where = "where id={$v}"; unset($data[$k]); continue; } //若字段不为id，则过滤后再拼接成set字段 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}"; //echo $sql; $this->sql = $sql; return (int)$this->exec($sql); } /** * 查询多条数据 * @return array 成功返回二维数组，失败返回空数组 */ public function select() { $sql = "select {$this->field} from {$this->tableName} {$this->where} {$this->order} {$this->limit}"; $this->sql = $sql; //执行SQL,结果集是一个对象 $res = $this->query($sql); //判断是否查询成功, if ($res){ //成功返回二维数组 return $res->fetchAll(2); } //失败返回空数组 return []; } /** * 查询一条数组 * @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} {$this->order} limit 1"; $this->sql = $sql; //执行sql,结果集为对象 $res = $this->query($sql); //判断是否查询成功 if ($res){ //成功则返回一条数据(一维数组) $result = $res->fetchAll(2); return $result[0]; } //失败返回空数组 return []; } /** * 统计总数目 * @return int 返回总数 */ public function count() { $sql = "select count(*) as total from {$this->tableName} {$this->where} limit 1"; $this->sql = $sql; //执行SQL,结果集为对象 $res = $this->query($sql); //处理结果集 if ($res){ $result = $res->fetchAll(2); //var_dump($result); return $result[0]["total"]; } return 0; } /** * 设置要查询的字段信息 * @param string $field 要查询的字段 * @return object 返回自己，保证连贯操作 */ public function field($field) { //判断字段是否存在 if (empty($filed)){ return $this; } $this->field = $field; return $this; } /** * 获取最后执行的sql语句 * @return string sql语句 */ public function _sql() { return $this->sql; } /** * where条件 * @param string $where 要输入的where条件 * @return object 返回自己，保证连贯操作 */ public function where($where) { $this->where = "where ".$where; return $this; } /** * order条件 * @param string $order 要输入的order条件 * @return object 返回自己，保证连贯操作 */ public function order($order) { $this->order = "order by ".$order; return $this; } /** * limit条件 * @param string $limit 要输入的limit条件 * @return object 返回自己，保证连贯操作 */ public function limit($limit) { $this->limit = "limit ".$limit; return $this; } } ~~~