巅云智能建站平台搭建版(创业门户版)火爆上线,终身授权!新增:文章智能采集+全站真静态打包+城市分站+智能小程序+非法词过滤+H5自适应+智能链词等功能功能详情
建站专提News

PHP基于ORM方式操作MySQL数据库实例

一佰互联网站开发设计(www.yinxi.net) 发布日期 2019-04-26 09:01:53 浏览数: 100

本文实例讲述了PHP基于ORM方式操作MySQL数据库。分享给大家供大家参考,具体如下:

ORM----Oriented Relationship Mapper,即用面向对象的方式来操作数据库。归根结底,还是对于SQL语句的封装。

首先,我们的数据库有如下一张表:

我们希望能够对这张表,利用setUserid("11111"),即可以设置userid;getUserid()既可以获得对象的userid。所以,我们需要建立model对象,与数据库中的表对应。

由于每张表所对应的model都应该是有set/get操作,所以,我们用一个父类BasicModel进行定义。其他model都是继承至这个model。

BasicModel的代码如下:

<?php  /*   * author:Tammy Pi   * function:Model类的基类,封装set/get操作   */  class BasicModel{    private $map = null;    function TbUser() {      $this->map = array();    }    function __set($key,$value){      $this->map[$key] = $value;    }    function __get($key){      return $this->map[$key];    }    function __call($name,$arguments) {      if(substr($name,0,3)=="set"){        $this->__set(strtolower(substr($name,3)),$arguments[0]);      }else{        return $this->__get(strtolower(substr($name,3)));      }    }  }?>

那么,与tb_user表相互对应的model类TbUser则对它进行继承。

<?php  require_once("BasicModel.php");  class TbUser extends BasicModel{  }?>

这样,我们就可以对TbUser的实例进行set/get操作了。

要用ORM进行操作数据库,就必须可以findByWhere($where)进行查询,返回的为对象数组;save($tbUser)进行保存;delete($obj)进行删除;update($obj)进行更新操作。

本质上,就是用户传入的是对象,我们再利用代码将对象转换为SQL语句。本质上,执行的还是SQL语句。

所以,我们对一系列的操作用接口表示。IBasicDAO的代码如下:

<?php  interface IBasicDAO {    public function findByWhere($where);    public function findWhereOrderBy($where,$order,$start=null,$limit=null);    public function save($obj);    public function delete($obj);    public function update($obj);  }?>

我们最关键,就是对此接口进行实现。完成对象和SQL的转换。BasicDAO的代码如下:

