成人精品一区二区三区中文字幕-成人精品一区二区三区-成人精品一级毛片-成人精品亚洲-日本在线视频一区二区-日本在线视频免费

導航首頁 ? 技術教程 ? PHP基于ORM方式操作MySQL數據庫實例
全站頭部文字 我要出現在這里
PHP基于ORM方式操作MySQL數據庫實例 701 2023-12-08   

本文實例講述了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程序設計有所幫助。


主站蜘蛛池模板: 王者图片| 光棍电影| 眼睛胬肉手术多久恢复| 仲文你好vlog最新视频| 电影网1905免费版| 《浪漫樱花》电影| 简单的应急预案怎么写| 《爱的温暖》电影在线观看| 王菲电影| 秋霞影视| 精灵使的剑舞无删减版在线观看| 不要再来伤害我简谱| 欧美日韩欧美日韩在线观看视频| 六年级五单元作文| 布莱克·莱弗利身高体重| 山西少儿频道| 电视剧《后浪》| 韩国三级大全中文字幕999| 在线播放美脚パンスト女教师| 被抛弃的青春1982| 教育向美而生读书心得体会| 黄视频免费观看网站| 心经全文260字| 网络胜利组| 日本大片ppt免费ppt| 啊嗯啊| 竹内美宥| 高岛真一| 爱情天梯| 女同性电影| 北京卫视节目单全天| 一吻定情1| 陪我过个冬原唱歌词| 刑事侦缉档案1演员表| 告别信| 五年级下册第四单元语文园地| 甲铁城的卡巴内利| 远方的故乡简谱| 招领启事的格式| 池田夏希| 风间由美的电影|

!!!站長長期在線接!!!

網站、小程序:定制開發/二次開發/仿制開發等

各種疑難雜癥解決/定制接口/定制采集等

站長微信:lxwl520520

站長QQ:1737366103