一個PDO操作類

<?php

/*
*    Author: AthrunSoft
*    class.pdomysql.php 0.01 2012-4-15
*/
class pdomysql {
    public static $dbtype = 'mysql';
    public static $dbhost = '';
    public static $dbport = '';
    public static $dbname = '';
    public static $dbuser = '';
    public static $dbpass = '';
    public static $charset = '';
    public static $stmt = null;
    public static $DB = null;
    public static $connect = true; //是否長連接
   public static $debug = false;
    private static $parms = array();

    /**
     * 構造函數
     */
    public function __construct() {
        self::$dbtype = 'mysql';
        self::$dbhost = DBHOST;
        self::$dbport = DBPORT;
        self::$dbname = DBNAME;
        self::$dbuser = DBUSER;
        self::$dbpass = DBPASS;
        self::$connect = ISCONNECT;
        self::$charset = CHARSET;
        self::connect();
        self::$DB->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
        self::$DB->setAttribute(PDO::ATTR_EMULATE_PREPARES, true);
        self::execute('SET NAMES ' . self::$charset);
    }
    /**
     *析構函數
     */
    public function __destruct() {
        self::close();
    }


    /*********************基本方法開始*********************/
    /**
     * 作用:連結資料庫
     */
    public function connect() {
        try {
            self::$DB = new PDO(self::$dbtype . ':host=' . self::$dbhost . ';port=' . self::
                $dbport . ';dbname=' . self::$dbname, self::$dbuser, self::$dbpass, array(PDO::
                ATTR_PERSISTENT => self::$connect));
        }
        catch (PDOException $e) {
            die("Connect Error Infomation:" . $e->getMessage());
        }
    }

    /**
     *關閉資料連接
     */
    public function close() {
        self::$DB = null;
    }

    /**
     * 對字串進行轉義
     */
    public function quote($str) {
        return self::$DB->quote($str);
    }

    /**
     * 返回一個日期時間字符
     */
    public function now() {
        return date("Y-m-d H:i:s");
    }
    /**
     * 作用:獲取當前庫的所有表名
     * 返回:當前庫的所有表名
     * 類型:陣列
     */
    public function getTablesName() {
        self::$stmt = self::$DB->query('SHOW TABLES FROM ' . self::$dbname);
        $result = self::$stmt->fetchAll(PDO::FETCH_NUM);
        self::$stmt = null;
        return $result;
    }

    /**
     * 作用:獲取資料表裡的欄位
     * 返回:表字段結構
     * 類型:陣列
     */
    public function getFields($table) {
        self::$stmt = self::$DB->query("DESCRIBE $table");
        $result = self::$stmt->fetchAll(PDO::FETCH_ASSOC);
        self::$stmt = null;
        return $result;
    }

    /**
     * 作用:獲得最後INSERT的主鍵ID
     * 返回:最後INSERT的主鍵ID
     * 類型:數字
     */
    public function getLastId() {
        return self::$DB->lastInsertId();
    }

    /**
     *事務開始
     */
    public function autocommit() {
        self::$DB->beginTransaction();
    }

    /**
     *事務提交
     */
    public function commit() {
        self::$DB->commit();
    }

    /**
     *交易復原
     */
    public function rollback() {
        self::$DB->rollback();
    }

    /**
     * 作用:執行INSERT\UPDATE\DELETE
     * 返回:執行語句影響行數
     * 類型:數字
     */
    public function execute($sql) {
        self::getPDOError($sql);
        return self::$DB->exec($sql);
    }

    /**
     * 獲取要操作的資料
     * 返回:合併後的SQL語句
     * 類型:字串
     */
    private function getCode($table, $args) {
        $code = '';
        if (is_array($args)) {
            foreach ($args as $k => $v) {
                if ($v == '') {
                    continue;
                }
                $code .= "`$k`='$v',";
            }
        }
        $code = substr($code, 0, -1);
        return $code;
    }

