PHP模型Model类封装数据库操作示例
本文实例讲述了PHP模型Model类封装数据库操作。分享给大家供大家参考，具体如下：
tableName=PRE.$tableName;
//2.初始化连接数据库
$this->getConnect();
//3.获得当前表的所有字段
$this->getFields();
}
/**
*初始化连接数据库操作
*/
publicfunctiongetConnect()
{
//1.连接数据库
$this->link=mysqli_connect(HOST,USER,PWD,DB,PORT);
//2.判断连接
if(mysqli_connect_errno($this->link)>0){
echomysqli_connect_error($this->link);
exit;
}
}
/**
*执行并发送SQL(查询)
*@paramstring$sql要查询的SQL语句
*@returnarray返回查询出来的二维数组
*/
publicfunctionquery($sql)
{
$result=mysqli_query($this->link,$sql);
if($result&&mysqli_num_rows($result)>0){
$arr=[];
while($row=mysqli_fetch_assoc($result)){
$arr[]=$row;
}
}
return$arr;
}
/**
*获取当前表的所有字段
*/
publicfunctiongetFields()
{
//查看表结构
$sql="desc{$this->tableName}";
//执行并发送SQL
$result=$this->query($sql);
$fields=[];
foreach($resultas$k=>$v){
$fields[]=$v['Field'];
}
$this->allFields=$fields;
}
/**
*执行并发送SQL语句(增删改)
*@paramstring$sql要执行的SQL语句
*@returnbool|int|string添加成功则返回上一次操作id,删除修改操作则返回true,失败则返回false
*/
publicfunctionexec($sql)
{
$result=mysqli_query($this->link,$sql);
//处理结果集
if($result&&mysqli_affected_rows($this->link)>0){
//判断是否为添加操作，是则返回上一次执行的id
if(mysqli_insert_id($this->link)){
returnmysqli_insert_id($this->link);
}
//删除修改操作成功则返回true
returntrue;
}else{
//未执行成功则返回false
returnfalse;
}
}
/**
*查询多条数据
*/
publicfunctionselect()
{
$sql="select{$this->field}from{$this->tableName}{$this->where}{$this->order}{$this->limit}";
//执行并发送SQL
return$this->query($sql);
}
/**
*查询一条数据
*@paramstring$id要查询的id
*@returnarray返回一条数据
*/
publicfunctionfind($id="")
{
//判断id是否存在
if(empty($id)){
$where=$this->where;
}else{
$where="whereid={$id}";
}
$sql="select{$this->field}from{$this->tableName}{$where}limit1";
//执行并发送sql
$result=$this->query($sql);
//返回一条数据
return$result[0];
}
/**
*设置要查询的字段信息
*@paramstring$field要查询的字段
*@returnobject返回自己，保证连贯操作
*/
publicfunctionfield($field)
{
//判断字段是否存在
if(empty($field)){
return$this;
}
$this->field=$field;
return$this;
}
/**
*统计总条数
*@returnint返回总数
*/
publicfunctioncount()
{
//准备SQL语句
$sql="selectcount(*)astotalfrom{$this->tableName}limit1";
$result=$this->query($sql);
//返回总数
return$result[0]['total'];
}
/**
*添加操作
*@paramarray$data要添加的数组
*@returnbool|int|string添加成功则返回上一次操作的id,失败则返回false
*/
publicfunctionadd($data){
//判断是否是数组
if(!is_array($data)){
return$this;
}
//判断是否全是非法字段
if(empty($data)){
die("非法数据");
}
//过滤非法字段
foreach($dataas$k=>$v){
if(!in_array($k,$this->allFields)){
unset($data[$k]);
}
}
//将数组中的键取出
$keys=array_keys($data);
//将数组中取出的键转为字符串拼接
$key=implode(",",$keys);
//将数组中的值转化为字符串拼接
$value=implode("','",$data);
//准备SQL语句
$sql="insertinto{$this->tableName}({$key})values('{$value}')";
//执行并发送SQL
return$this->exec($sql);
}
/**
*删除操作
*@paramstring$id要删除的id
*@returnbool删除成功则返回true,失败则返回false
*/
publicfunctiondelete($id="")
{
//判断id是否存在
if(empty($id)){
$where=$this->where;
}else{
$where="whereid={$id}";
}
$sql="deletefrom{$this->tableName}{$where}";
echo$sql;
//执行并发送
return$this->exec($sql);
}
/**
*修改操作
*@paramarray$data要修改的数组
*@returnbool修改成功返回true，失败返回false
*/
publicfunctionupdate($data){
//判断是否是数组
if(!is_array($data)){
return$this;
}
//判断是否是全是非法字段
if(empty($data)){
die("非法数据");
}
$str="";
//过滤非法字段
foreach($dataas$k=>$v){
if($k=="id"){
$where="whereid={$v}";
unset($data[$k]);
}
if(in_array($k,$this->allFields)){
$str.="{$k}='{$v}',";
}else{
unset($data[$k]);
}
}
//判断是否有条件
if(empty($this->where)){
die("请输入条件");
}
//去掉最右侧的逗号
$str=rtrim($str,",");
$sql="update{$this->tableName}set{$str}{$this->where}";
return$this->exec($sql);
}
/**
*where条件
*@paramstring$where输入的where条件
*@return$this返回自己，保证连贯操作
*/
publicfunctionwhere($where)
{
$this->where="where".$where;
return$this;
}
/**
*order排序条件
*@paramstring$order以此为基准进行排序
*@return$this返回自己，保证连贯操作
*/
publicfunctionorder($order)
{
$this->order="orderby".$order;
return$this;
}
/**
*limit条件
*@paramstring$limit输入的limit条件
*@return$this返回自己，保证连贯操作
*/
publicfunctionlimit($limit)
{
$this->limit="limit".$limit;
return$this;
}
/**
*析构方法
*关闭数据库连接
*/
publicfunction__destruct()
{
mysqli_close($this->link);
}
}
//自行调试
$a=newModel("表名");
//var_dump($a->find(3));
//var_dump($a->select());
//var_dump($a->count());
//$res=$a->select();
//var_dump($res);
?>
更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+mysqli数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP基本语法入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。