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

PHP中PDO的使用方法

編輯:關於PHP編程

本文不涉及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人生

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