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

àì夳堔傛蜴生んèń 2024-04-17 06:06 74阅读 0赞

ORM 对象关系映射，

**O（Object） 对象**，在项目中就是实体，更加精确的来说就是数据Model，也可以说持久化类。

**R（Relation） 关系数据**，

**M (Mapping)映射**，将对象映射到关系数据，将关系数据映射到对象的过程。更加直观理解就是，ORM 就是以OOP思想，产生增删改查SQL语句。

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

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

首先，我们的数据库有如下一张表：

![20190826120020893.png][]

我们希望能够对这张表，利用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_pdo]》、《[php+Oracle数据库程序设计技巧总结][php_Oracle]》、《[PHP+MongoDB数据库操作技巧大全][PHP_MongoDB]》、《[php面向对象程序设计入门教程][php]》、《[php字符串(string)用法总结][php_string]》、《[php+mysql数据库操作入门教程][php_mysql]》及《[php常见数据库操作技巧汇总][php 1]》

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

[20190826120020893.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/16/7e4bb425bf864d6691e245f511ac9b73.png
[PHP_pdo]: https://www.jb51.net/Special/192.htm
[php_Oracle]: https://www.jb51.net/Special/759.htm
[PHP_MongoDB]: https://www.jb51.net/Special/586.htm
[php]: https://www.jb51.net/Special/43.htm
[php_string]: https://www.jb51.net/Special/47.htm
[php_mysql]: https://www.jb51.net/Special/84.htm
[php 1]: https://www.jb51.net/Special/231.htm