自定義mysql DB類 實現(xiàn)增刪該查

<?php 
//數(shù)據(jù)庫連接類
class DB{
    //私有屬性
    private static $dbcon = false;
    private $host;
    private $port;
    private $user;
    private $pass;
    private $db;
    private $charset;
    private $link;

    //私有構(gòu)造方法
    private function __construct(){
        $this->host = 'rm-uf6kvqj8697g106ccmo.mysql.rds.aliyuncs.com';
        $this->port = '3306';
        $this->user = 'weiyuntao';
        $this->pass = 'Wyt123456';
        $this->db = 'queue';
        $this->charset = 'utf8';
        //連接數(shù)據(jù)庫
        $this->db_connect();
        //選擇數(shù)據(jù)庫
        $this->db_userdb();
        //設(shè)置字符集
        $this->db_charset();
    }

    //連接數(shù)據(jù)庫
    private function db_connect(){
        $this->link = mysqli_connect(
            $this->host,
            $this->user,
            $this->pass,
            $this->db,
            $this->port
            );
        if(!$this->link){
            echo "連接數(shù)據(jù)庫失敗<br>";
            echo "錯誤編碼".mysqli_errno($this->link)."<br>";
            echo "錯誤編碼".mysqli_error($this->link)."<br>";
            exit;
        }
    }

    //設(shè)置字符集
    private function db_charset(){
        mysqli_query($this->link,"set names {$this->charset}");
    }

    //選擇數(shù)據(jù)庫
    private function db_userdb(){
        $result = mysqli_query($this->link,"use {$this->db}");
    }

    //私有的克隆
    private function __clone(){
        die('clone is not allowed');
    }

    //公用的靜態(tài)方法 $db = DB::getIntance();
    public static function getIntance(){
        if(self::$dbcon==false){
            self::$dbcon=new self;
        }
        return self::$dbcon;
    }

    //執(zhí)行sql語句
    public function query($sql){
        $res = mysqli_query($this->link,$sql);
        if(!$res){
            echo "sql語句執(zhí)行失敗<br>";
            echo "錯誤編碼是".mysqli_errno($this->link)."<br>";
            echo "錯誤信息是".mysqli_error($this->link)."<br>";  
        }
        return $res;
    }

    //獲取最后一條記錄id
    public function getInsertid(){
        return mysqli_insert_id($this->link);
    }

    /**
    *查詢某個字段
    *@param
    *@return string or int
    */
    public function getOne($sql){
        $query = $this->query($sql);
        return mysqli_free_result($query);
    }

    //獲取一行記錄，return array一維數(shù)組
    public function getRaw($sql,$type="assoc"){
        $query = $this->query($sql);
        if(!in_array($type,array("assoc","array","row"))){
            die("mysqli_query error");
        }
        $funcname = "mysqli_fetch_".$type;
        return $funcname($query);
    }

    //獲取多條數(shù)據(jù)碧囊，二維數(shù)組
    public function getAll(){
        $query = $this->query($sql);
        $list = array();
        while($r = $this->getFormSource($query)){
            $list[]=$r;
        }
        return $list;
    }

    public function selectAll($table,$where,$fields = '*',$order='',$skip=0,$limit=1000){
        if(is_array($where)){
            foreach ($where as $key => $val) {
                if(is_numeric($val)){
                    $condition = $key.'='.$val;
                }else{
                    $condition = $key.'=\".$val.\"';
                }
            }
        }else{
            $condition = $where;
        }   
        if(!empty($order)){
            $order = "order by ".$order;
        }
        $sql = "select $fields from $table where $condition $order limit $skip,$limit";
        $result = $this->query($sql);
        if($result){
            return true;
        }else{
            return false;
        }
    }   

    /**
    *添加數(shù)據(jù)
    *@param string $table 表名
    *@param string or array $data[數(shù)據(jù)]
    *@return int 最新添加的id
    */
    public function insert($table,$data){
        $key_str = '';
        $v_str = '';
        foreach ($data as $key => $v) {
            $key_str.=$key.',';
            $v_str.= "'$v',";
        }
        $key_str = trim($key_str,',');
        $v_str = trim($v_str,',');
        //判斷數(shù)據(jù)是否為空
        $sql = "insert into $table ($key_str) values ($v_str)";
        $this->query($sql);
        return $this->getInsertid();
    }

    //刪除一條數(shù)據(jù)
    /**
    *@param $table $where=array('id'=>'a') 表名 條件
    *@return 受影響的行數(shù)
    */
    public function deleteOne($table,$where){
        if(is_array($where)){
            foreach ($where as $key => $val) {
                $condition = $key.'='."'$val'";     
            }
        }else{
            $condition = $where;
        }
        $sql = "delete from $table where $condition";
        $this->query($sql);
        //返回受影響的行數(shù)
        return mysqli_affected_rows($this->link);
    }

    /**
    *刪除多條數(shù)據(jù)方法
    *@param1 $table $where 表名 條件
    *@reurn 受影響的行數(shù)
    */
    public function deleteAll($table,$where){
        if(is_array($where)){
            foreach ($where as $key => $val) {
                if(is_array($val)){
                    $condition = $key.' '.'in('.implode(',',$val).')';
                }else{
                    $condition = $key.'='.$val;
                }
            }
        }else{
            $condition = $where;
        }
        $sql = "delete from $table where $condition";
        $this->query($sql);

        //返回受影響的行數(shù)
        return mysqli_affected_rows($this->link);
    }

    /**
    *修改操作
    *@param $table $data $where 表名 數(shù)據(jù) 條件
    */

    public function update($table,$data,$where,$limit = 0){
        //遍歷數(shù)組栏妖，得到每一個字段和字段的值
        $str = '';
        foreach ($data as $key => $v) {
            $str .= "$key='$v',";
        }
        $str = trim($str,',');
        if(is_array($where)){
            foreach ($where as $key => $val) {
                if(is_array($val)){
                    $condition = $key.'in ('.implode(',',$val).')';
                }else{
                    $condition = $key.'='.$val;
                }
            }
        }else{
            $condition = $where;
        }

        if(!empty($limit)){
            $limit = "limit".' '.$limit;
        }else{
            $limit = '';
        }
        //修改sql語句
        $sql = "update $table set $str where $condition $limit";
        $res = $this->query($sql);
        if($res){
            return true;
        }else{
            return false;
        }
        
    }



}



?>

引用使用：

<?php 
    include './db.php';
    $db = DB::getIntance();

    $data = [
        'mobile'=>'13525728794'
    ];
    $res = $db->insert('order_queue',$data);
    var_dump($res);
?>