php值mysql操作类，php值mysqldb=new mysqli($host,$user,$pwd,$name); //数据库连接 if(mysqli_connect_errno()){ echo 数据库连接错误.mysqli_connect_errno(); exit(); } $this->db->query(set names utf8); $this->table=$table_names; $this->opt['field']=*; $this->opt['where']=$this->opt['order']=$this->opt['limit']=$this->opt['group']='';// var_dump($this->opt['where']); //$this->m($table_names); } //数据库连接// protected function m($table_name){// $this->db=new mysqli(dbhost,dbuser,dbpwd,dbname);//// if(mysqli_connect_errno()){// echo 数据库连接错误.mysqli_connect_errno();// exit();// }// $this->db->query(set names utf8);// $this->table=$table_name;// } //表中的字段 public function tbfield(){ $desc=$this->db->query(desc {$this->table}); $fieldarr=array(); while(($row=$desc->fetch_assoc())!=false){ $fieldarr[]=$row['field']; } // var_dump($fieldarr); return $fieldarr; } //查询字段 public function field($filed){ //拆分字段 $filedarr=is_string($filed)?explode(,,$filed):$filed; if(is_array($filedarr)){ $filed=''; foreach($filedarr as $v){ $filed.='.$v.'.,; } } //var_dump($filed); return rtrim($filed,,); } //判断字段是否存在 public function isfield($fileds) { $filedarr=is_string($fileds)?explode(,,$fileds):$fileds; $tbfiled=$this->tbfield(); //var_dump( $tbfiled); foreach($filedarr as $v){ if(!in_array($v,$tbfiled)){ echo 字段输入发错; } } } //条件语句 public function where($where){ $this->opt['where']=is_string($where)? where {$where}:不是字符串; return $this; } //limit public function limit($limit){ $this->opt['limit']=is_string($limit)? limit {$limit}:不是字符串; return $this; } public function order($order){ $this->opt['order']=is_string($order)? order by {$order}:不是字符串; return $this; } public function group($group){ $this->opt['group']=is_string($group)? group by {$group}:不是字符串; return $this; } // 查询字符串 public function select(){ $sql=select * from {$this->table} {$this->opt['where']} {$this->opt['group']} {$this->opt['limit']} {$this->opt['order']}; return $this->fetch($sql); } //结果集查询 public function fetch($sql){ $result=$this->db->query($sql); $sqlarr=array(); while(($row=$result->fetch_assoc())!=false){ $sqlarr[]=$row; } // var_dump($sqlarr); return $sqlarr; } //无结果集查询 public function querys($sql){ $sqls=$this->db->query($sql); return $this->db->affected_rows; } //删除语句 public function delete($where=array()){ if($where== && empety($this->opt['where'])) die( 不能为空); if($where!=){ if(is_array($where)){ $where=implode(,,$where); } $this->opt['where']= where id in({$where}); } $sql=delete from {$this->table} {$this->opt['where']} {$this->opt['limit']}; var_dump($sql); //return $this->query($sql); } //数组键名 public function key($key){ if(!is_array($key))die(非法数组); $keys=; foreach($key as $v){ $keys.=$v.,; } return rtrim($keys,,); } //数组值 public function value($value){ if(!is_array($value))die(非法数组); $strvalue=; foreach($value as $v){ $strvalue.='.$v.'.,; } return rtrim($strvalue,,); } //添加语句 public function add($filed){ if(!is_array($filed)) die(非法数组); $fileds=$this->key(array_keys($filed)); //返回数组中的键名 //var_dump($fileds); $values=$this->value(array_values($filed)); $sql=insert into {$this->table}({$fileds})values($values); //var_dump($sql); return $this->querys($sql); } //查找单条记录 public function find($field,$id){ $sql=select {$this->opt['field']} from {$this->table} {$this->where($field.'='.'.$id.')}; var_dump($sql); return $this->fetch($sql); } //更新语句 public function save($arrs){ if(!is_array($arrs))die(非法的数组); //if(empty($this->opt['where']))die(条件不能为空); $str=; while(list($k,$v)=each($arrs)) { $str={$k}=.'{$v}',; } $str=rtrim($str,,); $sql=update {$this->table} set {$str}{$this->opt['where']}; return $this->querys($sql); } //获取总记录数 public function counts(){ $sql=select 'id' from {$this->table}{$this->opt['where']}; //var_dump($sql); return $this->querys($sql); }}$db=new mysqls('127.0.0.1','root','','mysql','user');
写的一部分有问题 参考了别人一部分
http://www.bkjia.com/phpjc/1138093.htmlwww.bkjia.comtruehttp://www.bkjia.com/phpjc/1138093.htmltecharticlephp值mysql操作类，php值mysql ?php/** * created by phpstorm. * user: administrator * date: 2016/6/27 * time: 18:55 */class mysqls{ private $table; //表 private $opt; public f...