本文不涉及PDO的安裝,只是簡單總結一下PDO的使用。
開始構造第一個PDO應用,在Web文檔目錄下創建一個pdo.php文件:
[php]
<?php
$dsn = "mysql:host=localhost;dbname=test";
$db = new PDO($dsn, 'root', '');
$count = $db->exec("INSERT INTO foo SET name = 'lix',gender='mail',time=NOW()");
echo $count;
$db = null;
?>
$dsn = "mysql:host=localhost;dbname=test";
用來構造DSN(數據源),裡面的信息包括:數據庫類型是mysql,主機地址是localhost,數據庫名稱是test,就這麼幾個信息。不同數據庫的數據源構造方式是不一樣的。
$db = new PDO($dsn, 'root', '');
初始化一個PDO對象,構造函數的參數第一個就是我們的數據源,第二個是連接數據庫服務器的用戶,第三個參數是密碼。
$count = $db->exec("INSERT INTO foo SET name = 'lix',gender='mail',time=NOW()");
echo $count;
調用連接成功的PDO對象來執行一個查詢,這個查詢是一個插入一條記錄的操作,使用PDO::exec() 方法會返回一個影響記錄的結果。最後還是需要結束對象資源:
$db = null;
默認這個不是長連接,如果需要數據庫長連接,需要最後加一個參數:array(PDO::ATTR_PERSISTENT => true) 變成這樣:
$db = new PDO($dsn, 'root', '', array(PDO::ATTR_PERSISTENT => true));
如果想獲取數據
[php]
<?php
$rs=$db->query("SELECT * FROM foo");
foreach($rs->fetch() as $row){
print_r($row);
}
?>
也可以用
[php]
<?php
$rs = $db->query("SELECT * FROM foo");
while($row = $rs->fetch()){
print_r($row);
}
?>
一次獲取所有數據
[php]
<?php
$rs = $db->query("SELECT * FROM foo");
$result_arr = $rs->fetchAll();
print_r($result_arr);
?>
結果顯示:
[php]
Array
(
[0] => Array
(
[id] => 1
[0] => 1
[name] => heiyeluren
[1] => heiyeluren
[gender] => 男
[2] => 男
[time] => 2006-10-28 23:14:23
[3] => 2006-10-28 23:14:23
)
}
我們看裡面的記錄,數字索引和關聯索引都有,浪費資源,我們只需要關聯索引的:
[php]
<?php
$db->setAttribute(PDO::ATTR_CASE, PDO::CASE_UPPER);
$rs = $db->query("SELECT * FROM foo");
$rs->setFetchMode(PDO::FETCH_ASSOC);
$result_arr = $rs->fetchAll();
print_r($result_arr);
?>
setAttribute() 方法是設置PDO屬性,主要屬性有:PDO::ATTR_CASE、PDO::ATTR_ERRMODE等等,我們這裡需要設置的是PDO::ATTR_CASE,就是我們使用關聯索引獲取數據集的時候,關聯索引是大寫還是小寫,有幾個選擇:
PDO::CASE_LOWER -- 強制列名是小寫
PDO::CASE_NATURAL -- 列名按照原始的方式
PDO::CASE_UPPER -- 強制列名為大寫
我們使用setFetchMode方法來設置獲取結果集的返回值的類型,同樣類型還有:
PDO::FETCH_ASSOC -- 關聯數組形式
PDO::FETCH_NUM -- 數字索引數組形式
PDO::FETCH_BOTH -- 兩者數組形式都有,這是缺省的
PDO::FETCH_OBJ -- 按照對象的形式,類似於以前的 mysql_fetch_object()
當然,一般情況下我們是使用PDO::FETCH_ASSOC,具體使用什麼,按照你自己的需要,其他獲取類型參考手冊。
除了上面這種獲取數據的方式,還可以:
[php]
<?php
$rs = $db->prepare("SELECT * FROM foo");
$rs->execute();
while($row = $rs->fetch()){
print_r($row);
}
?>
如果你想獲取指定記錄裡一個字段結果的話,可以使用 PDOStatement::fetchColumn():
[php]
<?php
$rs = $db->query("SELECT COUNT(*) FROM foo");
$col = $rs->fetchColumn();
echo $col;
?>
小結:
查詢操作主要是PDO::query()、PDO::exec()、PDO::prepare()。PDO::query()主要是用於有記錄結果返回的操作,特別是SELECT操作,PDO::exec()主要是針對沒有結果集合返回的操作,比如INSERT、UPDATE、DELETE等操作,它返回的結果是當前操作影響的列數。PDO::prepare()主要是預處理操作,需要通過$rs->execute()來執行預處理裡面的SQL語句,這個方法可以綁定參數,功能比較強大,不是本文能夠簡單說明白的,大家可以參考手冊和其他文檔。
獲取結果集操作主要是:PDOStatement::fetchColumn()、PDOStatement::fetch()、PDOStatement::fetchALL()。PDOStatement::fetchColumn() 是獲取結果指定第一條記錄的某個字段,缺省是第一個字段。PDOStatement::fetch() 是用來獲取一條記錄,PDOStatement::fetchAll()是獲取所有記錄集到一個中,獲取結果可以通過PDOStatement::setFetchMode來設置需要結果集合的類型。
另外有兩個周邊的操作,一個是PDO::lastInsertId()和PDOStatement::rowCount()。PDO::lastInsertId()是返回上次插入操作,主鍵列類型是自增的最後的自增ID。PDOStatement::rowCount()主要是用於PDO::query()和PDO::prepare()進行DELETE、INSERT、UPDATE操作影響的結果集,對PDO::exec()方法和SELECT操作無效。
【錯誤處理】
1. 面向對象的方式
先看看如果連接錯誤等的處理,使用面向對象的方式來處理:
[php]
<?php
try {
$db = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
$db = null;
} catch (PDOException $e) {
print "Error: " . $e->getMessage() . "<br/>";
die();
}
?>
這裡利用我們PHP 5面向對象的異常處理特征,如果裡面有異常的話就初始化調用PDOException來初始化一個異常類。
PDOException異常類的屬性結構:
[php]
<?php
class PDOException extends Exception
{
public $errorInfo = null; // 錯誤信息,可以調用 PDO::errorInfo() 或 PDOStatement::errorInfo()來訪問
protected $message; // 異常信息,可以試用 Exception::getMessage() 來訪問
protected $code; // SQL狀態錯誤代碼,可以使用 Exception::getCode() 來訪問
}
?>
簡單的看一下PHP 5內置的異常處理類結構:
[php]
<?php
class Exception
{
// 屬性
protected $message = 'Unknown exception'; // 異常信息
protected $code = 0; // 用戶自定義異常代碼
protected $file; // 發生異常的文件名
protected $line; // 發生異常的代碼行號
// 方法
final function getMessage(); // 返回異常信息
final function getCode(); // 返回異常代碼
final function getFile(); // 返回發生異常的文件名
final function getLine(); // 返回發生異常的代碼行號
final function getTrace(); // backtrace() 數組
final function getTraceAsString(); // 已格成化成字符串的 getTrace() 信息
}
?>
相應的,在代碼中可以合適的調用 getFile() 和 getLine() 來進行錯誤定位,更方便的進行調試。
2. 面向過程的方法
[php]
<?
$db = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
$rs = $db->query("SELECT aa,bb,cc FROM foo");
if ($db->errorCode() != '00000'){
print_r($db->errorInfo());
exit;
}
$arr = $rs->fetchAll();
print_r($arr);
$db = null;
?>
PDO和PDOStatement對象有errorCode() 和 errorInfo() 方法,如果沒有任何錯誤, errorCode() 返回的是: 00000 ,否則就會返回一些錯誤代碼。errorInfo() 返回的一個數組,包括PHP定義的錯誤代碼和MySQL的錯誤代碼和錯誤信息,數組結構如下:
[php]
Array
(
[0] => 42S22
[1] => 1054
[2] => Unknown column 'aaa' in 'field list'
)
每次執行查詢以後,errorCode() 的結果都是最新的,所以我們可以很容易自己控制錯誤信息顯示。
摘自 河大李信的 Crazy Coding人生