PHP實現(xiàn)PDO的mysql數(shù)據(jù)庫操作類
本文實例講述了PHP實現(xiàn)PDO的mysql數(shù)據(jù)庫操作類。分享給大家供大家參考。具體分析如下:
dbconfig類負(fù)責(zé)配置數(shù)據(jù)庫訪問信息,包括:服務(wù)器地址、端口、數(shù)據(jù)庫實例名、用戶名、用戶密碼、字符集等.
dbtemplate類集合了對數(shù)據(jù)庫的訪問操作,主要有以下幾個操作:
1. queryrows:返回多行記錄
2. queryrow:返回為單條記錄
3. queryforint:查詢單字段,返回整數(shù)
4. queryforfloat:查詢單字段,返回浮點數(shù)(float)
5. queryfordouble:查詢單字段,返回浮點數(shù)(double)
6. queryforobject:查詢單字段,返回對象,實際類型有數(shù)據(jù)庫決定
7. update : 執(zhí)行一條更新語句. insert / upadate / delete
具體代碼如下:
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;
}
/**
* 設(shè)置mysql數(shù)據(jù)庫服務(wù)器主機
* @param $host 主機的ip地址
*/
public static function sethost($host) {
if (isset($host) && strlen($host) > 0)
self::$host = trim($host);
}
/**
* 設(shè)置mysql數(shù)據(jù)庫服務(wù)器的端口
* @param $port 端口
*/
public static function setport($port) {
if (isset($port) && strlen($port) > 0)
self::$port = trim($port);
}
/**
* 設(shè)置mysql數(shù)據(jù)庫服務(wù)器的登陸用戶名
* @param $username
*/
public static function setusername($username) {
if (isset($username) && strlen($username) > 0)
self::$username = $username;
}
/**
* 設(shè)置mysql數(shù)據(jù)庫服務(wù)器的登陸密碼
* @param $password
*/
public static function setpassword($password) {
if (isset($password) && strlen($password) > 0)
self::$password = $password;
}
/**
* 設(shè)置mysql數(shù)據(jù)庫服務(wù)器的數(shù)據(jù)庫實例名
* @param $dbname 數(shù)據(jù)庫實例名
*/
public static function setdbname($dbname) {
if (isset($dbname) && strlen($dbname) > 0)
self::$dbname = $dbname;
}
/**
* 設(shè)置數(shù)據(jù)庫編碼
* @param $charset
*/
public static function setcharset($charset) {
if (isset($charset) && strlen($charset) > 0)
self::$charset = $charset;
}
}
/**
* 一個數(shù)據(jù)庫操作工具類
*
* @author zhjiun@gmail.com
*/
class dbtemplate {
/**
* 返回多行記錄
* @param $sql
* @param $parameters
* @return 記錄數(shù)據(jù)
*/
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;
}
}
/**
* 查詢單字段,返回整數(shù)
* @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;
}
}
/**
* 查詢單字段,返回浮點數(shù)(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;
}
}
/**
* 查詢單字段,返回浮點數(shù)(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;
}
}
/**
* 查詢單字段,返回對象,實際類型有數(shù)據(jù)庫決定
* @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;
}
}
/**
* 執(zhí)行一條更新語句.insert / upadate / delete
* @param $sql
* @param $parameters
* @return 影響行數(shù)
*/
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始于php5,php6中將默認(rèn)使用pdo,不同于以前版本中混亂的數(shù)據(jù)庫操作方式,pdo統(tǒng)一了對數(shù)據(jù)庫的訪問方式,給編程帶來了極大的便利性,本工具類就是基于pdo,模擬了java世界spring框架中的jdbctemplate操作類.
希望本文所述對大家的PHP程序設(shè)計有所幫助。
- php使用mysqli和pdo擴展,測試對比連接mysql數(shù)據(jù)庫的效率完整示例
- php中mysql連接方式PDO使用詳解
- php mysql PDO 查詢操作的實例詳解
- 全新的PDO數(shù)據(jù)庫操作類php版(僅適用Mysql)
- php中數(shù)據(jù)庫連接方式pdo和mysqli對比分析
- PHP基于pdo的數(shù)據(jù)庫操作類【可支持mysql、sqlserver及oracle】
- php使用PDO操作MySQL數(shù)據(jù)庫實例
- PHP使用PDO創(chuàng)建MySQL數(shù)據(jù)庫、表及插入多條數(shù)據(jù)操作示例
- php使用mysqli和pdo擴展,測試對比mysql數(shù)據(jù)庫的執(zhí)行效率完整示例
- PHP連接MySQL數(shù)據(jù)庫的三種方式實例分析【mysql、mysqli、pdo】
相關(guān)文章
php 調(diào)用ffmpeg獲取視頻信息的簡單實現(xiàn)
下面小編就為大家?guī)硪黄猵hp 調(diào)用ffmpeg獲取視頻信息的簡單實現(xiàn)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-04-04php中XMLHttpRequest(Ajax)不能設(shè)置自定義的Referer的解決方法
php中XMLHttpRequest(Ajax)不能設(shè)置自定義的Referer的解決方法,需要的朋友可以參考下。2011-11-11