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

本文实例讲述了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  # ORM  # 操作  # MySQL  # 数据库  # Php连接及读取和写入mysql数据库的常用代码  # PHP连接和操作MySQL数据库基础教程  # php mysql数据库操作类  # PHP备份/还原MySQL数据库的代码  # php实现mysql数据库备份类  # 常用的PHP数据库操作方法（MYSQL版）  # php连接mysql数据库代码  # PHP实现PDO的mysql数据库操作类  # php实现MySQL数据库备份与还原类实例  # 一款简单实用的php操作mysql数据库类  # PHP数据库操作之基于Mysqli的数据库操作类库  # 全新的PDO数据库操作类php版（仅适用Mysql）  # 作了  # 的是  # 程序设计  # 面向对象  # 数据库中  # 本质上  # 就可以  # 都是  # 操作技巧  # 相关内容  # 是有  # 感兴趣  # 这张  # 给大家  # 要用  # 分页  # 就可  # 既可  # 设置为  # 更多关于 

相关文章： 小程序网站制作需要准备什么资料,如何制作小程序？  如何选择建站程序？包含哪些必备功能与类型？  制作国外网站的软件,国外有哪些比较优质的网站推荐？  如何通过.red域名打造高辨识度品牌网站？  如何通过VPS搭建网站快速盈利？  免费制作统计图的网站有哪些,如何看待现如今年轻人买房难的情况？  如何在阿里云ECS服务器部署织梦CMS网站？  开源网站制作软件,开源网站什么意思？  济南网站制作的价格,历城一职专官方网站？  ,南京靠谱的征婚网站？  专业网站设计制作公司,如何制作一个企业网站，建设网站的基本步骤有哪些？  javascript中对象的定义、使用以及对象和原型链操作小结  如何自定义建站之星网站的导航菜单样式？  如何快速上传建站程序避免常见错误？  如何在阿里云高效完成企业建站全流程？  如何选择可靠的免备案建站服务器？  如何用VPS主机快速搭建个人网站？  想学网站制作怎么学,建立一个网站要花费多少？  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱？  云南网站制作公司有哪些,云南最好的招聘网站是哪个？  建站之星如何一键生成手机站？  如何在阿里云购买域名并搭建网站？  番禺网站制作公司哪家值得合作,番禺图书馆新馆开放了吗？  如何快速搭建FTP站点实现文件共享？  GML (Geography Markup Language)是什么，它如何用XML来表示地理空间信息？  如何在Windows虚拟主机上快速搭建网站？  建站之星如何取消后台验证码生成？  武汉网站如何制作,黄黄高铁武穴北站途经哪些村庄？  网站制作知乎推荐,想做自己的网站用什么工具比较好？  如何在万网自助建站平台快速创建网站？  三星网站视频制作教程下载,三星w23网页如何全屏？  零基础网站服务器架设实战：轻量应用与域名解析配置指南  TestNG的testng.xml配置文件怎么写  建站之星安装失败：服务器环境不兼容？  岳西云建站教程与模板下载_一站式快速建站系统操作指南  制作网站哪家好,cc、.co、.cm哪个域名更适合做网站？  建站之星2.7模板快速切换与批量管理功能操作指南  h5在线制作网站电脑版下载,h5网页制作软件？  家庭建站与云服务器建站，如何选择更优？  建站之家VIP精选网站模板与SEO优化教程整合指南  如何通过智能用户系统一键生成高效建站方案？  C++ static_cast和dynamic_cast区别_C++静态转换与动态类型安全转换  建站之星如何快速更换网站模板？  如何在搬瓦工VPS快速搭建网站？  如何选择高效便捷的WAP商城建站系统？  制作网站的软件下载免费,今日头条开宝箱老是需要下载怎么回事？  网站制作的软件有哪些,制作微信公众号除了秀米还有哪些比较好用的平台？  教学网站制作软件,学习*后期制作的网站有哪些？  如何自己制作一个网站链接,如何制作一个企业网站，建设网站的基本步骤有哪些？  北京建设网站制作公司,北京古代建筑博物馆预约官网？