Mysql封装

<?php

header("content-type:text/html;charset=utf-8");

class db{
    //私有的静态属性
    private static $dbcon = false ;
    //私有的构造方法
    private function __construct($dbname){
        $dbcon = @mysql_connect(‘127.0.0.1‘, ‘root‘, ‘root‘);
        mysql_select_db($dbname, $dbcon) or die("mysql connect error");
        mysql_query("set names utf8", $dbcon);
    }
    //私有的克隆方法
    private function __clone(){}
    
    //公共的静态方法, 数据库连接对象
    public static function getInstance($dbname){
        if(self::$dbcon == false){
            self::$dbcon = new self($dbname);
        }
        return self::$dbcon;
    }
    /**
     * 执行语句
     * @param  $sql
     * @return source
     */
    public function query($sql){
        return mysql_query($sql);
    }
    /**
     * 查询某个字段, 例如 select count(*),  select username
     * @param  $sql
     * @return string or int
     */
    public function getOne($sql){
        $query = $this->query($sql);
        return mysql_result($query, 0);
    }
    /**
     * 获取一行记录
     * @param  $sql
     * @return array 一维
     */
    public function getRow($sql, $type=‘assoc‘){
        $query = $this->query($sql);
        if(!in_array($type, array("assoc", "array", "row"))){
            die("mysql_query error");
        }
        $functionname = "mysql_fetch_".$type;
        return $functionname($query);
    }
    /**
     * 前置条件:通过资源获取一条记录
     * @param  $query source
     * @return array 一维
     */
    public function getRowFromSource($query, $type="assoc"){
        if(!in_array($type, array("assoc", "array", "row"))){
            die("mysql_query error");
        }
        $functionname = "mysql_fetch_".$type;
        return $functionname($query);
    }
    /**
     * 获取所有记录
     * @param  $sql
     * @return array 二维
     */
    public function getAll($sql){
        $query = $this->query($sql);
        $list = array();
        while ($row = $this->getRowFromSource($query)) {
            $list[] = $row;
        }
        return $list;
    }
    /*
    * 新增数据方法
    * @param1 $table, $data 表名 数据
    * @return 上一次增加操做产生ID值
    */
    public function insert($table, $data){
        //遍历数组，得到每一个字段和字段的值
        $kstr = ‘‘ ;
        $vstr = ‘‘ ;
        foreach ($data as $key => $val) {
            //$key是字段名, $val是对应的值
            $kstr .= $key."," ;
            $vstr .= "‘$val‘,";
        }
        $kstr = rtrim($kstr, ‘,‘);
        $vstr = rtrim($vstr, ‘,‘);
        //添加的sql语句
        $sql = "insert into $table ($kstr) values ($vstr)";
        
        //执行
        $this->query($sql);
        //返回上一次增加操做产生ID值
        return $this->getInsertId();
    }
    /*
    * 删除一条数据方法
    * @param1 $table, $where=array(‘id‘=>‘1‘) 表名 条件
    * @return 受影响的行数
    */
    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);
        //返回受影响的行数
        return mysql_affected_rows();
    }
    /*
    * 删除多条数据方法
    * @param1 $table, $where 表名 条件
    * @return 受影响的行数
    */
    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);
        //返回受影响的行数
        return mysql_affected_rows();
    }
    /*
    * 修改数据方法
    * @param1 $table,$data,$where 表名 数据 条件
    * @return 受影响的行数
    */
    public function update($table,$data,$where){
        //遍历数组，得到每一个字段和字段的值
        $str=‘‘;
        if(is_array($data)){
            foreach($data as $key=>$v){
                $str.="$key=‘$v‘,";  
            }
            $str=rtrim($str,‘,‘);
            //修改的SQL语句
            $sql="update $table set $str where $where";
        } else {
            //修改的SQL语句
            $sql="update $table set $data where $where";
        }
        $this->query($sql);
        //返回受影响的行数
        return mysql_affected_rows();
    }
    /**
     * 获取刚插入数据的id
     * @return int
     */
    public function getInsertId(){
        return mysql_insert_id();
    }
    /**
     * print_r 打印数据
     */
    public function p($arr){
        echo "<pre>";
        print_r($arr);
        echo "</pre>";
    }
    /**
     * var_dump 打印数据
     */
    public function v($arr){
        echo "<pre>";
        var_dump($arr);
        echo "</pre>";
    }


}
// $dbname = ‘yii2_project‘;
// $db = db::getInstance($dbname);
// // where article_id=1
// // $sql = "select * from article";
// // $arr = $db->getAll($sql);
// $db->p($db);

}