php mysql数据库操作类(实例讲解)
接着稍微说说整体的思路。整个类的封装,包含一个连接数据库的私有属性$conn和若干操作函数。$conn在对象实例化的时候,由构造函数处理传入的参数后返回一个资源型的连接句柄。而后即可通过调用该实例化的对象的相应方法对数据库进行增删查改的操作。
talklessandshowcode:
*@version1.0 *@since2015 */ classMysql{ //数据库连接返回值 private$conn; /** *[构造函数,返回值给$conn] *@param[string]$hostname[主机名] *@param[string]$username[用户名] *@param[string]$password[密码] *@param[string]$dbname[数据库名] *@param[string]$charset[字符集] *@return[null] */ function__construct($hostname,$username,$password,$dbname,$charset='utf8'){ $conn=@mysql_connect($hostname,$username,$password); if(!$conn){ echo'连接失败,请联系管理员'; exit; } $this->conn=$conn; $res=mysql_select_db($dbname); if(!$res){ echo'连接失败,请联系管理员'; exit; } mysql_set_charset($charset); } function__destruct(){ mysql_close(); } /** *[getAll获取所有信息] *@param[string]$sql[sql语句] *@return[array][返回二维数组] */ functiongetAll($sql){ $result=mysql_query($sql,$this->conn); $data=array(); if($result&&mysql_num_rows($result)>0){ while($row=mysql_fetch_assoc($result)){ $data[]=$row; } } return$data; } /** *[getOne获取单条数据] *@param[string]$sql[sql语句] *@return[array][返回一维数组] */ functiongetOne($sql){ $result=mysql_query($sql,$this->conn); $data=array(); if($result&&mysql_num_rows($result)>0){ $data=mysql_fetch_assoc($result); } return$data; } /** *[getOne获取单条数据] *@param[string]$table[表名] *@param[string]$data[由字段名当键,属性当键值的一维数组] *@return[type][返回false或者插入数据的id] */ functioninsert($table,$data){ $str=''; $str.="INSERTINTO`$table`"; $str.="(`".implode("`,`",array_keys($data))."`)"; $str.="VALUES"; $str.="('".implode("','",$data)."')"; $res=mysql_query($str,$this->conn); if($res&&mysql_affected_rows()>0){ returnmysql_insert_id(); }else{ returnfalse; } } /** *[update更新数据库] *@param[string]$table[表名] *@param[array]$data[更新的数据,由字段名当键,属性当键值的一维数组] *@param[string]$where[条件,‘字段名'=‘字段属性'] *@return[type][更新成功返回影响的行数,更新失败返回false] */ functionupdate($table,$data,$where){ $sql='UPDATE'.$table.'SET'; foreach($dataas$key=>$value){ $sql.="`{$key}`='{$value}',"; } $sql=rtrim($sql,','); $sql.="WHERE$where"; $res=mysql_query($sql,$this->conn); if($res&&mysql_affected_rows()){ returnmysql_affected_rows(); }else{ returnfalse; } } /** *[delete删除数据] *@param[string]$table[表名] *@param[string]$where[条件,‘字段名'=‘字段属性'] *@return[type][成功返回影响的行数,失败返回false] */ functiondel($table,$where){ $sql="DELETEFROM`{$table}`WHERE{$where}"; $res=mysql_query($sql,$this->conn); if($res&&mysql_affected_rows()){ returnmysql_affected_rows(); }else{ returnfalse; } } }
实例化类:
getOne($sql); //获取多条数据 $sql="SELECT*FROMas_articlewhereas_article_type_id=1orderbyas_article_addtimedesclimit$start,$limit"; $service=$db->getAll($sql); //插入数据 $arr=array( 'as_article_title'=>'数据库操作类', 'as_article_author'=>'rex', ); $res=$db->insert('as_article',$arr); //更新数据 $arr=array( 'as_article_title'=>'实例化对象', 'as_article_author'=>'Lee', ); $where="as_article_id=1"; $res=$db->update('as_article',$arr,$where); //删除数据 $where="as_article_id=1"; $res=$db->del('as_article',$where); ?>
演示完代码,大概说几句。
getOne方法传入$sql的sql语句用于查询单条数据并返回一维数组;getAll方法同样传入sql语句,用于查询多条数据,并返回二维数组;insert方法传入表名和关联数组,返回boolen型或者插入数据对应索引;update方法传入表名、关联数组和条件,返回boolen或者影响的行数;del方法传入表名和条件,返回boolen型。
that'sall,butnottheall.有兴趣的朋友可以把getOne和getAll直接传入sql语句作为参数的方式再优化一下。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。