程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> 關於PHP編程 >> PDO的mysql數據庫操作類

PDO的mysql數據庫操作類

編輯:關於PHP編程

pdo的mysql教程數據庫教程操作類
* dbconfig類負責配置數據庫訪問信息,包括:服務器地址、端口、數據庫實例名、用戶名、用戶密碼、字符集等。
  * dbtemplate類集合了對數據庫的訪問操作,主要有以下幾個操作:
  1. queryrows : 返回多行記錄
  2. queryrow : 返回為單條記錄
  3. queryforint : 查詢單字段,返回整數
  4. queryforfloat : 查詢單字段,返回浮點數(float)
  5. queryfordouble : 查詢單字段,返回浮點數(double)
  6. queryforobject : 查詢單字段,返回對象,實際類型有數據庫決定
  7. update : 執行一條更新語句. insert / upadate / delete

 */

class dbconfig {

    private static $dbms = "mysql";
    private static $host = '127.0.0.1';
    private static $port = '3306';
    private static $username = '';
    private static $password = '';
    private static $dbname = '';
    private static $charset = 'utf-8';
    private static $dsn;

    /**
     *
     * @return   返回pdo dsn配置
     */
    public static function getdsn() {
        if (!isset(self::$dsn)) {
            self::$dsn = self::$dbms . ':host=' . self::$host . ';port=' .
                    self::$port . ';dbname=' . self::$dbname;
            if (strlen(self::$charset) > 0) {
                self::$dsn = self::$dsn . ';charset=' . self::$charset;
            }
        }
        return self::$dsn;
    }

    /**
     * 設置mysql數據庫服務器主機
     * @param  $host 主機的ip地址
     */
    public static function sethost($host) {
        if (isset($host) && strlen($host) > 0)
            self::$host = trim($host);
    }

    /**
     * 設置mysql數據庫服務器的端口
     * @param  $port 端口
     */
    public static function setport($port) {
        if (isset($port) && strlen($port) > 0)
            self::$port = trim($port);
    }

    /**
     * 設置mysql數據庫服務器的登陸用戶名
     * @param  $username
     */
    public static function setusername($username) {
        if (isset($username) && strlen($username) > 0)
            self::$username = $username;
    }

    /**
     * 設置mysql數據庫服務器的登陸密碼
     * @param  $password
     */
    public static function setpassword($password) {
        if (isset($password) && strlen($password) > 0)
            self::$password = $password;
    }

    /**
     * 設置mysql數據庫服務器的數據庫實例名
     * @param  $dbname 數據庫實例名
     */
    public static function setdbname($dbname) {
        if (isset($dbname) && strlen($dbname) > 0)
            self::$dbname = $dbname;
    }

    /**
     * 設置數據庫編碼
     * @param  $charset
     */
    public static function setcharset($charset) {
        if (isset($charset) && strlen($charset) > 0)
            self::$charset = $charset;
    }

}

/**
 * 一個數據庫操作工具類
 *
 * @author [email protected]
 */
class dbtemplate {

    /**
     * 返回多行記錄
     * @param  $sql
     * @param  $parameters
     * @return  記錄數據
     */
    public function queryrows($sql, $parameters = null) {
        return $this->exequery($sql, $parameters);
    }

    /**
     * 返回為單條記錄
     * @param  $sql
     * @param  $parameters
     * @return
     */
    public function queryrow($sql, $parameters = null) {
        $rs = $this->exequery($sql, $parameters);
        if (count($rs) > 0) {
            return $rs[0];
        } else {
            return null;
        }
    }

    /**
     * 查詢單字段,返回整數
     * @param  $sql
     * @param  $parameters
     * @return
     */
    public function queryforint($sql, $parameters = null) {
        $rs = $this->exequery($sql, $parameters);
        if (count($rs) > 0) {
            return intval($rs[0][0]);
        } else {
            return null;
        }
    }

    /**
     * 查詢單字段,返回浮點數(float)
     * @param  $sql
     * @param  $parameters
     * @return
     */
    public function queryforfloat($sql, $parameters = null) {
        $rs = $this->exequery($sql, $parameters);
        if (count($rs) > 0) {
            return floatval($rs[0][0]);
        } else {
            return null;
        }
    }

    /**
     * 查詢單字段,返回浮點數(double)
     * @param  $sql
     * @param  $parameters
     * @return
     */
    public function queryfordouble($sql, $parameters = null) {
        $rs = $this->exequery($sql, $parameters);
        if (count($rs) > 0) {
            return doubleval($rs[0][0]);
        } else {
            return null;
        }
    }

    /**
     * 查詢單字段,返回對象,實際類型有數據庫決定
     * @param  $sql
     * @param  $parameters
     * @return
     */
    public function queryforobject($sql, $parameters = null) {
        $rs = $this->exequery($sql, $parameters);
        if (count($rs) > 0) {
            return $rs[0][0];
        } else {
            return null;
        }
    }

    /**
     * 執行一條更新語句.insert / upadate / delete
     * @param  $sql
     * @param  $parameters
     * @return  影響行數
     */
    public function update($sql, $parameters = null) {
        return $this->exeupdate($sql, $parameters);
    }

    private function getconnection() {
        $conn = new pdo(dbconfig::getdsn(), dbconfig::getusername(), dbconfig::getpassword());
        $conn->setattribute(pdo::attr_case, pdo::case_upper);
        return $conn;
    }

    private function exequery($sql, $parameters = null) {
        $conn = $this->getconnection();
        $stmt = $conn->prepare($sql);
        $stmt->execute($parameters);
        $rs = $stmt->fetchall();
        $stmt = null;
        $conn = null;
        return $rs;
    }

    private function exeupdate($sql, $parameters = null) {
        $conn = $this->getconnection();
        $stmt = $conn->prepare($sql);
        $stmt->execute($parameters);
        $affectedrows = $stmt->rowcount();
        $stmt = null;
        $conn = null;
        return $affectedrows;
    }
}


/*
pdo始於php教程5,php6中將默認使用pdo。不同於以前版本中混亂的數據庫操作方式,pdo統一了對數據庫的訪問方式,給編程帶來了極大的便利性。本工具類就是基於pdo,模擬了java世界spring框架中的jdbctemplate操作類
 */

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved