本文实例讲述了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）  # 作了  # 的是  # 程序设计  # 面向对象  # 数据库中  # 本质上  # 就可以  # 都是  # 操作技巧  # 相关内容  # 是有  # 感兴趣  # 这张  # 给大家  # 要用  # 分页  # 就可  # 既可  # 设置为  # 更多关于 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel任务队列怎么用_Laravel Queues异步处理任务提升应用性能  如何制作公司的网站链接,公司想做一个网站，一般需要花多少钱？  无锡营销型网站制作公司,无锡网选车牌流程？  微信小程序 闭包写法详细介绍  uc浏览器二维码扫描入口_uc浏览器扫码功能使用地址  Laravel如何操作JSON类型的数据库字段？（Eloquent示例）  JavaScript如何实现错误处理_try...catch如何捕获异常？  打开php文件提示内存不足_怎么调整php内存限制【解决方案】  软银砸40亿美元收购DigitalBridge 强化AI资料中心布局  如何在IIS中配置站点IP、端口及主机头？  微信小程序制作网站有哪些,微信小程序需要做网站吗？  HTML 中如何正确使用模板变量为元素的 name 属性赋值  如何用腾讯建站主机快速创建免费网站？  html文件怎么打开证书错误_https协议的html打开提示不安全【指南】  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  图片制作网站免费软件,有没有免费的网站或软件可以将图片批量转为A4大小的pdf？  WordPress 子目录安装中正确处理脚本路径的完整指南  小米17系列还有一款新机？主打6.9英寸大直屏和旗舰级影像  Laravel Artisan命令怎么自定义_创建自己的Laravel命令行工具完全指南  如何挑选高效建站主机与优质域名？  Laravel如何实现用户密码重置功能？（完整流程代码）  Laravel怎么实现搜索高亮功能_Laravel结合Scout与Algolia全文检索【实战】  php在windows下怎么调试_phpwindows环境调试操作说明【操作】  HTML透明颜色代码怎么让图片透明_给img元素加透明色的技巧【方法】  ChatGPT 4.0官网入口地址 ChatGPT在线体验官网  制作旅游网站html,怎样注册旅游网站？  Laravel 419 page expired怎么解决_Laravel CSRF令牌过期处理  HTML5空格和margin有啥区别_空格与外边距的使用场景【说明】  JS中页面与页面之间超链接跳转中文乱码问题的解决办法  Laravel策略(Policy)如何控制权限_Laravel Gates与Policies实现用户授权  百度输入法ai组件怎么删除 百度输入法ai组件移除工具  英语简历制作免费网站推荐,如何将简历翻译成英文？  Laravel队列由Redis驱动怎么配置_Laravel Redis队列使用教程  PythonWeb开发入门教程_Flask快速构建Web应用  香港服务器网站推广：SEO优化与外贸独立站搭建策略  详解Android——蓝牙技术 带你实现终端间数据传输  微信小程序 canvas开发实例及注意事项  网页制作模板网站推荐,网页设计海报之类的素材哪里好？  Laravel表单请求验证类怎么用_Laravel Form Request分离验证逻辑教程  如何在阿里云部署织梦网站？  HTML5建模怎么导出为FBX格式_FBX格式兼容性及导出步骤【指南】  微信小程序 配置文件详细介绍  Laravel怎么配置自定义表前缀_Laravel数据库迁移与Eloquent表名映射【步骤】  制作电商网页,电商供应链怎么做？  如何用VPS主机快速搭建个人网站？  Java垃圾回收器的方法和原理总结  简历没回改：利用AI润色让你的文字更专业  佛山企业网站制作公司有哪些,沟通100网上服务官网？  Laravel如何为API生成Swagger或OpenAPI文档  Android自定义listview布局实现上拉加载下拉刷新功能