当前位置: 首页 > PHP > 正文
<?php   

//include("config.php");   
define('db_host','localhost'); //数据库服务器   
define('db_user','root');      //数据库用户名   
define('dbpw','');    //数据库密码   
define('dbname','test');  //数据库名   
define('dbcharset','utf8');    //数据库编码,不建议修改   

//$db = new mysql($dbhost='', $dbuser='', $dbpw='', $dbname = 'test222', $pconnect = 0);   

/**  
include("inc/mysql.class.php");  
   
$db = new mysql();  
   
$query = $db->query("select * from test order by ID DESC");  
   
//取一条记录  
$res = $db->fetch_row($query);  
   
//取所有记录  
$res = $db->fetch_all($query);  
   
//插入  
$db->query("insert into test values (3,'测试222222222','test','fffff')");  
   
   
//mysql_result 只取一个时  
$query = $db->query("select title from test order by ID DESC");  
$rs = $db->result($query,0);  
print_r($rs);  
   
//查询  
$query = $db->query("select * from test order by ID DESC");  
while($rw = $db->fetch_array($query))  
{  
    print_r($rw);  
}  
   
   
**/  

/**  
 * mysql查询类  
 * 改造自discuz的mysql查询类  
 */  
class mysql {   
    /**  
     * 查询总次数  
     *  
     * @var int  
     */  
    var $querynum = 0;   
    /**  
     * 连接句柄  
     *  
     * @var object  
     */  
    var $link;   

    /**  
     * 定义一些默认的变量  
     */  
    private $dbhost = db_host;   
    private $dbname = dbname;   
    private $dbuser = db_user;   
    private $dbpw = dbpw;   
    private $dbcharset = dbcharset;   

    /**  
     * 构造函数  
     *  
     * @param string $dbhost 主机名  
     * @param string $dbuser 用户  
     * @param string $dbpw   密码  
     * @param string $dbname 数据库名  
     * @param int $pconnect 是否持续连接  
     */  
    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);   
        }   

    }   
    /**  
     * 选择数据库  
     *  
     * @param string $dbname  
     * @return  
     */  
    function select_db($dbname) {   
        return mysql_select_db($dbname, $this->link);   
    }   
    /**  
     * 取出结果集中一条记录  
     *  
     * @param object $query  
     * @param int $result_type  
     * @return array  
     */  
    function fetch_array($query, $result_type = MYSQL_ASSOC) {   
        return mysql_fetch_array($query, $result_type);   
    }   

    /**  
     * 取出所有结果  
     *  
     * @param object $query  
     * @param int $result_type  
     * @return array  
     */  
    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;   

    }   

    /**  
     * 从结果集中取得一行作为枚举数组  
     *  
     * @param object $query  
     * @return array  
     */  
    function fetch_row($query) {   
        $query = mysql_fetch_row($query);   
        return $query;   
    }   

    /**  
     * 返回查询结果  
     *  
     * @param object $query  
     * @param string $row  
     * @return mixed  
     */  
    function result($query, $row) {   
        $query = @mysql_result($query, $row);   
        return $query;   
    }   

    /**  
     * 查询SQL  
     *  
     * @param string $sql  
     * @param string $type  
     * @return object  
     */  
    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;   
    }   
    /**  
     * 取影响条数  
     *  
     * @return int  
     */  
    function affected_rows() {   
        return mysql_affected_rows($this->link);   
    }   
    /**  
     * 返回错误信息  
     *  
     * @return array  
     */  
    function error() {   
        return (($this->link) ? mysql_error($this->link) : mysql_error());   
    }   
    /**  
     * 返回错误代码  
     *  
     * @return int  
     */  
    function errno() {   
        return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());   
    }   

    /**  
     * 结果条数  
     *  
     * @param object $query  
     * @return int  
     */  
    function num_rows($query) {   
        $query = mysql_num_rows($query);   
        return $query;   
    }   
    /**  
     * 取字段总数  
     *  
     * @param object $query  
     * @return int  
     */  
    function num_fields($query) {   
        return mysql_num_fields($query);   
    }   
    /**  
     * 释放结果集  
     *  
     * @param object $query  
     * @return bool  
     */  
    function free_result($query) {   
        return mysql_free_result($query);   
    }   
    /**  
     * 返回自增ID  
     *  
     * @return int  
     */  
    function insert_id() {   
        return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);   
    }   

    /**  
     * 从结果集中取得列信息并作为对象返回  
     *  
     * @param object $query  
     * @return object  
     */  
    function fetch_fields($query) {   
        return mysql_fetch_field($query);   
    }   
    /**  
     * 返回mysql版本  
     *  
     * @return string  
     */  
    function version() {   
        return mysql_get_server_info($this->link);   
    }   
    /**  
     * 关闭连接  
     *  
     * @return bool  
     */  
    function close() {   
        return mysql_close($this->link);   
    }   
    /**  
     * 输出错误信息  
     *  
     * @param string $message  
     * @param string $sql  
     */  
    function halt($message = '', $sql = '') {   
        echo $message . ' ' . $sql;   
        exit;   

    }   
}   
?>  

DISCUZ的PHP MYSQL 操作类,新手参考:等您坐沙发呢!

发表评论

gravatar

快捷键:Ctrl+Enter