<?php  require_once("IBasicDAO.php");  class BasicDAO implements IBasicDAO{    protected $modelName = null;    private $tableName = null;    private $h = "localhost";    private $user = "root";    private $pass = "root";    private $db = "db_toilet";    //获得连接    public function getConnection(){      $conn = mysqli_connect($this->h,$this->user,$this->pass,$this->db);      return $conn;    }    //初始化    public function init() {      //根据model的名字得到表的名字      $this->tableName = strtolower(substr($this->modelName,0,2))."_".strtolower(substr($this->modelName,2));    }    //获得一个表的列名    public function getColumn($tableName) {      $sql = "show columns from ".$tableName;      $conn = $this->getConnection();      $columns = array();      if($conn!=null){        $rtn = mysqli_query($conn,$sql);        while($rtn!==false&&($row=mysqli_fetch_array($rtn))!=null){          $columns[] = $row[0];        }        mysqli_close($conn);      }      return $columns;    }    //条件查询    public function findByWhere($where){      //获得数据表的列名      $columns = $this->getColumn($this->tableName);      //拼接sql语句      $sql = "select * from ".$this->tableName." where ".$where;      $conn = $this->getConnection();      $arr = array();      if($conn!=null){        $rtn = mysqli_query($conn,$sql);        while($rtn!==false&&($row=mysqli_fetch_array($rtn))!=null){          $index = -1;          $obj = new $this->modelName();          foreach($columns as $column){            $obj->{"set".ucfirst($column)}($row[++$index]);          }          $arr[] = $obj;        }        mysqli_close($conn);      }      return $arr;    }    //分页查询;支持排序    public function findWhereOrderBy($where,$order,$start=null,$limit=null){      //获得数据表的列名      $columns = $this->getColumn($this->tableName);      //拼接sql语句      $sql = "select * from ".$this->tableName." where ".$where." order by ".$order;      if($start!=null&&$limit!=null){        $sql .= "limit ".$start.",".$limit;      }      $conn = $this->getConnection();      $arr = array();      if($conn!=null){        $rtn = mysqli_query($conn,$sql);        while($rtn!==false&&($row=mysqli_fetch_array($rtn))!=null){          $index = -1;          $obj = new $this->modelName();          foreach($columns as $column){            $obj->{"set".ucfirst($column)}($row[++$index]);          }          $arr[] = $obj;        }        mysqli_close($conn);      }      return $arr;    }    //保存操作    public function save($obj){      $columns = $this->getColumn($this->tableName);      $conn = $this->getConnection();      $tag = false;      if($conn!=null){        $sql = "insert into ".$this->tableName."(";        foreach($columns as $column){          $sql .= $column.",";        }        $sql = substr($sql,0,strlen($sql)-1).") values(";        foreach($columns as $column){          $value = $obj->{"get".ucfirst($column)}();          //判断$value的类型          if($value==null){            $sql .= "null,";          }else if(preg_match("/^[0-9]*$/", $value)){            //是数字            $sql .= $value.",";          }else{            $sql .= """.$value."",";          }        }        $sql = substr($sql,0,strlen($sql)-1);        $sql .= ")";        //执行sql语句        mysqli_query($conn,$sql);        $tag = true;        mysqli_close($conn);      }      return $tag;    }    //删除操作    public function delete($obj){      $conn = $this->getConnection();      $tag = false;      if($conn!=null){        $sql = "delete from ".$this->tableName." where ";        $columns = $this->getColumn($this->tableName);        $value = $obj->{"get".ucfirst($columns[0])}();        if($value!=null){          //是数字          if(preg_match("/^[0-9]*$/", $value)){            $sql .= $columns[0]."=".$value;          }else{            $sql .= $columns[0]."="".$value.""";          }          //执行          mysqli_query($conn,$sql);          $tag = true;        }        mysqli_close($conn);      }      return $tag;    }    //更新操作    public function update($obj){      $conn = $this->getConnection();      $columns = $this->getColumn($this->tableName);      $tag = false;      if($conn!=null){        $sql = "update ".$this->tableName." set ";        for($i=1;$i<count($columns);$i++){          $column = $columns[$i];          $value = $obj->{"get".ucfirst($columns[$i])}();          if($value==null){            $sql .= $column."=null,";          }else if(preg_match("/^[0-9]*$/",$value)){            $sql .= $column."=".$value.",";          }else{            $sql .= $column."="".$value."",";          }        }        $sql = substr($sql,0,strlen($sql)-1);        $sql .= " where ";        $tempColumn = $columns[0];        $tempValue = $obj->{"get".ucfirst($columns[0])}();        if(preg_match("/^[0-9]*$/", $tempValue)){          $sql .= $tempColumn."=".$tempValue;        }else{          $sql .= $tempColumn."="".$tempValue.""";        }        //执行操作        mysqli_query($conn,$sql);        $tag = true;        mysqli_close($conn);      }      return $tag;    }  }?>

那么,对tb_user表进行操作时,主要利用的是TbUserDAO,它将modelName设置为"TbUser",代码就得知操作的表为tb_user,然后就可以进行一系列操作了。

<?php  require_once("BasicDAO.php");  require_once("../model/TbUser.php");  class TbUserDAO extends BasicDAO{    function TbUserDAO(){      $this->modelName = "TbUser";      parent::init();    }  }?>

那么,就可以采用面向对象的方式对数据库进行操作了。如:

$tbUserDAO = new TbUserDAO();$tbUser = new TbUser();$tbUser->setUserid("fetchingsoft@163.com");$tbUser->setUsername("fetching");$tbUserDAO->update($tbUser);echo "执行成功!";print_r($list);

这样对数据库中的记录进行更新。

更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP基于pdo操作数据库技巧总结》、《php+Oracle数据库程序设计技巧总结》、《PHP+MongoDB数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。

一佰互联是全国知名建站品牌服务商,我们有九年网站建设、网站制作、网页设计、php开发和域名注册及虚拟主机服务经验,提供的自助建站服务更是全国有名。近年来还整合团队优势自主开发了可视化多用户”巅云建站系统“3.0平台版,拖拽排版网站制作设计,轻松实现pc站、手机微网站、小程序、APP一体化全网营销网站建设 ,已成功的为全国上百家网络公司提供自助建站平台搭建服务。

相关新闻more

27
04月
PHP统计目录中文件以及目录中目录大小的方法

本文实例讲述了PHP统计目录中文件以及目录中目录大小的方法。分享给大家供大家参考,具体如下:<?php //循环遍历目录中所有... >>详情

26
04月
PHP实现二维数组根据key进行排序的方法

本文实例讲述了PHP实现二维数组根据key进行排序的方法。分享给大家供大家参考,具体如下:在PHP中内置了很多对数组进行处理的函数,有很多时... >>详情

17
05月
网站的标题是最能体现SEO优化排名的地方_巅

网站的问题是最能浮现SEO优化排名的处所,一个问题的优劣可以或许直接影响网站的排名,以是在网站建树筹备投入行使可能打算举办SEO优化的时辰,... >>详情

01
05月
php表单提交程序的安全使用方法第1/2页

用于显示错误信息和成功信息,其实也可以直接echo出错误信息,这里我只是想我的出错信息页面漂亮点,定义了一个页面输出的函数罢了。 复制代码 ... >>详情

高端网站建设

美工兼顾SEO,为企业电子商务营销助力!

电话:

023-85725751
建站

产品

域名注册 虚拟主机 云服务器 企业邮局
智能建站 APP打包 微站/小程序 创业平台
网站推广 媒体营销 智能采集 AI机器人
400电话 短信营销 店销机器人
私人定制 门户网站