国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數據庫 > MySQL > 正文

簡單快速有趣的MySQL數據庫操作類:SimpleDB

2024-07-24 12:56:34
字體:
來源:轉載
供稿:網友
菜鳥學堂:

自己寫著玩的,代碼沒有測試,不過覺得思路不錯,如果能夠加上部分異常處理的功能,應該比較帥了,支持php4/php5,恩,雖然沒有adodb或者pear::db強,不錯一般應用應該不錯,恩。

喜歡的就自己拿去用吧,自己隨便改,呵呵,也歡迎提意見。(注釋遵循phpdoc的標準,便于生成手冊)

 注意:代碼未經測試,出現問題可要自己負責哇,呵呵。

 

 

 

 

<?
//==========================================
// 文件: simpledb.class.php
// 程序: mysql數據庫操作類
// 作者: heiyeluren <http://blog.csdn.net/heiyeshuwu
// 時間: 2006-09-20
//==========================================

class simpledb
{
    /**
     * 連接標識
     * @var resource
     */
    var $dblink;
    /**
     * 數據庫查詢語句
     * @var string
     */
    var $dbsql;
    /**
     * 查詢結果
     * @var resource
     */
    var $dbresult;
    /**
     * 查詢記錄集
     * @var array
     */
    var $dbrecord;
    /**
     * 數據庫字符集
     * @var string
     */
    var $dbcharset = 'gbk';
    /**
     * 數據庫結果集提取方式
     * @var int
     */
    var $fetchmode = mysql_assoc;
    /**
     * 日志保存路徑
     * @var string
     */
    var $logpath = '/tmp/mysql_log';
   
    /**
     * 是否記錄sql查詢失敗的sql日志,缺省是false
     * @var bool
     */
    var $islog = false;
    /**
     * 是否在sql查詢出錯的時候顯示錯誤并且終止腳本執行,缺省是true
     *
     * @var bool
     */
    var $iserror = true;
   
   
    //--------------------------
    // 內部接口
    //--------------------------
    /**
     * 構造函數
     *
     * @param string $db_host 連接主機
     * @param string $db_user 連接用戶
     * @param string $db_passwd 數據庫密碼
     * @param string $db_name 數據庫
     * @param bool $is_pconnect 是否長連接,默認是否
     * @return simpledb
     */
    function simpledb($db_host, $db_user, $db_passwd, $db_name, $is_pconnect=false){
        $this->connect($db_host, $db_user, $db_passwd, $db_name, $is_pconnect);
    }
   
    /**
     * 連接數據庫
     *
     * @param string $db_host  數據庫主機地址,例如:localhost,或者 localhost:3306
     * @param string $db_user 連接數據庫的用戶
     * @param string $db_passwd 用戶密碼
     * @param string $db_name 數據庫名字
     * @param boo $is_pconnect 是否使用長連接
     * @return resource 返回連接資源標識符
     */
    function connect($db_host, $db_user, $db_passwd, $db_name, $is_pconnect){
        if ($is_pconnect){
            return $this->dblink = @mysql_pconnect($db_host, $db_user, $db_passwd);
        }
        $this->dblink = @mysql_connect($db_host, $db_user, $db_passwd);
        @mysql_select_db($db_name, $this->dblink);
        $mysql_version = $this->getone("select version()");
        if ($this->dbcharset!='' && preg_match("/^(5.|4.1)/", $mysql_version)){
            $this->query("set names '$this->dbcharset'", $this->dblink);
        }       
        return $this->dblink;
    }
   
    /**
     * 關閉數據庫連接
     *
     * @return bool 是否成功關閉連接
     */
    function disconnect(){
        $ret = @mysql_close($this->dblink);
        $this->dblink = null;
        return $ret;
    }

    /**
     * 設置查詢結果返回數據類型
     *
     * @param int $modetype 設置查詢結果返回設置,1為關聯索引和數字所有都有,2為使用關聯索引,3為使用數字索引
     */
    function setfetchmode($modetype){
        switch ($modetype){
            case 1:    //數字索引和關聯索引都有
                $this->fetchmode = mysql_both;
                break;
            case 2:    //使用關聯索引
                $this->fetchmode = mysql_assoc;
                break;
            case 3: //使用數字索引
                $this->fetchmode = mysql_num;
                break;
            default://缺省使用關聯索引
                $this->fetchmode = mysql_assoc;
        }
    }
   
