首页 > 代码库 > 操作mysql model
操作mysql model
****************
<?php define(‘HOST‘,‘localhost‘); define(‘USER‘,‘root‘); define(‘PWD‘,‘root‘); define(‘DBNAME‘,‘db59‘);class Model { protected $link;//数据库连接资源 protected $tabName;//表名 protected $where=null;//条件 protected $limit=null;//限制 protected $orderBy=null;//排序 protected $fields=array();//字段信息 protected $pk;//主键的名称 protected $sql;//sql语句 function __construct($tabName){ $this->link=mysql_connect(HOST,USER,PWD,true); mysql_select_db(DBNAME,$this->link); mysql_query(‘set names utf8‘); $this->tabName=$tabName; //获取表中的所有字段,放置在成员属性 fields中 $this->getFields(); } /** * 获取字段信息,以数组的形式写入到成员属性fields中 * 获取主键的名称,写入到成员属性pk中 * * */ function getFields(){ $sql="desc $this->tabName"; $result=mysql_query($sql); if($result && mysql_num_rows($result)>0){ while($arr=mysql_fetch_assoc($result)){ //print_r($arr); //echo "<hr/>"; $this->fields[]=$arr[‘Field‘]; if($arr[‘Key‘]==‘PRI‘){ $this->pk=$arr[‘Field‘]; } } } //print_r($this->fields); //exit; } /* * select查询获取多条语句 * @return array 查询的数据的数组 * * */ /* * find 单条数据 * max 获取最大值 * min 获取最小值 * avg 获取平均数 * sum 获取和 * * */ function select(){ $data=array(); $this->sql="select * from {$this->tabName} {$this->where} {$this->orderBy} {$this->limit}"; $result=mysql_query($this->sql); if($result && mysql_num_rows($result)>0){ while($arr=mysql_fetch_assoc($result)){ $data[]=$arr; } } $this->clearAll(); return $data; } /** * 添加数据 * @param array 要添加的数据 * @return int 影响行数 * * */ function insert($var=array()){ if(empty($var)){ $var=$_POST; } $keys=‘‘; $values=‘‘; foreach($var as $k=>$v){ if(!in_array($k,$this->fields)){ continue; } $keys.="`{$k}`,"; $values.="‘{$v}‘,"; } $keys=rtrim($keys,‘,‘); $values=rtrim($values,‘,‘); $this->sql="insert into {$this->tabName}({$keys}) values({$values})"; $result=mysql_query($this->sql); if($result){ return mysql_affected_rows(); }else{ return 0; } } /** * 修改数据 * @param array 要添加的数据 * @return int 影响行数 * * 如 array(‘name‘=>‘abc‘,‘sex‘=>0,‘password‘=>‘123‘,‘id‘=>10); * `name`=‘abc‘,`sex`=‘0‘,`password`=‘123‘ * */ function update($var=array()){ $tmp=‘‘; if(empty($var)){ $var=$_POST; } $keys=‘‘; $values=‘‘; foreach($var as $k=>$v){ if(!in_array($k,$this->fields) || $k==$this->pk){ //过滤掉非法字段以及主键 continue; } $tmp.="`{$k}`=‘{$v}‘,"; } $tmp=rtrim($tmp,‘,‘); //$this->sql="insert into {$this->tabName}({$keys}) values({$values})"; $this->sql="update {$this->tabName} set {$tmp} where {$this->pk}={$var[$this->pk]}"; $result=mysql_query($this->sql); if($result){ return mysql_affected_rows(); }else{ return 0; } } /** * 删除方法 * @param int id号 * @return int 影响行数 * * */ function delete($var){ $sql="delete from {$this->tabName} where {$this->pk}={$var}"; $result=mysql_query($sql); if($result){ return mysql_affected_rows(); }else{ return 0; } } protected function clearAll(){ $this->where=null; $this->limit=null; $this->orderBy=null; } /** * 条件函数 * 在函数中向成员属性$where传递条件的值 * @param string $var 条件值 * @return Model 对象 * */ function where($var){ $where=‘‘;//临时变量where if(is_int($var)){ $where="id={$var}"; }elseif(is_string($var)){ $where="{$var}"; }elseif(is_array($var)){ $logic=isset($var[‘_logic‘])?$var[‘_logic‘]:‘and‘; //array(‘name‘=>‘ztz‘,‘sex‘=>‘1‘,‘abc‘=>‘or‘) //"name=‘ztz‘ and sex=1" foreach($var as $k=>$v){ //判断键是否是合法的字段名称,非法的被过滤 //$k = ‘abc‘; //$this->fields array(‘id‘,‘name‘,‘sex‘,‘password‘); if(!in_array($k,$this->fields)){ continue; } $where.="{$k} = ‘{$v}‘ {$logic} "; } $where=rtrim($where," {$logic} "); }else{ die(‘您在where中输入的数据不再处理范围之内,请核对代码,或者联系项目经理解决‘); //return $this; } $this->where="where $where";//where id >10 return $this; } function limit($var){ $this->limit="limit {$var}"; return $this; } function orderBy($var){ $this->orderBy=" order by {$var}"; return $this; } /** * 获取最后一条sql语句 * @return string $sql 返回成员属性sql语句 * * */ function getLastSql(){ return $this->sql; } } $user=new Model(‘user‘); //where 条件可以是 //string 可以直接用 //int id=10 // "name=‘ztz‘ or sex=1" array(‘name‘=>‘ztz‘,‘sex‘=>‘1‘,‘_logic‘=>‘and‘) $user->update(); $arr=$user->select(); //$user->delete(10); print_r($arr); //echo "<hr/>"; //$arr2=$user->select(); //print_r($arr2); echo "<hr/>"; echo $user->getLastSql();?><html> <head> <meta http-equiv="content-type" content="text/html; charset=utf-8"> <title>Model.class</title> </head><body> <form action=‘‘ method=‘post‘> <input type="hidden" name="id" value="http://www.mamicode.com/27"/> 姓名:<input type="text" name="name"/> 性别:<input type="radio" name="sex" value=http://www.mamicode.com/‘1‘/>男 女 <input type="submit" /> </form></body></html>
操作mysql model
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。