浅谈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');



写的一部分有问题 参考了别人一部分。

以上就是小编为大家带来的浅谈PHP值mysql操作类全部内容了，希望大家多多支持中文源码网~