zoukankan      html  css  js  c++  java
  • 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');
    

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

  • 相关阅读:
    《TD项目开发小结》
    感悟
    毕业两年了
    ip+port无法访问nginx问题
    问题解决之道
    调休9天的那些日子
    关于类加载器(ClassLoader)
    ios核心蓝牙之心率监控(swift)
    git(git-flow)的高效管理使用
    WKWebview加载本地图片时出现路径问题
  • 原文地址:https://www.cnblogs.com/mengluo/p/5625002.html
Copyright © 2011-2022 走看看