Rumah >pembangunan bahagian belakang >tutorial php >PHP基于ORM操作MySQL数据库
PHP基于ORM操作MySQL数据库
- 小云云asal
- 2018-02-12 11:06:571624semak imbas
ORM----Oriented Relationship Mapper，即用面向对象的方式来操作数据库。归根结底，还是对于SQL语句的封装。本文我们主要和大家介绍PHP基于ORM方式操作MySQL数据库,结合具体实例形式分析了php针对mysql数据库常用操作的封装与使用技巧,希望对大家有用。
首先，我们的数据库有如下一张表：
我们希望能够对这张表，利用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);这样对数据库中的记录进行更新。
相关推荐：
Atas ialah kandungan terperinci PHP基于ORM操作MySQL数据库. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!
Kenyataan：
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Artikel sebelumnya：PHP中PDO实现的SQLite操作类Artikel seterusnya：php实现猴子摘桃算法代码分享
Artikel berkaitan
Lihat lagi- Cara menggunakan cURL untuk melaksanakan permintaan Dapatkan dan Hantar dalam PHP
- Cara menggunakan cURL untuk melaksanakan permintaan Dapatkan dan Hantar dalam PHP
- Cara menggunakan cURL untuk melaksanakan permintaan Dapatkan dan Hantar dalam PHP
- Cara menggunakan cURL untuk melaksanakan permintaan Dapatkan dan Hantar dalam PHP
- Semua simbol ungkapan dalam ungkapan biasa (ringkasan)