PHP基于ORM方式操作MySQL數(shù)據(jù)庫(kù)實(shí)例
本文實(shí)例講述了PHP基于ORM方式操作MySQL數(shù)據(jù)庫(kù)。分享給大家供大家參考，具體如下：
ORM----Oriented Relationship Mapper，即用面向?qū)ο蟮姆绞絹?lái)操作數(shù)據(jù)庫(kù)。歸根結(jié)底，還是對(duì)于SQL語(yǔ)句的封裝。
首先，我們的數(shù)據(jù)庫(kù)有如下一張表：
我們希望能夠?qū)@張表，利用setUserid("11111")，即可以設(shè)置userid；getUserid()既可以獲得對(duì)象的userid。所以，我們需要建立model對(duì)象，與數(shù)據(jù)庫(kù)中的表對(duì)應(yīng)。
由于每張表所對(duì)應(yīng)的model都應(yīng)該是有set/get操作，所以，我們用一個(gè)父類BasicModel進(jìn)行定義。其他model都是繼承至這個(gè)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表相互對(duì)應(yīng)的model類TbUser則對(duì)它進(jìn)行繼承。
<?php
require_once("BasicModel.php");
class TbUser extends BasicModel{
}
?>
這樣，我們就可以對(duì)TbUser的實(shí)例進(jìn)行set/get操作了。
要用ORM進(jìn)行操作數(shù)據(jù)庫(kù)，就必須可以findByWhere($where)進(jìn)行查詢，返回的為對(duì)象數(shù)組；save($tbUser)進(jìn)行保存;delete($obj)進(jìn)行刪除;update($obj)進(jìn)行更新操作。
本質(zhì)上，就是用戶傳入的是對(duì)象，我們?cè)倮么a將對(duì)象轉(zhuǎn)換為SQL語(yǔ)句。本質(zhì)上，執(zhí)行的還是SQL語(yǔ)句。
所以，我們對(duì)一系列的操作用接口表示。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);
}
?>
我們最關(guān)鍵，就是對(duì)此接口進(jìn)行實(shí)現(xiàn)。完成對(duì)象和SQL的轉(zhuǎn)換。
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() {
//根據(jù)model的名字得到表的名字
$this->tableName = strtolower(substr($this->modelName,0,2))."_".strtolower(substr($this->modelName,2));
}
//獲得一個(gè)表的列名
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){
//獲得數(shù)據(jù)表的列名
$columns = $this->getColumn($this->tableName);
//拼接sql語(yǔ)句
$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;
}
//分頁(yè)查詢；支持排序
public function findWhereOrderBy($where,$order,$start=null,$limit=null){
//獲得數(shù)據(jù)表的列名
$columns = $this->getColumn($this->tableName);
//拼接sql語(yǔ)句
$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)){
//是數(shù)字
$sql .= $value.",";
}else{
$sql .= "'".$value."',";
}
}
$sql = substr($sql,0,strlen($sql)-1);
$sql .= ")";
//執(zhí)行sql語(yǔ)句
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){
//是數(shù)字
if(preg_match("/^[0-9]*$/", $value)){
$sql .= $columns[0]."=".$value;
}else{
$sql .= $columns[0]."='".$value."'";
}
//執(zhí)行
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."'";
}
//執(zhí)行操作
mysqli_query($conn,$sql);
$tag = true;
mysqli_close($conn);
}
return $tag;
}
}
?>
那么，對(duì)tb_user表進(jìn)行操作時(shí)，主要利用的是TbUserDAO，它將modelName設(shè)置為"TbUser"，代碼就得知操作的表為tb_user，然后就可以進(jìn)行一系列操作了。
<?php
require_once("BasicDAO.php");
require_once("../model/TbUser.php");
class TbUserDAO extends BasicDAO{
function TbUserDAO(){
$this->modelName = 'TbUser';
parent::init();
}
}
?>
那么，就可以采用面向?qū)ο蟮姆绞綄?duì)數(shù)據(jù)庫(kù)進(jìn)行操作了。
如：
$tbUserDAO = new TbUserDAO();
$tbUser = new TbUser();
$tbUser->setUserid("fetchingsoft@163.com");
$tbUser->setUsername("fetching");
$tbUserDAO->update($tbUser);
echo "執(zhí)行成功！";
print_r($list);
這樣對(duì)數(shù)據(jù)庫(kù)中的記錄進(jìn)行更新。
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《PHP基于pdo操作數(shù)據(jù)庫(kù)技巧總結(jié)》、《php+Oracle數(shù)據(jù)庫(kù)程序設(shè)計(jì)技巧總結(jié)》、《PHP+MongoDB數(shù)據(jù)庫(kù)操作技巧大全》、《php面向?qū)ο蟪绦蛟O(shè)計(jì)入門(mén)教程》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門(mén)教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
- Php連接及讀取和寫(xiě)入mysql數(shù)據(jù)庫(kù)的常用代碼
- PHP連接和操作MySQL數(shù)據(jù)庫(kù)基礎(chǔ)教程
- php mysql數(shù)據(jù)庫(kù)操作類
- PHP備份/還原MySQL數(shù)據(jù)庫(kù)的代碼
- php實(shí)現(xiàn)mysql數(shù)據(jù)庫(kù)備份類
- 常用的PHP數(shù)據(jù)庫(kù)操作方法（MYSQL版）
- php連接mysql數(shù)據(jù)庫(kù)代碼
- PHP實(shí)現(xiàn)PDO的mysql數(shù)據(jù)庫(kù)操作類
- php實(shí)現(xiàn)MySQL數(shù)據(jù)庫(kù)備份與還原類實(shí)例
- 一款簡(jiǎn)單實(shí)用的php操作mysql數(shù)據(jù)庫(kù)類
- PHP數(shù)據(jù)庫(kù)操作之基于Mysqli的數(shù)據(jù)庫(kù)操作類庫(kù)
- 全新的PDO數(shù)據(jù)庫(kù)操作類php版（僅適用Mysql）
相關(guān)文章
![使用php+Ajax實(shí)現(xiàn)唯一校驗(yàn)實(shí)現(xiàn)代碼[簡(jiǎn)單應(yīng)用]](http://img.jbzj.com/images/xgimg/bcimg0.png)
使用php+Ajax實(shí)現(xiàn)唯一校驗(yàn)實(shí)現(xiàn)代碼[簡(jiǎn)單應(yīng)用]
使用php+Ajax實(shí)現(xiàn)唯一校驗(yàn)實(shí)現(xiàn)代碼[簡(jiǎn)單應(yīng)用],前臺(tái)用ajax后臺(tái)用php，需要的朋友可以參考下。2011-11-11
php下刪除一篇文章生成的多個(gè)靜態(tài)頁(yè)面
php自定義函數(shù)之刪除一篇文章生成的多個(gè)靜態(tài)頁(yè)面，可能有多頁(yè)的文章，都是需要考慮到的。2010-08-08
本篇文章是對(duì)php中fsockopen偽造post與get的方法進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-06-06
php實(shí)現(xiàn)google與baidu的分頁(yè)代碼，需要的朋友可以參考下。2009-11-11
set_include_path和get_include_path使用及注意事項(xiàng)
set_include_path 設(shè)置默認(rèn)包含路徑,本文將介紹下其的使用方法，及注意事項(xiàng)，感興趣的朋友可以了解下，或許對(duì)你學(xué)習(xí)php有所幫助2013-02-02
PHP+JS實(shí)現(xiàn)文件分塊上傳的示例代碼
我們?cè)谏蟼鞔笪募r(shí)，可能會(huì)由于服務(wù)器的原因?qū)е挛募蟼魇?，文件過(guò)大時(shí)由于服務(wù)器的配置或響應(yīng)事件過(guò)長(zhǎng)導(dǎo)致上傳文件失敗，這時(shí)候我們可以將一個(gè)大的文件分為若干塊，然后分批次上傳到服務(wù)端。本文介紹了實(shí)現(xiàn)的方法，需要的可以參考一下2022-11-11
1億條數(shù)據(jù)如何分表100張到Mysql數(shù)據(jù)庫(kù)中（PHP）
這篇文章主要介紹了當(dāng)數(shù)據(jù)量猛增的時(shí)候如何把一億條數(shù)據(jù)分表100張到Mysql數(shù)據(jù)庫(kù)中,需要的朋友可以參考下2015-07-07
PHP實(shí)現(xiàn)的比較完善的購(gòu)物車類
這篇文章主要介紹了PHP實(shí)現(xiàn)的比較完善的購(gòu)物車類,包含了針對(duì)商品常見(jiàn)的增加、刪除與修改等功能,非常具有實(shí)用價(jià)值,需要的朋友可以參考下2014-12-12
這篇文章主要為大家詳細(xì)介紹了PHP多維數(shù)組排序array的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-11-11
這篇文章主要介紹了以文件形式緩存php變量的方法,涉及php緩存類的定義與使用技巧,需要的朋友可以參考下2015-06-06