    /**
     * 設置數據庫客戶端提取結果集的字符編碼
     *
     * @param string $charset 編碼的字符串,比如 utf8,gbk之類的,缺省是gbk
     */
    function setcharset($charset){
        if ($charset != ''){
            $this->dbcharset = $charset;
        }
    }
   
    /**
     * 設置日志存儲路徑
     *
     * @param string $log_path 日志路徑,該必須是可寫的
     */
    function setlogpath($log_path){
        if ($log_path != ''){
            $this->logpath = $log_path;
        }
    }
   
    /**
     * 寫sql執行日志
     *
     * @param string $sql 查詢的sql語句
     * @param string $file 當前執行查詢的文件
     */
    function writelog($sql, $file){
        if (!file_exists($this->logpath)){
                @mkdir($this->logpath);
        }
        $log_file = $this->logpath ."/mysql_".date("y-m-d").".log";
        $log_msg = "[".date("y-m-d h:i:s")."] - ".$file.": ".$sql." ";
        error_log($log_msg, 3, $log_file);               
    }
   
    /**
     * 顯示上依次sql執行錯誤的錯誤信息
     */
    function showerror(){
        $errmessage = "mysql query error ". mysql_errno($this->dblink) .": ". mysql_error($this->dblink);
        die($errmessage);
    }
   
    /**
     * 返回mysql的版本信息
     *
     * @return string mysql的版本
     */
    function getversion(){
        return $this->getone("select version()");
    }   

    /**
     * 查詢操作的底層接口
     *
     * @param string $sql 要執行查詢的sql語句
     * @return bool 執行成功返回true,失敗返回false
     */
    function query($sql){
        $this->dbsql = $sql;
        $this->dbresult = null;
        $this->dbresult = @mysql_query($sql, $this->dblink);
        if ($this->dbresult === false){
            if ($this->islog){
                $this->writelog($sql, __file__);
            }
            if ($this->iserror){
                $this->showerror();
            }
            return false;
        }
        return true;   
    }    
   

    //--------------------------
    // 數據獲取接口
    //--------------------------
    /**
     * 獲取sql執行的全部結果集(二維數組)
     *
     * @param string $sql 需要執行查詢的sql語句
     * @return 成功返回查詢結果的二維數組,失敗返回false
     */
    function getall($sql){
        if (!$this->query($sql)){
            return false;
        }
        $this->dbrecord = array();
        while ($row = @mysql_fetch_array($this->dbresult, $this->fetchmode)) {
            $this->dbrecord[] = $row;
        }
        @mysql_free_result($this->dbresult);
        if (!is_array($this->dbrecord) || empty($this->dbrecord)){
            return false;
        }
        return $this->dbrecord;
    }
   
    /**
     * 獲取單行記錄(一維數組)
     *
     * @param string $sql 需要執行查詢的sql語句
     * @return 成功返回結果記錄的一維數組,失敗返回false
     */
    function getrow($sql){
        if (!$this->query($sql)){
            return false;
        }
        $this->dbrecord = array();
        $this->dbrecord = @mysql_fetch_array($this->dbresult, $this->fetchmode);
        @mysql_free_result($this->dbresult);
        if (!is_array($this->dbrecord) || empty($this->dbrecord)){
            return false;
        }
        return $this->dbrecord;
    }
   
    /**
     * 獲取一列數據(一維數組)
     *
     * @param string $sql 需要獲取的字符串
     * @param string $field 需要獲取的列,如果不指定,默認是第一列
     * @return 成功返回提取的結果記錄的一維數組,失敗返回false
     */
    function getcol($sql, $field=''){
        if (!$this->query($sql)){
            return false;
        }
        $this->dbrecord = array();
        while($row = @mysql_fetch_array($this->dbresult, $this->fetchmode)){
            if (trim($field) == ''){
                $this->dbrecord[] = current($row);
            } else {
                $this->dbrecord[] = $row[$field];
            }
        }
        @mysql_free_result($this->dbresult);
        if (!is_array($this->dbrecord) || empty($this->dbrecord)){
            return false;
        }
        return $this->dbrecord;       
    }
   
