Wie PHP eine MySQL-Datenbank basierend auf ORM betreibt

In diesem Artikel wird hauptsächlich PHP für den Betrieb der MySQL-Datenbank basierend auf der ORM-Methode vorgestellt. Er analysiert die Kapselungs- und Verwendungsfähigkeiten von PHP für allgemeine Vorgänge der MySQL-Datenbank in Form spezifischer Beispiele

Die Details sind wie folgt:

ORM----Oriented Relationship Mapper, der einen objektorientierten Ansatz zum Betrieb der Datenbank verwendet. Letztlich geht es immer noch um die Kapselung von SQL-Anweisungen.

Zuallererst hat unsere Datenbank die folgende Tabelle:

Wir hoffen, setUserid("11111") für diese Tabelle verwenden zu können, also Set userid; getUserid() kann die Benutzer-ID des Objekts abrufen. Daher müssen wir ein Modellobjekt erstellen, das der Tabelle in der Datenbank entspricht.

Da das jeder Tabelle entsprechende Modell über Set/Get-Operationen verfügen sollte, verwenden wir zur Definition eine übergeordnete Klasse BasicModel. Andere Modelle erben von diesem Modell. Der Code von

BasicModel lautet wie folgt:

<?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)==&#39;set&#39;){
        $this->__set(strtolower(substr($name,3)),$arguments[0]);
      }else{
        return $this->__get(strtolower(substr($name,3)));
      }
    }
  }
?>

Dann erbt ihn die Modellklasse TbUser, die der Tabelle tb_user entspricht.

<?php
  require_once("BasicModel.php");
  class TbUser extends BasicModel{
  }
?>

Auf diese Weise können wir Set/Get-Operationen für die Instanz von TbUser ausführen.

Um ORM zum Betreiben der Datenbank zu verwenden, müssen Sie in der Lage sein, mit findByWhere($where) abzufragen, was ein Array von Objekten zurückgibt, die gelöscht werden sollen; update($obj) ), um den Aktualisierungsvorgang durchzuführen.

Im Wesentlichen übergibt der Benutzer ein Objekt und wir verwenden Code, um das Objekt in eine SQL-Anweisung umzuwandeln. Im Wesentlichen werden SQL-Anweisungen weiterhin ausgeführt.

Wir verwenden also Schnittstellen, um eine Reihe von Operationen darzustellen. Der Code von IBasicDAO lautet wie folgt:

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

Das Wichtigste für uns ist die Implementierung dieser Schnittstelle. Schließen Sie die Konvertierung von Objekten und SQL ab. Der Code von

BasicDAO lautet wie folgt:

<?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 .= "&#39;".$value."&#39;,";
          }
        }
        $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]."=&#39;".$value."&#39;";
          }
          //执行
          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."=&#39;".$value."&#39;,";
          }
        }
        $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."=&#39;".$tempValue."&#39;";
        }
        //执行操作
        mysqli_query($conn,$sql);
        $tag = true;
        mysqli_close($conn);
      }
      return $tag;
    }
  }
?>

Beim Betrieb der Tabelle tb_user wird dann hauptsächlich TbUserDAO verwendet, das den ModelName auf setzt „TbUser“: Der Code weiß, dass die Operationstabelle tb_user ist, und kann dann eine Reihe von Vorgängen ausführen.

<?php
  require_once("BasicDAO.php");
  require_once("../model/TbUser.php");
  class TbUserDAO extends BasicDAO{
    function TbUserDAO(){
      $this->modelName = &#39;TbUser&#39;;
      parent::init();
    }
  }
?>

Dann können Sie die Datenbank objektorientiert betreiben.

Zum Beispiel:

$tbUserDAO = new TbUserDAO();
$tbUser = new TbUser();
$tbUser->setUserid("fetchingsoft@163.com");
$tbUser->setUsername("fetching");
$tbUserDAO->update($tbUser);
echo "执行成功！";
print_r($list);

Aktualisieren Sie die Datensätze in der Datenbank.

Verwandte Empfehlungen:

Ausführliche Erläuterung zur Implementierung einer form automatischen Einreichung

So verwenden Sie den regulären Abgleich, um leere Zeilen und Kommentarzeilen in

phpstorm

PHPstorm zu löschen vollständigste Zusammenfassung der Tastenkombinationen

Das obige ist der detaillierte Inhalt vonWie PHP eine MySQL-Datenbank basierend auf ORM betreibt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!