浅谈PHP值mysql操作类

浅谈PHP值mysql操作类

<?php/** * Created by PhpStorm. * User: Administrator * Date: 2016/6/27 * Time: 18:55 */ Class Mysqls{   private $table; //表  private $opt;   public function __construct($host,$user,$pwd,$name,$table_names)  {    $this->db=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');