    /**
     * 執行具體SQL操作
     * 返回:運行結果
     * 類型:陣列或數位
     */
    private function _fetch($sql, $type) {
        $result = array();
        self::$stmt = self::$DB->query($sql);
        self::getPDOError($sql);
        self::$stmt->setFetchMode(PDO::FETCH_ASSOC);
        switch ($type) {
            case '0':
                $result = self::$stmt->fetch();
                break;
            case '1':
                $result = self::$stmt->fetchAll();
                break;
            case '2':
                if ($sql) {
                    $result = self::$stmt->fetchColumn();
                } elseif (self::$stmt) {
                    $result = self::$stmt->rowCount();
                } else {
                    $result = 0;
                }
                break;
        }
        self::$stmt = null;
        return $result;
    }

    /**
     * 分頁計算
     */
    private function count($pagesize, &$page, &$pagecount, &$recordcount) {
        //獲取記錄行數,計算頁數,以及重新檢查當前頁碼
        $pagecount = ceil($recordcount / $pagesize);
        if ($pagecount > 0) {
            if ($page > $pagecount) {
                $page = $pagecount;
            } elseif ($page < 1) {
                $page = 1;
            }
        } else {
            $page = 1;
        }
    }
    /*********************基本方法結束*********************/


    /*********************Sql操作方法開始*********************/
    /**
     * 作用:插入資料
     * 返回:表內記錄
     * 類型:陣列
     * 參數:$db->insert('$table',array('title'=>'Zxsv'))
     */
    public function add($table, $args) {
        $sql = "INSERT INTO `$table` SET ";
        $code = self::getCode($table, $args);
        $sql .= $code;
        return self::execute($sql);
    }

    /**
     * 修改資料
     * 返回:記錄數
     * 類型:數字
     * 參數:$db->update($table,array('title'=>'Zxsv'),array('id'=>'1'),$where ='id=3');
     */
    public function update($table, $args, $where) {
        $code = self::getCode($table, $args);
        $sql = "UPDATE `$table` SET ";
        $sql .= $code;
        $sql .= " Where $where";
        return self::execute($sql);
    }

    /**
     * 作用:刪除資料
     * 返回:表內記錄
     * 類型:陣列
     * 參數:$db->delete($table,$condition = null,$where ='id=3')
     */
    public function delete($table, $where) {
        $sql = "DELETE FROM `$table` Where $where";
        return self::execute($sql);
    }

    /**
     * 作用:獲取單行資料
     * 返回:表內第一條記錄
     * 類型:陣列
     * 參數:$db->fetOne($table,$condition = null,$field = '*',$where ='')
     */
    public function fetOne($table, $field = '*', $where = false) {
        $sql = "SELECT {$field} FROM `{$table}`";
        $sql .= ($where) ? " WHERE $where" : '';
        return self::_fetch($sql, $type = '0');
    }

    /**
     * 作用:獲取單行資料
     * 返回:表內第一條記錄
     * 類型:陣列
     * 參數:select * from table where id='1'
     */
    public function getOne($sql) {
        return self::_fetch($sql, $type = '0');
    }
    /**
     * 作用:獲取首行首列資料
     * 返回:首行首列欄位值
     * 類型:值
     * 參數:select `a` from table where id='1'
     */
    public function scalar($sql, $fieldname) {
        $row = self::_fetch($sql, $type = '0');
        return $row[$fieldname];
    }
    /**
     * 獲取記錄總數
     * 返回:記錄數
     * 類型:數字
     * 參數:$db->fetRow('$table',$condition = '',$where ='');
     */
    public function fetRowCount($table, $field = '*', $where = false) {
        $sql = "SELECT COUNT({$field}) AS num FROM `$table`";
        $sql .= ($where) ? " WHERE $where" : '';
        return self::_fetch($sql, $type = '2');
    }

