PHP基于ORM方式操作MySQL数据库实例
发布时间：2021-01-24 19:49:05 所属栏目：PHP教程 来源：网络整理
导读：本篇章节讲解PHP基于ORM方式操作MySQL数据库。供大家参考研究具体如下： ORM----Oriented Relationship Mapper，即用面向对象的方式来操作数据库。归根结底，还是对于SQL语句的封装。 首先，我们的数据库有如下一张表： 我们希望能够对这张表，利
|
副标题[/!--empirenews.page--]
本篇章节讲解PHP基于ORM方式操作MySQL数据库。分享给大家供大家参考，具体如下： ORM----Oriented Relationship Mapper，即用面向对象的方式来操作数据库。归根结底，还是对于SQL语句的封装。 首先，我们的数据库有如下一张表：
我们希望能够对这张表，利用setUserid("22222")，即可以设置userid；getUserid()既可以获得对象的userid。所以，我们需要建立model对象，与数据库中的表对应。 由于每张表所对应的model都应该是有set/get操作，所以，我们用一个父类BasicModel进行定义。其他model都是继承至这个model。 BasicModel的代码如下： map = array(); } function __set($key,$value){ $this->map[$key] = $value; } function __get($key){ return $this->map[$key]; } function __call($name,$arguments) { if(substr($name,3)=='set'){ $this->__set(strtolower(substr($name,3)),$arguments[0]); }else{ return $this->__get(strtolower(substr($name,3))); } } } ?>那么，与tb_user表相互对应的model类TbUser则对它进行继承。 这样，我们就可以对TbUser的实例进行set/get操作了。 要用ORM进行操作数据库，就必须可以findByWhere($where)进行查询，返回的为对象数组；save($tbUser)进行保存;delete($obj)进行删除;update($obj)进行更新操作。 本质上，就是用户传入的是对象，我们再利用代码将对象转换为SQL语句。本质上，执行的还是SQL语句。 所以，我们对一系列的操作用接口表示。IBasicDAO的代码如下： 我们最关键，就是对此接口进行实现。完成对象和SQL的转换。 BasicDAO的代码如下： h,$this->user,$this->pass,$this->db);
return $conn;
}
//初始化
public function init() {
//根据model的名字得到表的名字
$this->tableName = strtolower(substr($this->modelName,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,$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,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,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 （编辑：晋中站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