    /**
     * 獲取一個數據(當條數組)
     *
     * @param string $sql 需要執行查詢的sql
     * @return 成功返回獲取的一個數據,失敗返回false
     */
    function getone($sql, $field=''){
        if (!$this->query($sql)){
            return false;
        }
        $this->dbrecord = array();
        $row = @mysql_fetch_array($this->dbresult, $this->fetchmode);
        @mysql_free_result($this->dbresult);
        if (!is_array($row) || empty($row)){
            return false;
        }
        if (trim($field) != ''){
            $this->dbrecord = $row[$field];
        }else{
            $this->dbrecord = current($row);
        }
        return $this->dbrecord;
    }

    /**
     * 獲取指定各種條件的記錄
     *
     * @param string $table 表名(訪問的數據表)
     * @param string $field 字段(要獲取的字段)
     * @param string $where 條件(獲取記錄的條件語句,不包括where,默認為空)
     * @param string $order 排序(按照什么字段排序,不包括order by,默認為空)
     * @param string $limit 限制記錄(需要提取多少記錄,不包括limit,默認為空)
     * @param bool $single 是否只是取單條記錄(是調用getrow還是getall,默認是false,即調用getall)
     * @return 成功返回記錄結果集的數組,失敗返回false
     */
    function getrecord($table, $field='*', $where='', $order='', $limit='', $single=false){
        $sql = "select $field from $table";
        $sql .= trim($where)!='' ? " where $where " : $where;
        $sql .= trim($order)!='' ? " order by $order" : $order;
        $sql .= trim($limit)!='' ? " limit $limit" : $limit;
        if ($single){
            return $this->getrow($sql);
        }
        return $this->getall($sql);
    }
   
    /**
     * 獲取指點各種條件的記錄(跟getrecored類似)
     *
     * @param string $table 表名(訪問的數據表)
     * @param string $field 字段(要獲取的字段)
     * @param string $where 條件(獲取記錄的條件語句,不包括where,默認為空)
     * @param array $order_arr 排序數組(格式類似于: array('id'=>true), 那么就是按照id為順序排序, array('id'=>false), 就是按照id逆序排序)
     * @param array $limit_arr 提取數據的限制數組()
     * @return unknown
     */
    function getspecifyrecord($table, $field='*', $where='', $order_arr=array(), $limit_arr=array()){
        $sql = "select $field from $table";
        $sql .= trim($where)!='' ? " where $where " : $where;
        if (is_array($order_arr) && !empty($order_arr)){
            $arr_key = key($order_arr);
            $sql .= " order by $arr_key " . ($order_arr[$arr_key] ? "asc" : "desc");
        }
        if (is_array($limit_arr) && !empty($limit_arr)){
            $start_post = intval(array_shift($limit_arr));
            $offset = intval(array_shift($limit_arr));
            $sql .= " limit $start_post,$offset";
        }
        return $this->getall($sql);
    }   
   
    /**
     * 獲取指定條數的記錄
     *
     * @param string $table 表名
     * @param int $start_pos 開始記錄
     * @param int $offset 偏移量
     * @param string $field 字段名
     * @param string $where 條件(獲取記錄的條件語句,不包括where,默認為空)
     * @param string $order 排序(按照什么字段排序,不包括order by,默認為空)
     * @return 成功返回包含記錄的二維數組,失敗返回false
     */
    function getlimitrecord($table, $start_pos, $offset, $field='*', $where='', $oder=''){
        $sql = "select $field from $table";
        $sql .= trim($where)!='' ? " where $where " : $where;
        $sql .= trim($order)!='' ? " order by $order" : $order;
        $sql .= "limit $start_pos,$offset";
        return $this->getall($sql);
    }
   
    /**
     * 獲取排序記錄
     *
     * @param string $table 表名
     * @param string $order_field 需要排序的字段(比如id)
     * @param string $order_method 排序的方式(1為順序, 2為逆序, 默認是1)
     * @param string $field 需要提取的字段(默認是*,就是所有字段)
     * @param string $where 條件(獲取記錄的條件語句,不包括where,默認為空)
     * @param string $limit 限制記錄(需要提取多少記錄,不包括limit,默認為空)
     * @return 成功返回記錄的二維數組,失敗返回false
     */
    function getorderrecord($table, $order_field, $order_method=1, $field='*', $where='', $limit=''){
        //$order_method的值為1則為順序, $order_method值為2則2則是逆序排列
        $sql = "select $field from $table";
        $sql .= trim($where)!='' ? " where $where " : $where;
        $sql .= " order by $order_field " . ( $order_method==1 ? "asc" : "desc");
        $sql .= trim($limit)!='' ? " limit $limit" : $limit;
        return $this->getall($sql);
    }
   