    /**
     * 獲取記錄總數
     * 返回:記錄數
     * 類型:數字
     * 參數:select count(*) from table
     */
    public function getRowCount($sql) {
        return self::_fetch($sql, $type = '2');
    }
    /**
     * 作用:獲取所有資料
     * 返回:表內記錄
     * 類型:二維陣列
     * 參數:$db->fetAll('$table',$condition = '',$field = '*',$orderby = '',$limit = '',$where='')
     */
    public function fetAll($table, $field = '*', $orderby = false, $where = false) {
        $sql = "SELECT {$field} FROM `{$table}`";
        $sql .= ($where) ? " WHERE $where" : '';
        $sql .= ($orderby) ? " ORDER BY $orderby" : '';
        return self::_fetch($sql, $type = '1');
    }
    /**
     * 作用:獲取分頁資料
     * 返回:表內記錄
     * 類型:二維陣列
     */
    public function fetPageAll($table, $field = '*', $where = false, $orderby = false,
        $pagesize, &$page, &$pagecount, &$recordcount) {
        $sql = "SELECT {$field} FROM `{$table}`";
        $sql .= ($where) ? " WHERE $where" : '';
        return self::getPageAll($sql, $orderby, $pagesize, $page, $pagecount, $recordcount);
    }
    /**
     * 作用:獲取所有資料
     * 返回:表內記錄
     * 類型:二維陣列
     * 參數:select * from table
     */
    public function getAll($sql) {
        return self::_fetch($sql, $type = '1');
    }

    /**
     * 作用:獲取分頁資料
     * 返回:表內記錄
     * 類型:二維陣列
     */
    public function getPageAll($sql, $orderby = false, $pagesize, &$page, &$pagecount,
        &$recordcount) {
        $sqlcount = "select count(1) as `recordcount` from ($sql) as t;";
        $recordcount = self::scalar($sqlcount, 'recordcount');
        self::count($pagesize, $page, $pagecount, $recordcount);
        $start = ($page - 1) * $pagesize;
        $sql .= ($orderby) ? " ORDER BY $orderby" : '';
        $sql .= " limit $start,$pagesize";
        return self::_fetch($sql, $type = '1');
    }
    /*********************Sql操作方法結束*********************/

    /*********************Pram操作方法開始*********************/
    /**
     * 作用:獲取單行資料
     * 返回:表內第一條記錄
     * 類型:陣列
     */
    public function pramGetOne($sql, $input_parameters) {
        return self::_pramfetch($sql, $input_parameters, $type = '0');
    }
    /**
     * 作用:獲取所有資料
     * 返回:表內記錄
     * 類型:二維陣列
     */
    public function pramGetAll($sql, $input_parameters) {
        return self::_pramfetch($sql, $input_parameters, $type = '1');
    }
    /**
     * 作用:執行帶參數SQL操作
     * 返回:執行語句影響行數
     * 類型:數字
     */
    public function pramExecute($sql, $input_parameters) {
        return self::_pramfetch($sql, $input_parameters, $type = '2');
    }
    /**
     * 作用:獲取首行首列資料
     * 返回:首行首列欄位值
     * 類型:值
     */
    public function pramScalar($sql, $input_parameters, $fieldname) {
        $row = self::_pramfetch($sql, $input_parameters, $type = '0');
        return $row[$fieldname];
    }
    /**
     * 執行帶參數SQL操作
     * 返回:運行結果
     * 類型:陣列或數位
     */
    private function _pramfetch($sql, $input_parameters, $type) {
        $result = array();
        self::$stmt = self::$DB->prepare($sql);
        self::getPDOError($sql);
        self::$stmt->execute($input_parameters);
        self::getSTMTError($sql);
        self::$stmt->setFetchMode(PDO::FETCH_ASSOC);
        switch ($type) {
            case '0':
                $result = self::$stmt->fetch();
                break;
            case '1':
                $result = self::$stmt->fetchAll();
                break;
            case '2':
                if (self::$stmt) {
                    $result = self::$stmt->rowCount();
                } else {
                    $result = 0;
                }
                break;
        }
        self::$stmt = null;
        return $result;
    }
    /*********************Pram操作方法結束*********************/


