ADODB详解
17.4? ADODB
PHP在數據庫的支持上是很令人稱道的,幾乎所有的知名數據庫系統都有對應的函數庫支持,而且支持得很完整。但遺憾的是,每一群數據庫支持函數無論在名稱或參數結構上,都有很大的差異,這使得PHP的系統開發者在面臨更換數據庫時,總會覺得痛苦萬分。
難道這個問題就沒有解決方法嗎?當然有,答案就是將要介紹的ADODB這個PHP類庫。
ADODB提供了完整的方法和屬性,可以用來控制數據庫系統,更棒的是你只要記得它的功能即可,因為不同的數據庫系統,只要修改一個屬性值,ADODB就會自動依據設定取用正確的PHP函數。
此外,再配合數據庫系統修改SQL命令,這樣PHP系統就可以在最短的時間內更換到另一個數據庫系統;如果在編寫程序時,對SQL命令能做妥善規劃,那就更快了。
經過以上的介紹,相信你已經對ADODB的功用有所了解了,以下為ADODB的詳細介紹。
下載ADODB:可以在http://adodb.sourceforge.net/ 取得最新版的ADODB(見圖17-2)。
圖17-2
ADODB的最新版本是adodb495a版,根據需要,可以下載完整版本的ADODB。如果您主要使用MySQL,則可以下載ADODB的lite版本,減少體積和一些不必要的系統開銷。
17.4.1? 使用ADODB
由于PHP的數據庫存取函數沒有標準化,所以需要一組函數庫或類別來隱藏不同數據庫函數界面間的差異。可以實現相對簡單的數據庫系統移植,這就是ADODB抽象層要實現的目標。
ADODB目前支持的數據庫系統MySQL、Oracle、MS SQL Server、Sybase/Sybase SQL Anywhere、Informix、PostgreSQL、FrontBase、Interbase(Firebird及Borland版本)、Foxpro、Access、ADO和ODBC連接。
與其他數據庫抽象層相比,其他類大多集中在處理與SELECT操作有關的內容,而ADODB對于INSERT及UPDATE操作也提供額外的支持,并且可以很快連接到多類數據庫,提供的統計方法,在底層實現字串連接及字串標記變量的差異處理(在某些數據庫中,字串的連接和標記符號是有差異的)。
字段類型對照系統是ADODB抽象層的特性之一,所以我們可以描述像CHAR、TEXT(而Oracle是Clob類型)及STRING這樣的通用字段類型,而不必理會采用的數據庫使用的是哪種類型,它會在底層替我們做對應和轉換。
因此使用ADODB開發,對于系統來說移植相對變得容易,因為所有與數據庫相依存的程序代碼被都隱藏在后端,使用者不再需要去移植類別里的邏輯。
ADODB擁躉者很多,很多著名的開源軟件:PostNuke、phpWiki、Mambo、eGroupware等,都使用ADODB作為數據庫抽象類庫。
17.4.2? ADODB安裝
首先要將全部文件解壓縮到Web服務器目錄里,如lib/adodb。要測試ADODB則需要一個數據庫,打開testdatabase.inc.php 這個文件,并且修改連接參數,以適合你所使用的數據庫。這個程序會在你的數據庫中建立一個新的資料表,以支持我們提供的測試程序及范例。
17.4.3 ?啟動ADODB
當要執行ADODB時,至少有兩個文件要被加載進來,第一個是 ADOdb.inc.php,這里面包含了所有數據庫類中要被使用的函數。而對數據庫操作的程序代碼則被放置在ADOdb.inc.php文件里。
ADODB可以連接的名稱及對應的數據庫系統,如表17-1所示。
表17-1
| 連接標識 | access | mssql | mysql | oci8 | postgres7 |
| 數據庫名稱 | MS Access | MS SQL Server | MySQL | Oracle 8 | PostgreSQL 7 |
下面我們來看怎么使用ADODB連接數據庫。
1.連接MySQL數據庫
我們使用如下方法連接一個MySQL數據庫:
require_coce('/libs/adodb/ADOdb.inc.php');
$conn = &ADONewConnection('mysql');
無論連接到一個什么類型的數據庫,我們都要使用ADONewConnection()函數來創建一個連接對象。
ADONewConnection接收一個選擇性參數:<database name>,用以表示要連接的數據庫。如果沒有參數被指定,它將會使用ADOLoadCode() 內部方法所載入的最后一個數據庫。
當建立好一個連接對象后,我們還沒有真正連接上數據庫,需要使用$conn->Connect()或者$conn->PConnect() 兩個方法,任選其一來完成真正的數據庫連接:
$conn -> Connect(DB_HOST,DB_USER,DB_PASSWORD,$database)
下面是創建一個mysql數據庫連接對象,并創建一個數據庫連接:
$conn = ADONewConnection('mysql'); //創建一個ADODB連接對象
$mysql_obj = $conn->connect('localhost','root','passwd','dbname'); //連接到MySQL服務器
if (!$ora_obj) {
? ?echo $mysql_conn->ErrorMsg(); //顯示連接的錯誤信息
? ?exit();
}else{
? ?$mysql_conn -> SetFetchMode(3);
}
Var_dump($mysql_obj);
這樣我們就創建好與本地MySQL服務器的連接了。可以看到,ADODB連接數據庫同樣很方便。
2.連接Oracle數據庫
如果要連接Oracle數據庫該如何寫呢?結合表17-1,我們可以編寫腳本如下:
require_once ("libs/adodb/adodb.inc.php");
$ora_conn = &ADONewConnection('oci8');
$ora_obj = $ora_conn -> Connect('localhost','oracle','oracle','oradb');
if (!$ora_obj) {
? ?echo $ora_conn->ErrorMsg();
? ?exit();
}else{
? ?$ora_conn -> SetFetchMode(3);
}
Var_dump($ora_conn);
注意:連接Oracle數據庫需要在PHP本地環境安裝好Oracle的客戶端驅動,以及連接文件設置。
其中,SetFetchMode(3)指的是取得記錄集時,返回的是二維關聯數組。也可以使用字符形式,這樣更明了一些:
$mysql_conn->SetFetchMode(ADODB_FETCH_ASSOC);
17.4.4? ADODB的查詢方法
ADODB的查詢方法如下。
1.直接查詢
Excute()方法通過連接句柄執行SQL查詢,并返回一個變量,如下:
$sql='SELECT * FROM ice_cream WHERE flavor LIKE ?';
$res = $cnx->Execute($sql,array('Chocolate'));
2.緩存查詢
ADODB提供內置的緩存機制,CacheExecute()方法用于每次查詢數據時,會把相應的結果序列化后保存到文件中,以后同樣的查詢語句就可以不用直接查詢數據庫,而是從緩存文件中獲取,從而提高Web系統的性能。CacheExecute()方法的格式如下:
CacheExecute($ttc,$sql)
該方法以緩存的形式執行一段查詢,其中$ttc為緩存的時間,請看如下代碼:
$ADODB_CACHE_DIR = "/var/tmp/adodb_cache"; //緩存保存的文件目錄
$sql = "SELECT surname, age FROM employees"; //構造一個查詢
$rs = &$db->CacheExecute(600,$sql);? // 緩存式查詢,緩存將被保存600秒后更新
3.清除緩存
CacheFlush()
該方法用來清除所有ADODB數據庫的緩存。?
17.4.5? 移動記錄集
記錄集(Record Set):從執行的方法中返回指定的記錄,使用moveFirst()、moveLast()、moveNext()和move($n)方法訪問記錄集中的一個指定記錄。例如:
$rs=$cnx->Execute('SELECT flavor,price FROM ice_cream');
$rs->MoveLast();
print "Flavor ".$rs->fields[0]." costs "
.$rs->fields[2]."/n";
$rs->MoveFirst();
//省略...
$rs->Move(2);
//省略...
$rs->MoveNext();
設置一個全局變量$ADODB_FETCH_MODE,從ADODB_FETCH_NUM(或從ADODB_FETCH_ASSOC返回)中取得數字索引(或關聯索引)數組。例如:
$ADODB_FETCH_MODE = ADODB_FETCH_ASSOC ;
$rs=$cnx->Execute('SELECT flavor,price FROM ice_cream');
print "<table>/n";
while (! $rs->EOF) {
??? print "<tr><td>".$rs->fields['flavor']}."</td>".
??? "<td>".$rs->fields['price']"."</td></tr>/n";
??? $rs->MoveNext();
}
print "</table>/n";
FetchObject()方法也是一個記錄集變量。
17.4.6? 使用ADODB生成HTML
ADODB的rs2html($res)函數,它提供一個簡單的方法,從$res變量中的記錄自動生成HTML表格。
它在tohtml.inc.php中,使用時需要包含進來,如下代碼:
require 'adodb/tohtml.inc.php';? //引入rs2html函數
require 'adodb/adodb.inc.php';
//省略...
$rs = $cnx->Execute('SELECT flavor,calories,price FROM ice_cream');
rs2html($rs);
使用rs2html($res,'CLASS="myClass")這種格式,表示指定表格使用的myClass的樣式表類進行顯示。
17.4.7? 使用ADODB進行分頁
ADODB_Pager(該方法定義在adodb-pager.inc.php中)提供一種簡單分頁顯示記錄的方法。
require 'adodb/adodb.inc.php';
require 'adodb/adodb-pager.inc.php';
$pager=new ADODB_Pager($cnx,"SELECT id,flavor,price FROM ice_cream_big");
$pager->Render();
使用$pager->Render($num)來設置每次顯示的行數,默認值為10。
17.4.8 ?生成下拉選擇菜單
getMenu($selectName)方法將幫助我們生成一個<select>標簽,即從記錄集中生成一個下拉菜單。其中,$selectName是該表單中select的name標簽。例如:
$rs = $cnx->execute('SELECT flavor,id FROM ice_cream');
print $rs->GetMenu('which_flavor');
相關說明如下:
?? getMenu($sN,$selected,$blank,$mult,$nm):其中,$selected (string)為默認選擇的值/項。
?? $blank (boolean):默認初始值或布爾值為true時,下拉選項為空。
?? $mult (boolean):下拉菜單是否可以允許多選。
?? $nm (integer):設置菜單多重選擇的屬性,也就是默認幾行。
17.4.9? ADODB開發實例
為了能更好地理解和使用ADODB,下面一起做一個完整的實例。
首先準備一個簡單的表,名為“library”,用于保存書籍目錄。結構與記錄內容如下:
mysql> SELECT * FROM library;
+----+--------------------+---------------+
| id | title? ? ? ? ?? ??? | author? ? ? ?? |
+----+--------------------+---------------+
| 14 | ASP.NET 2.0網絡編程?| Dennis Lehane? |
| 15 | For Kicks? ? ? ?? ? | Dick Francis?? |
| 16 | XML and PHP? ? ?? ??| Vikram Vaswani |
| 17 | Where Eagles Dare? | Jack Higgins?? |
+----+--------------------+----------------+
在library表中,包含3個字段,分別為:
?? id——主鍵,用于保存書的序列號;
?? title——用于保存書的標題;
?? author——用于保存作者信息。
下面看使用PHP的傳統開發方式,即使用PHP的MySQL API庫進行編寫的代碼,如下:
<?php
// 創建一個數據庫連接
$connection = mysql_connect("localhost", "root", "passwd") or die ("Unable to connect!");
// 選擇數據庫
mysql_select_db("adodb") or die ("Unable to select database!");
// 構建SQL和開始查詢
$query = "SELECT * FROM library";
$result = mysql_query($query) or die ("Error in query: $query. " . mysql_error());
// 遍歷記錄集,并顯示字段的內容
while ($row = mysql_fetch_row($result)){
?? echo "$row[1] - $row[2]/n";
}
// 顯示返回的記錄行數
echo "/n[" . mysql_num_rows($result) . " 行記錄被返回]/n";
// 關閉數據庫連接
mysql_close($connection);
?>
輸出結果如下:
ASP.NET 2.0網絡編程- Dennis Lehane
For Kicks - Dick Francis
XML and PHP - Vikram Vaswani
Where Eagles Dare - Jack Higgins
[4 行記錄被返回]
可以看到此例子比較簡潔,連接到數據庫,執行查詢,取回結果后顯示出來。
上述例子用mysql_fetch_row()的抽取功能,取得記錄后生成一個連續整數的索引數組,數據內容分別對應數據表中的字段。與此相似的還有mysql_fetch_assoc(),它生成一個關聯數組,或者mysql_fetch_object函數,它生成一個對象(其屬性相當于字段名)。
這段代碼是沒有任何問題的,但如果我們想從MySQL遷移到PostgreSQL數據庫或者Oracle怎么辦呢?代碼需要重寫了!這時,就需要數據抽象層ADODB上場了。
我們把上例改用ADODB重新編寫,請看下面的代碼:
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個MySQL連接對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
// 執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 遍歷返回的記錄集內容,打印返回列的內容:TITLE 和AUTHOR
while (!$result->EOF) {
?? echo $result->fields[1] . " - " . $result->fields[2] . "/n";
? ?? $result->MoveNext();
}
// 顯示返回的記錄行數
echo "/n[" . $result->RecordCount() . " 行記錄被返回]/n";
// 關閉數據庫連接
$db->Close();
?>
這個程序和上面程序的實現功能是一樣的,但是由于采用ADODB抽象層,而沒有采用PHP的本地API(mysql或mysqli擴展),因此可以靈活地更換數據庫系統,無論哪個數據庫以及如何更換,這段代碼都是可用的。
下面對上述代碼進行詳細的解釋說明。
首先,我們引用ADODB主類文件:
<?php
? include_once("libs/adodb/adodb.inc.php");
實際上,ADODB庫并非只有這一個文件,事實上有超過30個不同的文件,負責驅動不同的數據庫系統。我們不用擔心是否完全將類包含完全,該文件會自動識別和匹配當前的PHP版本及數據庫系統,并自動包含相關的類庫文件。
然后,創建ADODB的對象實例:
// 創建一個mysql連接對象
$DB = NewADOConnection("mysql");
通過對象的構造參數,告訴ADODB連接數據庫,這里連接的是MySQL數據庫服務器,對于其他數據庫,還可以相應地使用"pgsql"或"oci8"。可以連接的數據庫及連接標識參見表17-1。
接下來,連接數據庫,這是通過Connect()方法完成的,必須設置一套連接參數:
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
以上代碼試圖打開一個MySQL連接,3個參數分別為主機名、用戶名和密碼。
一旦Connect()方法建立連接后,就可以調用該對象的Execute()方法進行SQL數據庫查詢。
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
當查詢執行成功后,則返回含有查詢結果的對象。特別說明的是errormsg()方法,可以用來獲取查詢的一個錯誤信息。
從返回的結果集中循環取值:
// 遍歷返回的記錄集內容,打印返回列的內容:TITLE 和AUTHOR
while (!$result->EOF) {
?? echo $result->fields[1] . " - " . $result->fields[2] . "/n";
?? $result->MoveNext();
}
在這種情況下,在循環體內,使用對象的movenext()方法進行記錄的移動,每次循環打印后就移動到下一條記錄。
取得記錄集后,可以使用recordcount()方法取得記錄的條數。
// 遍歷返回的記錄集內容,打印返回列的內容:TITLE 和AUTHOR
echo "/n[" . $result->RecordCount() . " 行記錄被返回]/n";
最后,使用Close()方法關閉數據庫的連接。
// 關閉數據庫連接
$db->Close();
如果有人決定要更換數據庫,唯一需要改變的是將上述腳本的連接改為新的數據庫名稱和主機地址即可。
這就是數據抽象層最好的優勢之一,它提供一些盡可能通用的方法,將與數據庫打交道的代碼隱藏在內部,從而使PHP代碼簡單、清爽、可維護性好,并且縮短開發周期,以及擁有軟件包的整體感。
ADODB還提供了一些不同的方法處理結果記錄集。例如,我們可以取回結果集為一個關聯數組。請看如下腳本:
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "john", "doe", "adodb") or die("Unable to connect!");
// 將結果保存為一個關聯數組,也可以使用數值3
$ADODB_FETCH_MODE = ADODB_FETCH_ASSOC;
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 遍歷記錄集,顯示列的內容:TITLE 和AUTHOR
while (!$result->EOF) {
?? echo $result->fields['title'] . " - " . $result->fields['author'] . "/n";
? ?? $result->MoveNext();
}
// 取得和顯示返回的記錄行數
echo "/n[" . $result->RecordCount() . " 行記錄被返回]/n";
// 關閉數據庫連接
$db->Close();
?>
在這個例子里,$ADODB_FETCH_MODE的值用于確定ADODB如何構建結果記錄集。
你也可以把取得的行轉變為一個對象,其屬性相當于字段名,這就是ADODB的FetchNextObject()方法,請看如下腳本例子:
<?php
include("libs/adodb/adodb.inc.php");
// 創建一個mysql連接對象實例
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "john", "doe", "adodb") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 遍歷記錄集,顯示列的內容:TITLE 和AUTHOR
while ($row = $result->FetchNextObject()) {
?? echo $row->TITLE . " - " . $row->AUTHOR . "/n";
}
// 取得和顯示返回的記錄行數
echo "/n[" . $result->RecordCount() . " 行記錄被返回]/n";
// 關閉數據庫連接
$db->Close();
?>
值得一提的是,FetchNextObject()方法可以自動在記錄集中移動到下一行,我們不需要再使用MoveNext()方法,當到達記錄集尾部時,該方法返回false。
1.GetAll方法
我們可以使用GetAll方法代替Execute()方法,該方法返回的結果為一個二維關聯數據,這樣可以使用foreach或for循環語句處理,非常方便。另外,GetAll取得的數組與Smarty模板的foreach配合得非常好。
我們一起看下面的腳本例子:
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "root", "library") or die("Unable to connect");
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->GetAll($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 清除無用的對象
$db->Close();
// 可以使用print_r打印該數組的內容
// print_r($result); exit(0);
// 遍歷記錄集,顯示列的內容:TITLE 和AUTHOR
foreach ($result as $row){
?? echo $row[1] . " - " . $row[2] . "/n";
}
// 取得和顯示返回的記錄行數
echo "/n[" . sizeof($result) . " 行記錄被返回]/n";
?>
GetAll()方法取得記錄集后,產生一個二維數組,類似于下面的樣子:
Array
(
[0] => Array
? ? ? ? (
? ? ? ? ? ? [0] => 14
? ? ? ? ? ? [id] => 14
? ? ? ? ? ? [1] => Mystic River
? ? ? ? ? ? [title] => Mystic River
? ? ? ? ? ? [2] => Dennis Lehane
? ? ? ? ? ? [author] => Dennis Lehane
? ? ? ? )
? ? [1] => Array
? ? ? ? (
? ? ? ? ? ? [0] => 15
? ? ? ? ? ? [id] => 15
? ? ? ? ? ? [1] => For Kicks
? ? ? ? ? ? [title] => For Kicks
? ? ? ? ? ? [2] => Dick Francis
? ? ? ? ? ? [author] => Dick Francis
? ? ? ? )
? ? ?? //下略
)
我們在數組一章,提到過這類混合數組最適合用foreach來處理。這種方法是對Execute()方法的補充或替代,尤其適合在遍歷查詢整個表時使用。
另外,ADODB還提供取得一條記錄的方法:GetOne()。
2.GetOne()方法
ADODB有個比較直接的方法可以比較方便地檢測某條記錄是否存在,那就是它的GetOne($sql)方法。
該方法返回查詢記錄的第1條第1個字段名的值,如果執行過程中出現錯誤,則返回布爾值false。
我們可以檢測這個值是否存在:
<?php
Include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", “root”, “passwd”, “adodb”) or die("Unable to connect!");
$rs = $db->GetOne("SELECT * FROM library WHERE id='$id'");
if($rs){
? echo '記錄存在';
}else {
?? echo '記錄不存在';
}
?>
不過這樣有一個問題是,如果數據表中id=$id的記錄有多條,不僅僅要知道是否存在有這樣一條記錄,還要把這條記錄提取出來,則可以使用ADODB的GetRow()方法。
3.GetRow()方法
<?php
Include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", “root”, “passwd”, “adodb”) or die("Unable to connect!");
$rs = $db->GetRow("SELECT * FROM library WHERE id='$id'");
if(is_array($rs)){
?? echo '記錄存在';
?? print_r($rs);
} else {
?? echo '記錄不存在';
}
?>
需要注意的是,GetOne($sql) 和 GetRow($sql) 都能得到一條特定的記錄,或者得到該記錄不存在的信息,但是如果符合查詢條件的記錄存在多條時,則這兩個方法只傳回第一條記錄,其他的都自動拋棄。
如果只要得到查詢結果的行數,則可以使用結果集方法中的RecordCount()方法。
4.取得返回的記錄行數
ADODB還提供了一批實用功能,如在進行查詢時,提供了非常有用的RecordCount() 和FieldCount()方法,分別返回記錄的數量和字段的數量,以下是應用這兩個方法的例子。
<?php
include("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", “root”, “passwd”, “adodb”) or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 取得和顯示返回的記錄行數
echo $result->RecordCount() . " 行記錄被返回/n";
// 取得和顯示返回的字段個數
echo $result->FieldCount() . " 個字段被返回/n";
// clea up
$db->Close();
?>
我們可以使用FetchField()方法取得字段的信息,其中含有該字段的詳細資料,包括名稱和類型等,請看如下的腳本例子。
<?php
include("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 取得記錄集中字段的結構信息
for($x=0; $x<$result->FieldCount(); $x++){
?? print_r($result->FetchField($x));
}
// 清理無用的對象
$db->Close();
?>
下面輸出的是有關id字段的結構信息。
stdClass myMagicbject
(
? ? [name] => id
? ? [table] => library
? ? [def] =>
? ? [max_length] => 3
? ? [not_null] => 1
? ? [primary_key] => 1
? ? [multiple_key] => 0
? ? [unique_key] => 0
? ? [numeric] => 1
? ? [blob] => 0
? ? [type] => int
? ? [unsigned] => 1
? ? [zerofill] => 0
? ? [binary] =>
)
?
5.其他相關方法
當執行一個INSERT查詢時,如果該表的主鍵是一個自動增量的字段,則可以使用ADODB的insert_id()方法,來獲得最后數據插入時自動產生的增量值。
<?php
include_once(“libs/adodb/adodb.inc.php”);
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", “root”, “root”, “adodb”) or die("Unable to connect!");
// 構造并執行INSERT插入操作
$title = $db->qstr("PHP5與MySQL5 Web開發技術詳解");
$author = $db->qstr("杜江");
$query = "INSERT INTO library (title, author) VALUES ($title, $author)";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 顯示插入的記錄號
if ($result){
?? echo "最后插入的記錄ID: " . $db->Insert_ID();
}
// 清理無用的對象
$db->Close();
?>
腳本中的qstr()方法,功能是過濾SQL查詢中的非法字符。
執行后,即無論查詢(SELECT)、刪除(DELETE)或修改(UPDATE)數據,如果想知道是否對表有影響,可以使用affected_rows()方法,它可以告訴我們操作后有多少(記錄)行受到了影響。請看下面的腳本例子:
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", “root”, “root”, “adodb”) or die("Unable to connect!");
// 構造并執行一個查詢
$query = "DELETE FROM library WHERE author = 'J. Luser'";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 取得和顯示執行后影響的記錄行數
if ($result){
?? echo $db->Affected_Rows() . " 行已被刪除";
}
// 清理無用的對象
$db->Close();
?>
6.限制查詢結果
上面我們討論了如何通過使用一個數據庫庫函數使應用程序更簡潔,更易于移植。比如從MS SQL Server轉移到MySQL,在MS SQL Server中使用指令“SELECT TOP 15 name FROM employee”取得數據的前15條,可在MySQL中卻不支持這種寫法,而要寫成:SELECT name FROM employee LIMIT 15。
它似乎對我們敲響了警鐘,應該停止在查詢語句中使用非標準SQL指令,而去認真地學習標準的SQL。
幸運的是,ADODB有一個處理 LIMIT的方法:SelectLimit(),這樣我們就根本不用管連接的是MySQL還是MS SQL Server,ADODB會在底層為我們自動轉換,請見下面的腳本例子:
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
// 構造并執行一個查詢
// 我們要取得5行記錄,從符合記錄的第3行開始取
$query = "SELECT * FROM library";
$result = $db->SelectLimit($query, 5, 3) or die("Error in query: $query. " . $db->ErrorMsg());
// 遍歷記錄集
while (!$result->EOF) {
?? echo $result->fields[1] . " - " . $result->fields[2] . "/n";
? ?$result->MoveNext();
}
// 清理無用的對象
$db->Close();
?>
在這個例子中,selectlimit()方法類似于MySQL的LIMIT語句,可用于控制從某行開始查詢,到某行的結果,從而取得我們指定的記錄集。
我們可以利用ADODB提供的MetaDatabases()方法取得當前服務器中所有數據庫的清單。還有一個方法和它很類似,即使用MetaTables()方法可以取得當前庫中所有表的清單。請看下面的例子:
<?php
include(“libs/adodb/adodb.inc.php”);
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
// 取得數據列表
echo "數據庫:/n";
foreach($db->MetaDatabases() as $d){
?? echo "* $d/n";??
}
// 取得數據表清單
echo "/n當前數據庫下的表:/n";
foreach($db->MetaTables() as $table){
?? echo "* $table/n";??
}
// 清理無用的對象
$db->Close();
?>
7.快速存取
有時,我們需要對一些不同的值做一些特殊的查詢,比如一系列的INSERT(插入)語句。ADODB類提供了兩個方法,可以使我們既節約時間又節省系統的開銷,請看如下示例:
<?php
include(“libs/adodb/adodb.inc.php”);
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
// 構造準備查詢,使用參數綁定
$query = $db->Prepare("INSERT INTO library (title, author) VALUES (?, ?)");
// 從CSV 中取得要插入的標題和作者名稱
$data = file("./book_list.csv");
// 遍歷該文件,并執行插入操作
foreach ($data as $l){
?? $arr = explode(",", $l);
?? // 插入值并綁定準備語句
?? $result = $db->Execute($query, array($arr[0], $arr[1])) or die("Error in query: $query. " . $db->ErrorMsg());
}
// 清理無用的對象
$db->Close;
?>
prepare()函數,把一個SQL查詢作為參數,讀取一個查詢,但并不立即執行。prepare()返回一個句柄給一個prepare查詢,當保存和傳遞給Execute()方法后,則立即執行該查詢。
?
8.處理事務
處理事務是許多應用程序的一個重要的特征(比如,錢從你的賬戶轉出,然后轉入到某個人的賬戶中。只要其中任意一步操作失敗,這整個過程都必須被認定為失敗。不然,錢被劃出,而沒有進對方的賬戶;或者,錢沒有劃出,但對方賬戶無端多了一筆錢)。
處理事務可以在代碼級上進行機警地管理控制。常數錯誤檢查被用來判斷執行COMMIT(事務的所有各項都正確,執行正確,結束事務)還是執行ROLLBACK(事務中有錯誤,所有改動需要恢復原來狀況)。
現在的數據庫系統絕大多數都支持事務,如MySQL、Oracle、MS SQL Server等,ADODB提供一個非常好的功能,能夠讓你更透明地使用這一特性。請看下面的例子:
<?php
include(“libs/adodb/adodb.inc.php”);
// 創建一個mysql連接實例對
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", “root”, “root”, “adodb”) or die("Unable to connect!");
//關閉auto-commit自動提交事務
// 開始事務處理語句塊
$db->BeginTrans();
// 第一次查詢
$query = "INSERT INTO library (title, author) VALUES ('測試用書', '佚名')";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
//使用第一次查詢返回的ID號
if ($result){
?? $id = $db->Insert_ID();
?? $query = "INSERT INTO purchase_info (id, price) VALUES ($id, 'RMB 31.9')";
?? $result = $db->Execute($query)
?or die("Error in query: $query. " . $db->ErrorMsg());
}
// 如果操作成功
if ($result){
?? // 事務提交
?? $db->CommitTrans();
}// 否則回滾
else{
?? $db->RollbackTrans();
}
// 清理無用的對象
$db->Close;
?>
該腳本首先需要關掉數據庫的auto commit功能,通過begintrans()方法來處理,這種方法也標志著一個事務的開始。可以使用CommitTrans()或RollbackTrans()函數來處理操作,一旦auto commit已經關掉,你就可以任意執行所需要的查詢,確認事務的查詢執行無誤并完畢后,由我們自己決定何時執行commit操作。
每一次執行Execute()事務塊后,它會返回一個布爾值,告訴我們是否成功地執行了查詢。可以跟蹤到這個值,以及使用的時間,以決定是否要進行整個交易行為。一旦你相信一切都沒問題,則告訴數據庫committrans()方法;如果發現有錯誤發生,則可以進行回滾操作——執行rollbacktrans()方法。
值得注意的是,注意您的數據庫類型是否支持這些事務函數,前面已經說過,MySQL的InnoDB類型表支持事務,但是MyISAM類型并不支持。
9.使用緩存查詢
在一個動態頁面中,如果其中的一個查詢指令很少改變且頻繁被執行,我們則可以使用ADODB的緩存功能,可以將查詢指令的結果緩存成靜態文件,從而提高PHP腳本的性能。
當試圖通過緩存來提高你的應用程序的性能之前,建議先去優化查詢指令再開始本操作,這樣才會起到事半功倍之效果。
ADODB最棒的功能就是提供查詢緩存的功能。緩存可以大大改善應用程序的性能,尤其是網站系統,因為大部分用戶都是在瀏覽網站,數據庫完成的任務多半是查詢(SELECT操作)。為了更好地理解與應用緩存查詢的功能,我們來看下面的腳本例子。
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "root", "adodb") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 遍歷返回的記錄集,顯示列數據的內容 TITLE 和 AUTHOR
while (!$result->EOF) {
?? echo $result->fields[1] . " - " . $result->fields[2] . "/n";
? ?? $result->MoveNext();
}
// 顯示取得的記錄行數
echo "/n[" . $result->RecordCount() . " 行記錄被返回]/n";
// 關閉數據庫連接
$db->Close();
?>
這段代碼使用ADODB進行一個SELECT操作。比如說,這就是您的網站,平均有每分鐘5000次的點擊(PV,Page View)量,那么數據庫系統每小時至少要被查詢3萬次以上,可以想象,這對我們的MySQL數據庫的負載是相當繁重的。
因此ADODB提供了緩存的功能,可以將經常查詢的結果保存起來,進而降低數據庫服務器的負荷,同時也向用戶提供更快速的內容響應。
下面是修改上面的腳本,改為使用CacheExecute來進行緩存查詢的示例:
<?php
include("libs/adodb/adodb.inc.php");
//設置緩存保存的路徑,.表示當前目錄
$ADODB_CACHE_DIR = '.'; //為了管理方便,實際開發環境請指向到獨立的目錄中,如/tmp/adodb
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "adodb") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT * FROM library";
$result = $db->CacheExecute(300,$query) or die("Error in query: $query. " . $db->ErrorMsg());
// 遍歷返回的記錄集,顯示列數據的內容 TITLE 和 AUTHOR
while (!$result->EOF) {
?? echo $result->fields[1] . " - " . $result->fields[2] . "/n";
? ?? $result->MoveNext();
}
// 取得和顯示返回的記錄行數
echo "/n[" . $result->RecordCount() . " 行記錄被返回]/n";
// 關閉數據庫連接
$db->Close();
?>
CacheExecute()方法的第一個參數是緩存文件(緩存文件被命名為adodb_*.cache)將被保留的時間,以秒計時;第二個參數是SQL聲明。第一個參數是可選擇的,若沒有限定時間,默認值是3600秒,也就是1個小時。
值得一提的是,使用CacheExcute()方法時,需要將php.ini中的參數magic_quotes_runtime設為0。
也可以根據需要,在程序運行時動態修改它的值:
set_magic_quotes_runtime(0);
注意:將上述代碼放到調用數據庫的指令之前,我們還可以在任何時候,通過調用CacheFlush()來清除過時的緩存。
10.生成下拉列表菜單
ADODB特意為Web開發任務提供幾個通用的方法。其中,最有用的是GetMenu()方法,通過抽取數據庫的記錄集,自動地生成表單及菜單列表框。
下面介紹的就是從數據庫動態構建下拉菜單(Option)的例子。
<html>
<head></head>
<body>
<?php
include_once("libs/adodb/adodb.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "root", "library") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT title, id FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
//顯示HTML下拉列表菜單
echo $result->GetMenu("library", '', false);
// 關閉數據庫連接
$db->Close();
?>
</body>
</html>
GetMenu()方法需要傳入參數,用來控制列表框的行為。上例中第一個參數是列表框的名字(這個例子為“library”);第二個參數是顯示時默認的值,可以為空,從第一個記錄開始;第三個參數,指定列表框的項目是否為空;第四個參數,控制是否允許用戶多選。
上例的顯示結果如下:
<select name="library" >
<option value="15">Mystic River</option>
<option value="16">Where Eagles Dare</option>
<option value="17">XML and PHP</option>
</select>
可以看到,該列表菜單內容是從library表抽取的記錄,列表框的名字為“library”,在記錄集中,ID是菜單選項的值,名稱為菜單框顯示的元素。
由此可以看出,GetMenu()方法可以大幅度簡化Web開發任務,大大減少代碼量。
11.輸出到文件
ADODB還允許我們將記錄輸出為一個不同形式的文件:如逗號分隔符CSV文件,制表符表格,甚至于HTML形式的表格。
這些功能屬于ADODB的附屬功能,在使用時需要包含相關ADODB類文件,下面是樣例的內容。
<?php
include("libs/adodb/adodb.inc.php");
// 包含轉換方法的文件
include_once("libs/adodb/toexport.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "library") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT title, id FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 返回一個CSV字符串
echo rs2csv($result);
// 關閉數據庫的連接
$db->Close();
?>
輸出結果如下:
title,id
Mystic River,15
Where Eagles Dare,16
XML and PHP,17
我們也可以去除結果中第一行,即字段的名稱,使用腳本格式如下:
// 返回一個 CSV 字符串
echo rs2csv($result, false);
腳本的輸出結果將沒有字段名稱,如下:
Mystic River,15
Where Eagles Dare,16
XML and PHP,17
ADODB還提供生成制表符或分隔符文件功能,使用rs2tab()方法:
<?php
include("libs/adodb/adodb.inc.php");
// 包含轉換方法的文件
include("toexport.inc.php");
//創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "root", "library") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT title, id FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 返回一個TAB制表符分隔的字符串
echo rs2tab($result);
// 關閉數據庫連接
$db->Close();
?>
顯示結果如下:
title?? id
Mystic River?? 15
Where Eagles Dare?? 16
XML and PHP?? 17
ADODB還提供生成HTML表格的功能,使用rs2html()方法:
<html>
<head></head>
<body>
<?php
include_once(“libs/adodb/adodb.inc.php”);
// 包含轉換方法的文件
include_once("libs/adodb/tohtml.inc.php");
// 創建一個mysql連接實例對象
$db = NewADOConnection("mysql");
// 打開一個數據庫連接
$db->Connect("localhost", "root", "passwd", "library") or die("Unable to connect!");
// 構造并執行一個查詢
$query = "SELECT title, id FROM library";
$result = $db->Execute($query) or die("Error in query: $query. " . $db->ErrorMsg());
// 返回一個HTML格式的表格
echo rs2html($result);
// 關閉數據庫連接
$db->Close();
?>
</body>
</html>
輸出結果如下:
總結
- 上一篇: 短信java_Java发送手机短信(附代
- 下一篇: [4G5G专题-12]:功能-LTE载波