美文网首页
php-mysql数据库操作类

php-mysql数据库操作类

作者: peng_js | 来源:发表于2017-06-30 15:15 被阅读0次

    <?php
    /*
    设计一个类,该类能够在一实例化,就连接上了mysql数据库!
    当然,实例化的时候,需要传递连接数据库的基本信息:
    服务器地址,端口,用户名,密码,连接编码,要使用的数据库名;
    扩充需求:
    该实例化后的对象,还可以:
    1,单独去设定要使用的编码,
    2,以及单独选择要使用的数据库!

    继续扩充需求:
    6,有一个方法,可以执行“增删改”语句,并返回受影响的行数

    7,有一个方法,可以执行“返回一行数据”的select语句,并得到一个一维数组;
    比如:select * from XXX where id = 5;

    8,有一个方法,可以执行“返回多行数据”的select语句,并得到一个二维数组;
    比如:select * from XXX where id > 5 and id < 10;

    9,有一个方法,可以执行“返回一个数据”的select语句,并得到一个“标量值”;
    比如: select count(*) as c from XXX ;

    */

    class MySQLDB{
    //用于保存连接成功之后的资源
    private $link = null;

    private $host ; //定义一些属性,以保存连接信息
    private $port ;
    private $user ;
    private $pass ;
    private $charset ;
    private $dbname ;
    
    //第1步:私有化构造方法:
    private function __construct($conf){
        //将传递过来的俩接信息保存到相应属性中,并考虑默认值情况
        $this->host = !empty($conf['host']) ? $conf['host'] : "localhost";
        $this->port = !empty($conf['port']) ? $conf['port'] : 3306;
        $this->user = !empty($conf['user']) ? $conf['user'] : "root";
        $this->pass = !empty($conf['pass']) ? $conf['pass'] : "123";
        $this->charset = !empty($conf['charset']) ? $conf['charset'] : "utf8";
        $this->dbname = !empty($conf['dbname']) ? $conf['dbname'] : "php40";
    
        //建立连接
        $this->connect();
    
    }
    //第2步:定义一个私有的静态属性:
    private  static $instance = null;
    //第3步:定义一个公开的静态方法以根据一定的逻辑返回该对象:
    static public  function GetDB( $conf ){
            //if(  empty( static::$instance)  ){//改进为如下判断逻辑
            if( (static::$instance instanceOf static)  === false){
                static::$instance  =  new  static( $conf );
            }
            return  static::$instance;
    }
    //第4步:私有化克隆的魔术方法,以禁止外界克隆:
    private function __clone(){}
    
    
    function setCharset($char){
        //mysql_query("set names $char", $this->link);
        //以下一行代替上一行
        $this->query("set names $char");
    }
    function use_db( $db ){
        //mysql_query("use $db", $this->link);
        //以下一行代替上一行
        $this->query("use $db");
    }
    function close_db(){
    
        mysql_close($this->link);
    }
    
    //此方法用于执行“增删改”语句:
    function exec( $sql ){
        $result = $this->query( $sql );
        
        return $this->affectedRow();    //返回影响的行数
        
    }
    //此方法用于执行“返回一行数据” 的select语句并返回一个一维数组:
    function  GetOneRow( $sql ){
        $result = $this->query( $sql );
    
        //下面自然是成功的时候,处理数据:
        $rec = mysql_fetch_assoc( $result );//这就是一个一维数组!
        //类似这样:array('id'=>5, 'name'=>'张三', 'age'=>18);
        return $rec;
    
    }
    
    //此方法用于执行“返回多行数据” 的select语句并返回一个二维数组:
    function  GetAllRow( $sql ){
        $result = $this->query( $sql );
        $rows = array();
        while($rec = mysql_fetch_assoc( $result ) ){
            $rows[] = $rec; //这样之后,$rows就是二维数组了
        }
        return $rows;
    }
    //此方法用于执行“返回一个数据” 的select语句并返回一个标量数据值:
    function  GetOneData( $sql ){
        $result = $this->query( $sql );//仍然是一个结果集(资源)
        $rec = mysql_fetch_row( $result );  //取出第一行,并做成索引数组
        $data = $rec[0];
        return $data;
    }
    
    private function query( $sql ){
        $result = mysql_query($sql, $this->link);
        if($result === false){
            echo "<p>数据库执行失败:";
            echo "<br />失败语句:" . $sql;
            echo "<br />错误代号:" . mysql_errno();
            echo "<br />错误提示:" . mysql_error();
            echo "</p>";
            die();  //执行失败,直接终止!
        }
        return $result;
    }
    //序列化的时候,我们只要对6个数据进行序列化
    function __sleep(){
        
        return array("host","port","user","pass","charset","dbname");
    }
    
    //反序列化的时候,我们需要来使用数据将数据库连接成功
    function __wakeup(){
        //建立连接
        $this->connect();
    }
    
    //完成对象实例化的时候所必须的数据库连接基本操作
    private function connect(){
        $this->link = mysql_connect(
                        "{$this->host}:{$this->port}", 
                        "{$this->user}", 
                        $this->pass
                    )
                    or  die("连接数据库失败!");
        $this->setCharset( $this->charset );
        $this->use_db( $this->dbname );
    }
    //返回受影响的行数
    function affectedRow(){
        return mysql_affected_rows($this->link);
    }
    
    //获得最后一次insert时的自增长id值
    function getInsertedId(){
        return mysql_insert_id($this->link);
    }
    

    }

    相关文章

      网友评论

          本文标题:php-mysql数据库操作类

          本文链接:https://www.haomeiwen.com/subject/pfficxtx.html