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;    }  }?>