MySql数据库AdoDB函数实例详解

1．GetAll方法我们可以使用GetAll方法代替Execute()方法,该方法返回的结果为一个二维关联数据，这样可以使用foreach或for循环语句处理,非常方便,另外,GetAll取得的数组与Smarty模板的foreach配合得非常好.

我们一起看下面的脚本例子,代码如下:

1. <?php
2. include_once("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost","root","root","library")ordie("Unabletoconnect");
7. //构造并执行一个查询
8. $query="SELECT*FROMlibrary";
9. $result=$db->GetAll($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
10. //清除无用的对象
11. $db->Close();
12. //可以使用print_r打印该数组的内容
13. //print_r($result);exit(0);
14. //遍历记录集，显示列的内容：TITLE和AUTHOR
15. foreach($resultas$row){
16. echo$row[1]."-".$row[2]."n";
17. }
18. //取得和显示返回的记录行数
19. echo"n[".sizeof($result)."行记录被返回]n";
20. ?>

GetAll()方法取得记录集后m产生一个二维数组m类似于下面的样子,代码如下:

1. Array
2. (
3. [0]=>Array
4. (
5. [0]=>14
6. [id]=>14
7. [1]=>MysticRiver
8. [title]=>MysticRiver
9. [2]=>DennisLehane
10. [author]=>DennisLehane
11. )
12. [1]=>Array
13. (
14. [0]=>15
15. [id]=>15
16. [1]=>ForKicks
17. [title]=>ForKicks
18. [2]=>DickFrancis
19. [author]=>DickFrancis
20. )
21. //下略
22. )

我们在数组一章,提到过这类混合数组最适合用foreach来处理,这种方法是对Execute()方法的补充或替代,尤其适合在遍历查询整个表时使用.

另外,ADODB还提供取得一条记录的方法:GetOne().

2．GetOne()方法ADODB有个比较直接的方法可以比较方便地检测某条记录是否存在,那就是它的GetOne($sql)方法,该方法返回查询记录的第1条第1个字段名的值,如果执行过程中出现错误,则返回布尔值false.

我们可以检测这个值是否存在,代码如下:

1. <?php
2. Include_once("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost",“root”,“passwd”,“adodb”)ordie("Unabletoconnect!");
7. $rs=$db->GetOne("SELECT*FROMlibraryWHEREid='$id'");
8. if($rs){
9. echo'记录存在';
10. }else{
11. echo'记录不存在';
12. }
13. ?>

不过这样有一个问题是,如果数据表中id=$id的记录有多条,不仅仅要知道是否存在有这样一条记录,还要把这条记录提取出来,则可以使用ADODB的GetRow()方法.

3．GetRow()方法,代码如下:

1. <?php
2. Include_once("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost",“root”,“passwd”,“adodb”)ordie("Unabletoconnect!");
7. $rs=$db->GetRow("SELECT*FROMlibraryWHEREid='$id'");
8. if(is_array($rs)){
9. echo'记录存在';
10. print_r($rs);
11. }else{
12. echo'记录不存在';
13. }
14. ?>

需要注意的是，GetOne($sql) 和 GetRow($sql) 都能得到一条特定的记录,或者得到该记录不存在的信息,但是如果符合查询条件的记录存在多条时,则这两个方法只传回第一条记录,其他的都自动抛弃.

如果只要得到查询结果的行数,则可以使用结果集方法中的RecordCount()方法.

4．取得返回的记录行数ADODB还提供了一批实用功能,如在进行查询时,提供了非常有用的RecordCount() 和FieldCount()方法,分别返回记录的数量和字段的数量,以下是应用这两个方法的例子,代码如下:

1. <?php
2. include("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost",“root”,“passwd”,“adodb”)ordie("Unabletoconnect!");
7. //构造并执行一个查询
8. $query="SELECT*FROMlibrary";
9. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
10. //取得和显示返回的记录行数
11. echo$result->RecordCount()."行记录被返回n";
12. //取得和显示返回的字段个数
13. echo$result->FieldCount()."个字段被返回n";
14. //cleaup
15. $db->Close();
16. ?>

我们可以使用FetchField()方法取得字段的信息,其中含有该字段的详细资料,包括名称和类型等,请看如下的脚本例子,代码如下:

1. <?php
2. include("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost","root","passwd","adodb")ordie("Unabletoconnect!");
7. //构造并执行一个查询
8. $query="SELECT*FROMlibrary";
9. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
10. //取得记录集中字段的结构信息
11. for($x=0;$x<$result->FieldCount();$x++){
12. print_r($result->FetchField($x));
13. }
14. //清理无用的对象
15. $db->Close();
16. ?>

下面输出的是有关id字段的结构信息,代码如下:

1. stdClassmyMagicbject
2. (
3. [name]=>id
4. [table]=>library
5. [def]=>
6. [max_length]=>3
7. [not_null]=>1
8. [primary_key]=>1
9. [multiple_key]=>0
10. [unique_key]=>0
11. [numeric]=>1
12. [blob]=>0
13. [type]=>int
14. [unsigned]=>1
15. [zerofill]=>0
16. [binary]=>
17. )

5．其他相关方法当执行一个INSERT查询时,如果该表的主键是一个自动增量的字段,则可以使用ADODB的insert_id()方法,来获得最后数据插入时自动产生的增量值,代码如下 :

1. <?php
2. include_once(“libs/adodb/adodb.inc.php”);
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost",“root”,“root”,“adodb”)ordie("Unabletoconnect!");
7. //构造并执行INSERT插入操作
8. $title=$db->qstr("PHP5与MySQL5Web开发技术详解");
9. $author=$db->qstr("杜江");
10. $query="INSERTINTOlibrary(title,author)VALUES($title,$author)";
11. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
12. //显示插入的记录号
13. if($result){
14. echo"最后插入的记录ID：".$db->Insert_ID();
15. }
16. //清理无用的对象
17. $db->Close();
18. ?>

脚本中的qstr()方法,功能是过滤SQL查询中的非法字符,执行后,即无论查询（SELECT）、删除（DELETE）或修改（UPDATE）数据,如果想知道是否对表有影响,可以使用affected_rows()方法,它可以告诉我们操作后有多少（记录）行受到了影响,请看下面的脚本例子,代码如下:

1. <?php
2. include_once("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost",“root”,“root”,“adodb”)ordie("Unabletoconnect!");
7. //构造并执行一个查询
8. $query="DELETEFROMlibraryWHEREauthor='J.Luser'";
9. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
10. //取得和显示执行后影响的记录行数
11. if($result){
12. echo$db->Affected_Rows()."行已被删除";
13. }
14. //清理无用的对象
15. $db->Close();
16. ?>

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会在底层为我们自动转换,请见下面的脚本例子,代码如下:

1. <?php
2. include_once("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost","root","passwd","adodb")ordie("Unabletoconnect!");
7. //构造并执行一个查询
8. //我们要取得5行记录，从符合记录的第3行开始取
9. $query="SELECT*FROMlibrary";
10. $result=$db->SelectLimit($query,5,3)ordie("Errorinquery:$query.".$db->ErrorMsg());
11. //遍历记录集
12. while(!$result->EOF){
13. echo$result->fields[1]."-".$result->fields[2]."n";
14. $result->MoveNext();
15. }
16. //清理无用的对象
17. $db->Close();
18. ?>

在这个例子中,selectlimit()方法类似于MySQL的LIMIT语句,可用于控制从某行开始查询,到某行的结果,从而取得我们指定的记录集.

我们可以利用ADODB提供的MetaDatabases()方法取得当前服务器中所有数据库的清单,还有一个方法和它很类似,即使用MetaTables()方法可以取得当前库中所有表的清单,请看下面的例子,代码如下:

1. <?php
2. include(“libs/adodb/adodb.inc.php”);
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost","root","passwd","adodb")ordie("Unabletoconnect!");
7. //取得数据列表
8. echo"数据库:n";
9. foreach($db->MetaDatabases()as$d){
10. echo"*$dn";
11. }
12. //取得数据表清单
13. echo"n当前数据库下的表:n";
14. foreach($db->MetaTables()as$table){
15. echo"*$tablen";
16. }
17. //清理无用的对象
18. $db->Close();
19. ?>

7．快速存取有时,我们需要对一些不同的值做一些特殊的查询,比如一系列的INSERT（插入）语句,ADODB类提供了两个方法,可以使我们既节约时间又节省系统的开销,请看如下示例,代码如下:

1. <?php
2. include(“libs/adodb/adodb.inc.php”);
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost","root","passwd","adodb")ordie("Unabletoconnect!");
7. //构造准备查询，使用参数绑定
8. $query=$db->Prepare("INSERTINTOlibrary(title,author)VALUES(?,?)");
9. //从CSV中取得要插入的标题和作者名称
10. $data=file("./book_list.csv");
11. //遍历该文件，并执行插入操作
12. foreach($dataas$l){
13. $arr=explode(",",$l);
14. //插入值并绑定准备语句
15. $result=$db->Execute($query,array($arr[0],$arr[1]))ordie("Errorinquery:$query.".$db->ErrorMsg());
16. }
17. //清理无用的对象
18. $db->Close;
19. ?>

prepare()函数,把一个SQL查询作为参数,读取一个查询,但并不立即执行,prepare()返回一个句柄给一个prepare查询,当保存和传递给Execute()方法后,则立即执行该查询.

8．处理事务处理事务是许多应用程序的一个重要的特征,比如,钱从你的账户转出,然后转入到某个人的账户中,只要其中任意一步操作失败,这整个过程都必须被认定为失败,不然,钱被划出,而没有进对方的账户,或者,钱没有划出,但对方账户无端多了一笔钱.

处理事务可以在代码级上进行机警地管理控制,常数错误检查被用来判断执行COMMIT,事务的所有各项都正确,执行正确,结束事务,还是执行ROLLBACK,事务中有错误,所有改动需要恢复原来状况.

现在的数据库系统绝大多数都支持事务,如MySQL、Oracle、MS SQL Server等,ADODB提供一个非常好的功能,能够让你更透明地使用这一特性,请看下面的例子,代码如下:

1. <?php
2. include(“libs/adodb/adodb.inc.php”);
3. //创建一个mysql连接实例对
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost",“root”,“root”,“adodb”)ordie("Unabletoconnect!");
7. //关闭auto-commit自动提交事务
8. //开始事务处理语句块
9. $db->BeginTrans();
10. //第一次查询
11. $query="INSERTINTOlibrary(title,author)VALUES('测试用书','佚名')";
12. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
13. //使用第一次查询返回的ID号
14. if($result){
15. $id=$db->Insert_ID();
16. $query="INSERTINTOpurchase_info(id,price)VALUES($id,'RMB31.9')";
17. $result=$db->Execute($query)
18. ordie("Errorinquery:$query.".$db->ErrorMsg());
19. }
20. //如果操作成功
21. if($result){
22. //事务提交
23. $db->CommitTrans();
24. }//否则回滚
25. else{
26. $db->RollbackTrans();
27. }
28. //清理无用的对象
29. $db->Close;
30. ?>

该脚本首先,需要关掉数据库的auto commit功能,通过begintrans()方法来处理,这种方法也标志着一个事务的开始,可以使用CommitTrans()或 RollbackTrans()函数来处理操作,一旦auto commit已经关掉,你就可以任意执行所需要的查询,确认事务的查询执行无误并完毕后,由我们自己决定何时执行commit操作.

每 一 次执行Execute()事务块后,它会返回一个布尔值,告诉我们是否成功地执行了查询,可以跟踪到这个值,以及使用的时间,以决定是否要进行整个交易行为,一旦你相信一切都没问题,则告诉数据库committrans()方法,如果发现有错误发生,则可以进行回滚操作——执行 rollbacktrans()方法.

值得注意的是,注意您的数据库类型是否支持这些事务函数,前面已经说过,MySQL的InnoDB类型表支持事务,但是MyISAM类型并不支持.

9．使用缓存查询在一个动态页面中,如果其中的一个查询指令很少改变且频繁被执行,我们则可以使用ADODB的缓存功能,可以将查询指令的结果缓存成静态文件,从而提高PHP脚本的性能.

当试图通过缓存来提高你的应用程序的性能之前,建议先去优化查询指令再开始本操作,这样才会起到事半功倍之效果.

ADODB最棒的功能就是提供查询缓存的功能,缓存可以大大改善应用程序的性能,尤其是网站系统,因为大部分用户都是在浏览网站,数据库完成的任务多半是查询,SELECT操作,为了更好地理解与应用缓存查询的功能,我们来看下面的脚本例子,代码如下:

1. <?php
2. include_once("libs/adodb/adodb.inc.php");
3. //创建一个mysql连接实例对象
4. $db=NewADOConnection("mysql");
5. //打开一个数据库连接
6. $db->Connect("localhost","root","root","adodb")ordie("Unabletoconnect!");
7. //构造并执行一个查询
8. $query="SELECT*FROMlibrary";
9. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
10. //遍历返回的记录集，显示列数据的内容TITLE和AUTHOR
11. while(!$result->EOF){
12. echo$result->fields[1]."-".$result->fields[2]."n";
13. $result->MoveNext();
14. }
15. //显示取得的记录行数
16. echo"n[".$result->RecordCount()."行记录被返回]n";
17. //关闭数据库连接
18. $db->Close();
19. ?>

这段代码使用ADODB进行一个SELECT操作,比如说,这就是您的网站,平均有每分钟5000次的点击（PV，Page View）量,那么数据库系统每小时至少要被查询3万次以上,可以想象,这对我们的MySQL数据库的负载是相当繁重的.

因此ADODB提供了缓存的功能,可以将经常查询的结果保存起来,进而降低数据库服务器的负荷,同时也向用户提供更快速的内容响应.

下面是修改上面的脚本,改为使用CacheExecute来进行缓存查询的示例,代码如下:

1. <?php
2. include("libs/adodb/adodb.inc.php");
4. //设置缓存保存的路径，.表示当前目录
5. $ADODB_CACHE_DIR='.';//为了管理方便，实际开发环境请指向到独立的目录中，如/tmp/adodb
6. //创建一个mysql连接实例对象
7. $db=NewADOConnection("mysql");
9. //打开一个数据库连接
10. $db->Connect("localhost","root","passwd","adodb")ordie("Unabletoconnect!");
12. //构造并执行一个查询
13. $query="SELECT*FROMlibrary";
14. $result=$db->CacheExecute(300,$query)ordie("Errorinquery:$query.".$db->ErrorMsg());
16. //遍历返回的记录集，显示列数据的内容TITLE和AUTHOR
17. while(!$result->EOF){
18. echo$result->fields[1]."-".$result->fields[2]."n";
19. $result->MoveNext();
20. }
22. //取得和显示返回的记录行数
23. echo"n[".$result->RecordCount()."行记录被返回]n";
24. //phpfensi.com
25. //关闭数据库连接
26. $db->Close();
27. ?>

CacheExecute()方法的第一个参数是缓存文件（缓存文件被命名为adodb_*.cache）将被保留的时间,以秒计时,第二个参数是SQL声明,第一个参数是可选择的,若没有限定时间,默认值是3600秒,也就是1个小时.

值得一提的是,使用CacheExcute()方法时,需要将php.ini中的参数magic_quotes_runtime设为0,也可以根据需要,在程序运行时动态修改它的值:

set_magic_quotes_runtime(0)；

注意:将上述代码放到调用数据库的指令之前,我们还可以在任何时候,通过调用CacheFlush()来清除过时的缓存.

10．生成下拉列表菜单ADODB特意为Web开发任务提供几个通用的方法,其中,最有用的是GetMenu()方法,通过抽取数据库的记录集,自动地生成表单及菜单列表框.

下面介绍的就是从数据库动态构建下拉菜单（Option）的例子,代码如下:

1. <html>
2. <head></head>
3. <body>
4. <?php
5. include_once("libs/adodb/adodb.inc.php");
7. //创建一个mysql连接实例对象
8. $db=NewADOConnection("mysql");
10. //打开一个数据库连接
11. $db->Connect("localhost","root","root","library")ordie("Unabletoconnect!");
13. //构造并执行一个查询
14. $query="SELECTtitle,idFROMlibrary";
15. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
17. //显示HTML下拉列表菜单
18. echo$result->GetMenu("library",'',false);
20. //关闭数据库连接
21. $db->Close();
22. ?>
23. </body>
24. </html>

GetMenu()方法需要传入参数,用来控制列表框的行为,上例中第一个参数是列表框的名字（这个例子为“library”）,第二个参数是显示时默认的值,可以为空,从第一个记录开始,第三个参数,指定列表框的项目是否为空,第四个参数,控制是否允许用户多选.

上例的显示结果如下:

1. <selectname="library">
2. <optionvalue="15">MysticRiver</option>
3. <optionvalue="16">WhereEaglesDare</option>
4. <optionvalue="17">XMLandPHP</option>
5. </select>

可以看到,该列表菜单内容是从library表抽取的记录,列表框的名字为“library”,在记录集中,ID是菜单选项的值,名称为菜单框显示的元素.

由此可以看出,GetMenu()方法可以大幅度简化Web开发任务,大大减少代码量.

11．输出到文件ADODB还允许我们将记录输出为一个不同形式的文件,如逗号分隔符CSV文件,制表符表格,甚至于HTML形式的表格.

这些功能属于ADODB的附属功能,在使用时需要包含相关ADODB类文件,下面是样例的内容,代码如下:

1. <?php
2. include("libs/adodb/adodb.inc.php");
3. //包含转换方法的文件
4. include_once("libs/adodb/toexport.inc.php");
5. //创建一个mysql连接实例对象
6. $db=NewADOConnection("mysql");
7. //打开一个数据库连接
8. $db->Connect("localhost","root","passwd","library")ordie("Unabletoconnect!");
9. //构造并执行一个查询
10. $query="SELECTtitle,idFROMlibrary";
11. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
12. //返回一个CSV字符串
13. echors2csv($result);
14. //关闭数据库的连接
15. $db->Close();
16. ?>
17. //输出结果如下：
18. title,id
19. MysticRiver,15
20. WhereEaglesDare,16
21. XMLandPHP,17

我们也可以去除结果中第一行,即字段的名称,使用脚本格式如下:

返回一个 CSV 字符串:echo rs2csv($result, false);

脚本的输出结果将没有字段名称,如下:

Mystic River,15

Where Eagles Dare,16

XML and PHP,17

ADODB还提供生成制表符或分隔符文件功能,使用rs2tab()方法,代码如下:

1. <?php
2. include("libs/adodb/adodb.inc.php");
3. //包含转换方法的文件
4. include("toexport.inc.php");
5. //创建一个mysql连接实例对象
6. $db=NewADOConnection("mysql");
7. //打开一个数据库连接
8. $db->Connect("localhost","root","root","library")ordie("Unabletoconnect!");
9. //构造并执行一个查询
10. $query="SELECTtitle,idFROMlibrary";
11. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
12. //返回一个TAB制表符分隔的字符串
13. echors2tab($result);
14. //关闭数据库连接
15. $db->Close();
16. ?>
17. //显示结果如下：
18. titleid
19. MysticRiver15
20. WhereEaglesDare16
21. XMLandPHP17

ADODB还提供生成HTML表格的功能,使用rs2html()方法,代码如下:

1. <html>
2. <head></head>
3. <body>
4. <?php
5. include_once(“libs/adodb/adodb.inc.php”);
7. //包含转换方法的文件
8. include_once("libs/adodb/tohtml.inc.php");
10. //创建一个mysql连接实例对象
11. $db=NewADOConnection("mysql");
13. //打开一个数据库连接
14. $db->Connect("localhost","root","passwd","library")ordie("Unabletoconnect!");
16. //构造并执行一个查询
17. $query="SELECTtitle,idFROMlibrary";
18. $result=$db->Execute($query)ordie("Errorinquery:$query.".$db->ErrorMsg());
20. //返回一个HTML格式的表格
21. echors2html($result);
23. //关闭数据库连接
24. $db->Close();
25. ?>
26. </body>
27. </html>