pdo操作數據庫入門教程

2024-05-04 21:49:23

字體：大中小

來源：轉載

供稿：網友

我們開始構造第一個PDO應用,建立一個pdo.php教程文件在Web文檔目錄下.PDO功能確實強大,另外還有一些內容我沒有講到,比如綁定參數、預處理、存儲過程、事務處理等等功能,另外還有不同數據擴 DSN的構造,Oracle數據庫自己很多特殊的東西,都需要深入去學習理解,這篇文章就只是簡單的描述了一些入門知識,算是對PDO一個簡單的了解吧.

先來看一下實例代碼:

$dsn = "mysql:host=localhost;dbname=test";

$db = new PDO($dsn, 'root', '');

$count = $db-＞exec("INSERT INTO foo SET name = 'heiyeluren',gender='男',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 = 'heiyeluren',gender='男',time=NOW()");
echo $count;

調用我們連接成功的PDO對象來執行一個查詢,這個查詢是一個插入一條記錄的操作,使用PDO::exec() 方法會返回一個影響記錄的結果,所以我們輸出這個結果,最后還是需要結束對象資源:$db = null;

默認這個不是長連接，如果需要數據庫長連接，需要最后加一個參數：array(PDO::ATTR_PERSISTENT =＞ true) 變成這樣:

$db = new PDO($dsn, 'root', '', array(PDO::ATTR_PERSISTENT =＞ true));

一次操作就這么簡單,也許跟以前的沒有太大區別,跟ADOdb倒是有幾分相似.

繼續了解:如果我們想提取數據的話,那么就應該使用數據獲取功能,下面用到的$db都是上面已經連接好的對象.

foreach($db-＞query("SELECT * FROM foo")){

　print_r($row);

}

我們也可以使用這種獲取方式:

$rs = $db-＞query("SELECT * FROM foo");

while($row = $rs-＞fetch()){

　print_r($row);

}

如果想一次把數據都獲取到數組里可以這樣:

$rs = $db-＞query("SELECT * FROM foo");

$result_arr = $rs-＞fetchAll();

print_r($result_arr);

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

)

}

我們看里面的記錄,數字索引和關聯索引都有,浪費資源,我們只需要關聯索引的:

$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::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,具體使用什么,按照你自己的需要,其他獲取類型參考手冊,除了上面這種獲取數據的方式,還有這種:

$rs = $db-＞prepare("SELECT * FROM foo");

$rs-＞execute();

while($row = $rs-＞fetch()){

　print_r($row);

}

其實差不多,如果你想獲取指定記錄里一個字段結果的話,可以使用 PDOStatement::fetchColumn():

$rs = $db-＞query("SELECT COUNT(*) FROM foo");

$col = $rs-＞fetchColumn();

echo $col;

一般使用fetchColumn()來進行count統計或者某些只需要單字段的記錄很好操作.

簡單的總結一下上面的操作:

查詢操作主要是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操作無效。

錯誤處理:如果程序中碰到錯誤咋辦？我們這里描述PDO類的錯誤信息和異常處理。

1. 面向對象的方式

先看看如果連接錯誤等的處理,使用面向對象的方式來處理:

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異常類的屬性結構:

class PDOException extends Exception

{

　public $errorInfo = null; // 錯誤信息，可以調用 PDO::errorInfo() 或 PDOStatement::errorInfo()來訪問

//開源代碼Vevb.com

　protected $message; // 異常信息，可以試用 Exception::getMessage() 來訪問

　protected $code; // SQL狀態錯誤代碼，可以使用 Exception::getCode() 來訪問

}

這個異常處理類是集成PHP 5內置的異常處理類,我們簡單的看一下PHP 5內置的異常處理類結構:

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. 使用面向過程的方法,先看代碼:

$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;