php webqq机器人实现(3)

db.class.php

<?php
define('db_host','数据库服务器'); //数据库服务器  
define('db_user','roto');      //数据库用户名  
define('dbpw','ubkkE');    //数据库密码  
define('dbname','snet');  //数据库名  
define('dbcharset','utf8');    //数据库编码,不建议修改  

class mysql {  

    var $querynum = 0;        
    var $link;  
    var $sql;

    private $dbhost = db_host;  
    private $dbname = dbname;  
    private $dbuser = db_user;  
    private $dbpw = dbpw;  
    private $dbcharset = dbcharset;  

    function mysql($dbhost='', $dbuser='', $dbpw='', $dbname = '', $pconnect = 0) {  

        $dbhost==''?$dbhost=$this->dbhost:$dbhost;  
        $dbuser==''?$dbuser=$this->dbuser:$dbuser;  
        $dbpw==''?$dbpw=$this->dbpw:$dbpw;  
        $dbname==''?$dbname=$this->dbname:$dbname;  

        if($pconnect) {  
            if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {  
                $this->halt('Can not connect to MySQL server');  
            }  
        } else {  
            if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {  
                $this->halt('Can not connect to MySQL server');  
            }  
        }  
        if($this->version() > '4.1') {  
            if($this->dbcharset) {  
                mysql_query("SET character_set_connection=$this->dbcharset, character_set_results=$this->dbcharset, character_set_client=binary", $this->link);  
            }  

            if($this->version() > '5.0.1') {  
                mysql_query("SET sql_mode=''", $this->link);  
            }  
        }  

        if($dbname) {  
            mysql_select_db($dbname, $this->link);  
        }  

    }  

    function select_db($dbname) {  
        return mysql_select_db($dbname, $this->link);  
    }  

    function fetch_array($query, $result_type = MYSQL_ASSOC) {  
        return mysql_fetch_array($query, $result_type);  
    }  

    function fetch_all($query, $result_type = MYSQL_ASSOC) {  
        $result = array();  
        $num = 0;  

        while($ret = mysql_fetch_array($query, $result_type))  
        {  
            $result[$num++] = $ret;  
        }  
        return $result;  

    }  

    function fetch_row($query) {  
        $query = mysql_fetch_row($query);  
        return $query;  
    }  

    function result($query, $row) {  
        $query = @mysql_result($query, $row);  
        return $query;  
    }  

    function query($sql, $type = '') {  

        $func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?  
            'mysql_unbuffered_query' : 'mysql_query';  
        if(!($query = $func($sql, $this->link)) && $type != 'SILENT') {  
            $this->halt('MySQL Query Error: ', $sql);  
        }  

        $this->querynum++;  
        return $query;  
    }  

    function insert($table,$row){
        if(!$row)return null;
        $row = $this->_escape($row);
        $tmp = $tmp2 = array();
        foreach($row as $key => $val){
            $tmp[] = $key;
            $tmp2[] = $val;
        }
        $sql = "insert into $table (".join(',',$tmp).") values ('".join('\',\'',$tmp2)."')";
        return $this->query($sql);
    }

    function update($table,$row,$where= null){
        if(!$row || !$table)return null;

        $row = $this->_escape($row);
        $tmp = array();
        foreach($row as $key => $val){
            $tmp[] = $key."='$val'";
        }
        $sql = "update $table set ".join(',',$tmp)."";
        $sql = $where ? $sql.' where '.$where:$sql;
        return $this->query($sql);
    }

    function find($table,$field = '*',$where=null){
        if(!$table) return null;
        $sql = $this->bulidsql($table,$field,$where);
        $query = $this->query($sql);
        $data = null;
        while($row = $this->fech($query))
            $data[] = $row;         
        return $data;
    }

    function findOne($table,$field = '*',$where=null){
        if(!$table) return null;
        $sql = $this->bulidsql($table,$field,$where);
        return $this->fech($this->query($sql));
    }

    function bulidsql($table,$field = '*',$where=null){
        $sql = 'select '.$field.' from '.$table;
        $sql = $where ? $sql.' where '.$where:$sql;
        $this->sql = $sql;
        return $sql;
    }

    function fech($query,$type = MYSQL_ASSOC){
        return mysql_fetch_array($query, $type);
    }

    function _escape($row){
        if(is_array($row)){
            foreach($row as $key => $val){
                $row[$key] = addslashes($val);
            }
        }
        return $row;
    }

    function affected_rows() {  
        return mysql_affected_rows($this->link);  
    }  

    function error() {  
        return (($this->link) ? mysql_error($this->link) : mysql_error());  
    }  

    function errno() {  
        return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());  
    }  

    function num_rows($query) {  
        $query = mysql_num_rows($query);  
        return $query;  
    }  

    function num_fields($query) {  
        return mysql_num_fields($query);  
    }  

    function free_result($query) {  
        return mysql_free_result($query);  
    }  

    function insert_id() {  
        return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);  
    }  

    function fetch_fields($query) {  
        return mysql_fetch_field($query);  
    }  

    function version() {  
        return mysql_get_server_info($this->link);  
    }  

    function close() {  
        return mysql_close($this->link);  
    }  

    function halt($message = '', $sql = '') {  
        echo $message . ' ' . $sql;  
        exit;  

    }  
}  
?>