    /**
     * 分頁查詢(限制查詢的記錄條數)
     *
     * @param string $sql 需要查詢的sql語句
     * @param int $start_pos 開始記錄的條數
     * @param int $offset 每次的偏移量,需要獲取多少條
     * @return 成功返回獲取結果記錄的二維數組,失敗返回false
     */
    function limitquery($sql, $start_pos, $offset){
        $start_pos = intval($start_pos);
        $offset = intval($offset);
        $sql = $sql . " limit $start_pos,$offset ";
        return $this->getall($sql);
    }   
   
   
    //--------------------------
    // 無數據返回操作
    //--------------------------
    /**
     * 執行執行非select查詢操作
     *
     * @param string $sql 查詢sql語句
     * @return bool  成功執行返回true, 失敗返回false
     */
    function execute($sql){
        if (!$this->query($sql)){
            return false;
        }
        $count = @mysql_affected_rows($this->dblink);
        if ($count <= 0){
            return false;
        }
        return true;
    }
   
    /**
     * 自動執行操作(針對insert/update操作)
     *
     * @param string $table 表名
     * @param array $field_array 字段數組(數組中的鍵相當于字段名,數組值相當于值, 類似 array( 'id' => 100, 'user' => 'heiyeluren')
     * @param int $mode 執行操作的模式 (是插入還是更新操作, 1是插入操作insert, 2是更新操作update)
     * @param string $where 如果是更新操作,可以添加where的條件
     * @return bool 執行成功返回true, 失敗返回false
     */
    function autoexecute($table, $field_array, $mode, $where=''){
        if ($table=='' || !is_array($field_array) || empty($field_array)){
            return false;
        }
        //$mode為1是插入操作(insert), $mode為2是更新操作
        if ($mode == 1){
            $sql = "insert into $table set ";
        }else{
            $sql = "update $table set ";
        }
        foreach ($field_array as $key => $value){
            $sql .= "$key='$value',";
        }
        $sql = rtrim($sql, ',');
        if ($mode==2 && $where!=''){
            $sql .= "where $where";
        }
        return $this->execute($sql);
    }
   
   
    //--------------------------
    // 其他數據相關操作
    //--------------------------
    /**
     * 獲取最后一次查詢的sql語句
     *
     * @return string 返回最后一次查詢的sql語句
     */
    function getlastsql(){
        return $this->dbsql;
    }
       
    /**
     * 獲取上次插入操作的的id
     *
     * @return int 如果沒有連接或者查詢失敗,返回0, 成功返回id
     */
    function getlastid(){
        if (!$this->dblink){
            return 0;
        }
        if (($last_id = mysql_insert_id($this->dblink)) > 0){
            return $last_id;
        }
        return $this->getone("select last_insert_id()");
    }
   
    /**
     * 獲取記錄集里面的記錄條數 (用于select操作)
     *
     * @return int 如果上一次無結果集或者記錄結果集為空,返回0, 否則返回結果集數量
     */
    function getnumrows(){
        if (!$this->dbresult){
            return 0;
        }
        return mysql_num_rows($this->dbresult);
    }
   
    /**
     * 獲取受到影響的記錄數量 (用于update/delete/insert操作)
     *
     * @return int 如果沒有連接或者影響記錄為空, 否則返回影響的行數量
     */
    function getaffectedrows(){
        if (!$this->dblink){
            return 0;
        }
        return mysql_affected_rows($this->dblink);
    }
}
?>

 

 

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 墨玉县| 漠河县| 那曲县| 大冶市| 梅州市| 临洮县| 南昌市| 榆中县| 方正县| 梁山县| 汉寿县| 个旧市| 崇信县| 易门县| 宜章县| 贵南县| 东乡族自治县| 灵宝市| 兴国县| 樟树市| 鲁甸县| 祁门县| 定边县| 永济市| 赤壁市| 白沙| 宁河县| 即墨市| 广昌县| 吉林省| 宝清县| 广德县| 高安市| 渝北区| 电白县| 大姚县| 兰西县| 清苑县| 北票市| 海门市| 三门县|