    /*********************Proc操作方法開始*********************/
    /**
     * 添加參數
     */
    public function pramadd($parameter, $variable, $data_type, $length) {
        array_push(self::$parms, array($parameter, $variable, $data_type, $length));
    }
    /**
     * 清除所有參數
     */
    public function pramclear() {
        self::$parms = array();
    }
    /**
     * 作用:獲取單行資料
     * 返回:表內第一條記錄
     * 類型:陣列
     */
    public function procGetOne($sql) {
        return self::_procfetch($sql, $type = '0');
    }
    /**
     * 作用:獲取所有資料
     * 返回:表內記錄
     * 類型:二維陣列
     */
    public function procGetAll($sql) {
        return self::_procfetch($sql, $type = '1');
    }
    /**
     * 作用:執行一個存儲過程
     * 返回:執行語句影響行數
     * 類型:數字
     */
    public function procExecute($sql) {
        return self::_procfetch($sql, $type = '2');
    }
    /**
     * 作用:獲取out型的return
     */
    public function getReturn() {
        return self::scalar("select @ireturn AS iReturn", "iReturn");
    }
    /**
     * 執行帶參數SQL操作
     * 返回:運行結果
     * 類型:陣列或數位
     */
    private function _procfetch($sql, $type) {
        $result = array();
        self::$stmt = self::$DB->prepare($sql);
        self::getPDOError($sql);
        foreach (self::$parms as $pram) {
            self::$stmt->bindParam($pram[0], $pram[1], $pram[2], $pram[3]);
        }
        self::$stmt->execute();
        self::getSTMTError($sql);
        self::$stmt->setFetchMode(PDO::FETCH_ASSOC);
        switch ($type) {
            case '0':
                $result = self::$stmt->fetch();
                break;
            case '1':
//                do{
//                    $result[] = self::$stmt->fetchAll();
//                } while (self::$stmt->nextRowset());
                $result = self::$stmt->fetchAll();
                self::$stmt->closeCursor();
                break;
            case '2':
                if (self::$stmt) {
                    $result = self::$stmt->rowCount();
                } else {
                    $result = 0;
                }
                break;
        }
        self::$stmt = null;
        return $result;
    }
    
    /**
     * 權為測試使用,目前沒有辦法獲取到OUT參數.
     * 另外在一存講過程中若有rowset,同時還有OUT參數時,
     * 即使$db->scalar("select @Rcount AS Rcount", "Rcount")這种方式仍然獲到不到,
     * 執行時會出現下面的錯誤:
     * Cannot execute queries while other unbuffered queries are active. Consider using PDOStatement::fetchAll(). Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute.
     */
    public function procExecOut() {
        //$colour = 'red';
        self::$stmt = self::$DB->prepare('CALL puree_fruit(?)');
        self::$stmt->bindParam(1, $colour,PDO::PARAM_STR|PDO::PARAM_INPUT_OUTPUT, 4000);
        self::$stmt->execute();
        print("After pureeing fruit, the colour is: $colour");
    }
    /*********************Proc操作方法結束*********************/


    /*********************錯誤處理開始*********************/

    /**
     * 設置是否為調試模式
     */
    public function setDebugMode($mode = true) {
        return ($mode == true) ? self::$debug = true : self::$debug = false;
    }

