PHP基于ORM方式操作MySQL数据库实例
程序员文章站
2024-03-11 10:49:49
本文实例讲述了php基于orm方式操作mysql数据库。分享给大家供大家参考，具体如下：
orm----oriented relationship mapper，即用面向...
本文实例讲述了php基于orm方式操作mysql数据库。分享给大家供大家参考，具体如下：
orm----oriented relationship mapper，即用面向对象的方式来操作数据库。归根结底，还是对于sql语句的封装。
首先，我们的数据库有如下一张表：
我们希望能够对这张表，利用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);
这样对数据库中的记录进行更新。
更多关于php相关内容感兴趣的读者可查看本站专题：《php基于pdo操作数据库技巧总结》、《php+oracle数据库程序设计技巧总结》、《php+mongodb数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家php程序设计有所帮助。