相思资源网 Design By www.200059.com
本文实例讲述了PHP基于ORM方式操作MySQL数据库。分享给大家供大家参考,具体如下:
ORM----Oriented Relationship Mapper,即用面向对象的方式来操作数据库。归根结底,还是对于SQL语句的封装。
首先,我们的数据库有如下一张表:
我们希望能够对这张表,利用setUserid("11111"),即可以设置userid;getUserid()既可以获得对象的userid。所以,我们需要建立model对象,与数据库中的表对应。
由于每张表所对应的model都应该是有set/get操作,所以,我们用一个父类BasicModel进行定义。其他model都是继承至这个model。
BasicModel的代码如下:
<"htmlcode"><"BasicModel.php"); class TbUser extends BasicModel{ } "htmlcode"><"htmlcode"><"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; } } "TbUser",代码就得知操作的表为tb_user,然后就可以进行一系列操作了。<"BasicDAO.php"); require_once("../model/TbUser.php"); class TbUserDAO extends BasicDAO{ function TbUserDAO(){ $this->modelName = 'TbUser'; parent::init(); } } "htmlcode">$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程序设计有所帮助。
相思资源网 Design By www.200059.com广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com相思资源网 Design By www.200059.com暂无PHP基于ORM方式操作MySQL数据库实例的评论...
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?