    /**
     * 捕獲PDO錯誤資訊
     * 返回:出錯資訊
     * 類型:字串
     */
    private function getPDOError($sql) {
        self::$debug ? self::errorfile($sql) : '';
        if (self::$DB->errorCode() != '00000') {
            $info = (self::$stmt) ? self::$stmt->errorInfo() : self::$DB->errorInfo();
            echo (self::sqlError('mySQL Query Error', $info[2], $sql));
            exit();
        }
    }
    private function getSTMTError($sql) {
        self::$debug ? self::errorfile($sql) : '';
        if (self::$stmt->errorCode() != '00000') {
            $info = (self::$stmt) ? self::$stmt->errorInfo() : self::$DB->errorInfo();
            echo (self::sqlError('mySQL Query Error', $info[2], $sql));
            exit();
        }
    }

    /**
     * 寫入錯誤日志
     */
    private function errorfile($sql) {
        echo $sql . '<br />';
        $errorfile = _ROOT . './dberrorlog.php';
        $sql = str_replace(array("\n", "\r", "\t", "  ", "  ", "  "), array(" ", " ",
            " ", " ", " ", " "), $sql);
        if (!file_exists($errorfile)) {
            $fp = file_put_contents($errorfile, "<?PHP exit('Access Denied'); ?>\n" . $sql);
        } else {
            $fp = file_put_contents($errorfile, "\n" . $sql, FILE_APPEND);
        }

    }

    /**
     * 作用:運行錯誤資訊
     * 返回:運行錯誤資訊和SQL語句
     * 類型:字元
     */
    private function sqlError($message = '', $info = '', $sql = '') {
        $html = '<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"><html xmlns="http://www.w3.org/1999/xhtml">';
        $html .= '<head><title>mySQL Message</title><style type="text/css">body {margin:0px;color:#555555;font-size:12px;background-color:#efefef;font-family:Verdana} ol {margin:0px;padding:0px;} .w {800px;margin:100px auto;padding:0px;border:1px solid #cccccc;background-color:#ffffff;} .h {padding:8px;background-color:#ffffcc;} li {height:auto;padding:5px;line-height:22px;border-top:1px solid #efefef;list-style:none;overflow:hidden;}</style></head>';
        $html .= '<body><div class="w"><ol>';
        if ($message) {
            $html .= '<div class="h">' . $message . '</div>';
        }
        $html .= '<li>Date: ' . date('Y-n-j H:i:s', time()) . '</li>';
        if ($info) {
            $html .= '<li>SQLID: ' . $info . '</li>';
        }
        if ($sql) {
            $html .= '<li>Error: ' . $sql . '</li>';
        }
        $html .= '</ol></div></body></html>';
        return $html;
    }
    /*********************錯誤處理結束*********************/
}

?>

此类还有两个问题没有处理(基本也可以使用)：

１，在调用有out／inout参数的mysql存储过程时，没有办法像下面这样获取参数值，以下方法是官方的demo，可在我电脑上却从来没有获取到相应的值．

/* Call a stored procedure with an INOUT parameter */
$colour = 'red';
$sth = $dbh->prepare('CALL puree_fruit(?)');
$sth->bindParam(1, $colour, PDO::PARAM_STR|PDO::PARAM_INPUT_OUTPUT, 12);
$sth->execute();
print("After pureeing fruit, the colour is: $colour");

２，因为上面没有办法用PDO::PARAM_INPUT_OUTPUT的方式来获到out值．因此我改以下面的方式处理．结果又遇到另一个错误．好像是说没办法返回多个rowset的问题．

$db->pramclear();
$db->pramadd(1, 3, PDO::PARAM_INT,4,false);
$db->procGetAll("CALL UP_Banner_GetList(?,@Rcount);");
$db->scalar("select @Rcount AS Rcount", "Rcount");

错误信息：

Cannot execute queries while other unbuffered queries are active. Consider using PDOStatement::fetchAll(). Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute.

以上两个问题点在网上也找了很多资料，有的说是php的bug，也有的说在linux机器上不会有这样的问题．弄了这几天总的感觉是对pdo挺失望的．原以为自己可以封装好一个操作类，方便以后使用．希望哪位高手如果有也有此经历，请留言告之在下如何解决．谢谢!