PHP的PDO常用類庫(kù)實(shí)例分析
更新時(shí)間：2016年04月07日 11:16:41 作者：ruxingli
這篇文章主要介紹了PHP的PDO常用類庫(kù),結(jié)合實(shí)例形式分析了PDO類庫(kù)常見(jiàn)的連接,初始化及增刪改查等操作技巧,需要的朋友可以參考下
本文實(shí)例講述了PHP的PDO常用類庫(kù)。分享給大家供大家參考，具體如下：
1、Db.class.php 連接數(shù)據(jù)庫(kù)
<?php
// 連接數(shù)據(jù)庫(kù)
class Db {
static public function getDB() {
try {
$pdo = new PDO(DB_DSN, DB_USER, DB_PWD);
$pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 設(shè)置數(shù)據(jù)庫(kù)連接為持久連接
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 設(shè)置拋出錯(cuò)誤
$pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true); // 設(shè)置當(dāng)字符串為空轉(zhuǎn)換為 SQL 的 NULL
$pdo->query('SET NAMES utf8'); // 設(shè)置數(shù)據(jù)庫(kù)編碼
} catch (PDOException $e) {
exit('數(shù)據(jù)庫(kù)連接錯(cuò)誤，錯(cuò)誤信息：'. $e->getMessage());
}
return $pdo;
}
}
?>
2、Model.class.php 數(shù)據(jù)庫(kù)操作類
<?php
/**
* 數(shù)據(jù)庫(kù)操作類庫(kù)
* author Lee.
* Last modify $Date: 2012-1-19 13:59；04 $
*/
class M {
private $_db; //數(shù)據(jù)庫(kù)句柄
public $_sql; //SQL語(yǔ)句
/**
* 構(gòu)造方法
*/
public function __construct() {
$this->_db = Db::getDB();
}
/**
* 數(shù)據(jù)庫(kù)添加操作
* @param string $tName 表名
* @param array $field 字段數(shù)組
* @param array $val 值數(shù)組
* @param bool $is_lastInsertId 是否返回添加ID
* @return int 默認(rèn)返回成功與否，$is_lastInsertId 為true，返回添加ID
*/
public function insert($tName, $fields, $vals, $is_lastInsertId=FALSE) {
try {
if (!is_array($fields) || !is_array($vals))
exit($this->getError(__FUNCTION__, __LINE__));
$fields = $this->formatArr($fields);
$vals = $this->formatArr($vals, false);
$tName = $this->formatTabName($tName);
$this->_sql = "INSERT INTO {$tName} ({$fields}) VALUES ({$vals})";
if (!$is_lastInsertId) {
$row = $this->_db->exec($this->_sql);
return $row;
} else {
$this->_db->exec($this->_sql);
$lastId = (int)$this->_db->lastInsertId();
return $lastId;
}
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 數(shù)據(jù)庫(kù)修改操作
* @param string $tName 表名
* @param array $field 字段數(shù)組
* @param array $val 值數(shù)組
* @param string $condition 條件
* @return int 受影響的行數(shù)
*/
public function update($tName, $fieldVal, $condition) {
try {
if (!is_array($fieldVal) || !is_string($tName) || !is_string($condition))
exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$upStr = '';
foreach ($fieldVal as $k=>$v) {
$upStr .= '`'.$k . '`=' . '\'' . $v . '\'' . ',';
}
$upStr = rtrim($upStr, ',');
$this->_sql = "UPDATE {$tName} SET {$upStr} WHERE {$condition}";
$row = $this->_db->exec($this->_sql);
return $row;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 數(shù)據(jù)庫(kù)刪除操作（注：必須添加 where 條件）
* @param string $tName 表名
* @param string $condition 條件
* @return int 受影響的行數(shù)
*/
public function del($tName, $condition) {
try {
if (!is_string($tName) || !is_string($condition))
exit($this->getError(__FUNCTION__, __LINE__));
$tName= $this->formatTabName($tName);
$this->_sql = "DELETE FROM {$tName} WHERE {$condition}";
$row = $this->_db->exec($this->_sql);
return $row;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 返回表總個(gè)數(shù)
* @param string $tName 表名
* @param string $condition 條件
* @return int
*/
public function total($tName, $condition='') {
try {
if (!is_string($tName))
exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$this->_sql = "SELECT COUNT(*) AS total FROM {$tName}" .
($condition=='' ? '' : ' WHERE ' . $condition);
$re = $this->_db->query($this->_sql);
foreach ($re as $v) {
$total = $v['total'];
}
return (int)$total;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 數(shù)據(jù)庫(kù)刪除多條數(shù)據(jù)
* @param string $tName 表名
* @param string $field 依賴字段
* @param array $ids 刪除數(shù)組
* @return int 受影響的行數(shù)
*/
public function delMulti($tName, $field, $ids) {
try {
if (!is_string($tName) || !is_array($ids))
exit($this->getError(__FUNCTION__, __LINE__));
$delStr = '';
$tName = $this->formatTabName($tName);
$field = $this->formatTabName($field);
foreach ($ids as $v) {
$delStr .= $v . ',';
}
$delStr = rtrim($delStr, ',');
$this->_sql = "DELETE FROM {$tName} WHERE {$field} IN ({$delStr})";
$row = $this->_db->exec($this->_sql);
return $row;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 獲取表格的最后主鍵（注：針對(duì) INT 類型）
* @param string $tName 表名
* @return int
*/
public function insertId($tName) {
try {
if (!is_string($tName))
exit($this->getError(__FUNCTION__, __LINE__));
$this->_sql = "SHOW TABLE STATUS LIKE '{$tName}'";
$result = $this->_db->query($this->_sql);
$insert_id = 0;
foreach ($result as $v) {
$insert_id = $v['Auto_increment'];
}
return (int)$insert_id;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 檢查數(shù)據(jù)是否已經(jīng)存在（依賴條件）
* @param string $tName 表名
* @param string $field 依賴的字段
* @return bool
*/
public function exists($tName, $condition) {
try {
if (!is_string($tName) || !is_string($condition))
exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$condition}";
$result = $this->_db->query($this->_sql);
foreach ($result as $v) {
$b = $v['total'];
}
if ($b) {
return true;
} else {
return false;
}
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 檢查數(shù)據(jù)是否已經(jīng)存在（依賴 INT 主鍵）
* @param string $tName 表名
* @param string $primary 主鍵
* @param int $id 主鍵值
* @return bool
*/
public function existsByPK($tName, $primary, $id) {
try {
if (!is_string($tName) || !is_string($primary)
|| !is_int($id))
exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$primary} = ". $id;
$result = $this->_db->query($this->_sql);
foreach ($result as $v) {
$b = $v['total'];
}
if ($b) {
return true;
} else {
return false;
}
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 預(yù)處理刪除（注：針對(duì)主鍵為 INT 類型，推薦使用）
* @param string $tName 表名
* @param string $primary 主鍵字段
* @param int or array or string $ids 如果是刪除一條為 INT，多條為 array，刪除一個(gè)范圍為 string
* @return int 返回受影響的行數(shù)
*/
public function delByPK($tName, $primary, $ids, $mult=FALSE) {
try {
if (!is_string($tName) || !is_string($primary)
|| (!is_int($ids) && !is_array($ids) && !is_string($ids))
|| !is_bool($mult)) exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$stmt = $this->_db->prepare("DELETE FROM {$tName} WHERE {$primary}=?");
if (!$mult) {
$stmt->bindParam(1, $ids);
$row = $stmt->execute();
} else {
if (is_array($ids)) {
$row = 0;
foreach ($ids as $v) {
$stmt->bindParam(1, $v);
if ($stmt->execute()) {
$row++;
}
}
} elseif (is_string($ids)) {
if (!strpos($ids, '-'))
exit($this->getError(__FUNCTION__, __LINE__));
$split = explode('-', $ids);
if (count($split)!=2 || $split[0]>$split[1])
exit($this->getError(__FUNCTION__, __LINE__));
$i = null;
$count = $split[1]-$split[0]+1;
for ($i=0; $i<$count; $i++) {
$idArr[$i] = $split[0]++;
}
$idStr = '';
foreach ($idArr as $id) {
$idStr .= $id . ',';
}
$idStr = rtrim($idStr, ',');
$this->_sql ="DELETE FROM {$tName} WHERE {$primary} in ({$idStr})";
$row = $this->_db->exec($this->_sql);
}
}
return $row;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 返回單個(gè)字段數(shù)據(jù)或單條記錄
* @param string $tName 表名
* @param string $condition 條件
* @param string or array $fields 返回的字段，默認(rèn)是*
* @return string || array
*/
public function getRow($tName, $condition='', $fields="*") {
try {
if (!is_string($tName) || !is_string($condition)
|| !is_string($fields) || empty($fields))
exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$this->_sql = "SELECT {$fields} FROM {$tName} ";
$this->_sql .= ($condition=='' ? '' : "WHERE {$condition}") . " LIMIT 1";
$sth = $this->_db->prepare($this->_sql);
$sth->execute();
$result = $sth->fetch(PDO::FETCH_ASSOC);
if ($fields === '*') {
return $result;
} else {
return $result[$fields];
}
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 返回多條數(shù)據(jù)
* @param string $tName 表名
* @param string $fields 返回字段，默認(rèn)為*
* @param string $condition 條件
* @param string $order 排序
* @param string $limit 顯示個(gè)數(shù)
* @return PDOStatement
*/
public function getAll($tName, $fields='*', $condition='', $order='', $limit='') {
try {
if (!is_string($tName) || !is_string($fields)
|| !is_string($condition) || !is_string($order)
|| !is_string($limit))
exit($this->getError(__FUNCTION__, __LINE__));
$tName = $this->formatTabName($tName);
$fields = ($fields=='*' || $fields=='') ? '*' : $fields;
$condition = $condition=='' ? '' : " WHERE ". $condition ;
$order = $order=='' ? '' : " ORDER BY ". $order;
$limit = $limit=='' ? '' : " LIMIT ". $limit;
$this->_sql = "SELECT {$fields} FROM {$tName} {$condition} {$order} {$limit}";
$sth = $this->_db->prepare($this->_sql);
$sth->execute();
$result = $sth->fetchAll(PDO::FETCH_ASSOC);
return $result;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
/**
* 格式化數(shù)組（表結(jié)構(gòu)和值）
* @param array $field
* @param bool $isField
* @return string
*/
private function formatArr($field, $isField=TRUE) {
if (!is_array($field)) exit($this->getError(__FUNCTION__, __LINE__));
$fields = '';
if ($isField) {
foreach ($field as $v) {
$fields .= '`'.$v.'`,';
}
} else {
foreach ($field as $v) {
$fields .= '\''.$v.'\''.',';
}
}
$fields = rtrim($fields, ',');
return $fields;
}
/**
* 格式化問(wèn)號(hào)
* @param int $count 數(shù)量
* @return string 返回格式化后的字符串
*/
private function formatMark($count) {
$str = '';
if (!is_int($count)) exit($this->getError(__FUNCTION__, __LINE__));
if ($count==1) return '?';
for ($i=0; $i<$count; $i++) {
$str .= '?,';
}
return rtrim($str, ',');
}
/**
* 錯(cuò)誤提示
* @param string $fun
* @return string
*/
private function getError($fun, $line) {
return __CLASS__ . '->' . $fun . '() line<font color="red">'. $line .'</font> ERROR!';
}
/**
* 處理表名
* @param string $tName
* @return string
*/
private function formatTabName($tName) {
return '`' . trim($tName, '`') . '`';
}
/**
* 析構(gòu)方法
*/
public function __destruct() {
$this->_db = null;
}
}
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《php curl用法總結(jié)》、《PHP運(yùn)算與運(yùn)算符用法總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語(yǔ)法入門教程》、《php操作office文檔技巧總結(jié)(包括word,excel,access,ppt)》、《php日期與時(shí)間用法總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計(jì)入門教程》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
您可能感興趣的文章:
- 全新的PDO數(shù)據(jù)庫(kù)操作類php版（僅適用Mysql）
- PHP實(shí)現(xiàn)PDO的mysql數(shù)據(jù)庫(kù)操作類
- php基于PDO實(shí)現(xiàn)功能強(qiáng)大的MYSQL封裝類實(shí)例
- PHP用PDO如何封裝簡(jiǎn)單易用的DB類詳解
- PHP基于單例模式編寫PDO類的方法
- PHP基于pdo的數(shù)據(jù)庫(kù)操作類【可支持mysql、sqlserver及oracle】
- PHP封裝的PDO數(shù)據(jù)庫(kù)操作類實(shí)例
- PHP基于PDO實(shí)現(xiàn)的SQLite操作類【包含增刪改查及事務(wù)等操作】
- PHP封裝的數(shù)據(jù)庫(kù)模型Model類完整示例【基于PDO】
- php封裝的pdo數(shù)據(jù)庫(kù)操作工具類與用法示例
相關(guān)文章
學(xué)習(xí)php開(kāi)源項(xiàng)目的源碼指南
這篇文章主要介紹了學(xué)習(xí)php開(kāi)源項(xiàng)目的源碼指南,需要的朋友可以參考下2014-12-12
解析php中用PHPMailer來(lái)發(fā)送郵件的示例(126.com的例子)
本篇文章是對(duì)php中用PHPMailer來(lái)發(fā)送郵件的示例(126.com的例子)進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-06-06
優(yōu)化php效率,提高php性能的一些方法,開(kāi)發(fā)php的朋友可以注意下。2011-03-03
我在以前寫過(guò)怎么使用c#來(lái)壓縮和解壓縮swf文件,解壓縮,壓縮和讀取flash頭文件信息2008-12-12
php獲取ajax的headers方法與內(nèi)容實(shí)例
下面小編就為大家分享一篇php獲取ajax的headers方法與內(nèi)容實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2017-12-12
PHP8使用Attributes管理代碼元數(shù)據(jù)的示例詳解
在PHP 8中引入了一項(xiàng)強(qiáng)大的功能,即"Attributes"（屬性）,它們提供了一種新的方法來(lái)管理和操縱代碼元數(shù)據(jù),Attributes允許你在代碼中添加元數(shù)據(jù),本文給大家介紹了在PHP8中是如何使用Attributes管理代碼元數(shù)據(jù),需要的朋友可以參考下2023-12-12
這篇文章主要介紹了php封裝的mysqli類,結(jié)合完整實(shí)例形式分析了php針對(duì)mysqli操作類的定義與使用技巧,需要的朋友可以參考下2016-10-10
PHP 用數(shù)組降低程序的時(shí)間復(fù)雜度
時(shí)間復(fù)雜度是開(kāi)發(fā)人員用來(lái)衡量應(yīng)用程序算法優(yōu)劣的主要因素?？陀^地說(shuō)，算法的優(yōu)劣除了和時(shí)間復(fù)雜度有關(guān)，還與空間復(fù)雜度密切相關(guān)。2009-12-12
這個(gè)以前有人發(fā)帖子研究過(guò)了，但是之后只是說(shuō)出了哪個(gè)函數(shù)快并沒(méi)有總結(jié)，研究問(wèn)題的目的是要總結(jié)方法。2008-04-04
PHP中利用sleep函數(shù)實(shí)現(xiàn)定時(shí)執(zhí)行功能實(shí)現(xiàn)代碼
在PHP中，有一個(gè)sleep函數(shù)，大概意思是程序執(zhí)行遇到sleep函數(shù)時(shí)暫停N秒后繼續(xù)往下執(zhí)行。如sleep(10)意思就是程序自上往下執(zhí)行，遇到sleep(10)語(yǔ)句后暫停十秒，然后繼續(xù)往下執(zhí)行2016-08-08