数据库抽象层PDO和ADOdb

ADOdb具有以下特点：

(1)支持多种类型的数据库
(2)与其他PHP类库专注的select语句不同，ADOdb提供了对insert、update的全面支持，还提供了对不同数据库下日期、字符串数据类型的统一转换。
(3)可以对查询结果进行相应的缓存，通过减少相同的查询，可以在一定程度上提高数据库的执行效率。
(4)可以进行事务处理，即对一组数据库操作进行统一控制。通过ADOdb在代码级上的有效控制，对事务的成功或失败进行相应的处理，即事务各项都正确时，结束事务；有错误发生时，纠正所有的改动，恢复到原来的状态。

PDO的预执行语句

(1)查询只需要解析（或准备）一次，但是可以用相同或不同的参数执行多次。简单的说，预执行语句使用的资源更少，因而运行的更快。
(2)提供给预执行语句的参数不需要用括号括起来，驱动程序会处理这些。如果应用程序独占的使用预处理语句，则可以确保没有SQL入侵发生，相比传统方式较为耗时。

传统方式与抽象层开发PDO对比

连接数据库1000次，各自耗用时间如下：

查询1000次，各自耗用时间对比如下：

插入100条，各自耗用时间如下：

总体说来，连接数据库上PDO抽象层开发耗时较多，在插入和查询的性能上传统方式和PDO抽象层开发差不多，结合其其安全性和其他方面的因素，综合说来PDO方式较为优越。

预执行语句的实例：

bool PDOStatement::bindParam ( mixed $parameter , mixed &$variable [, int $data_type [, int $length [, mixed $driver_options ]]] )

参数说明：
$parameter：参数标识符
$variable：参数标识符对应的变量名
$data_type：明确数据类型使用PDO::PARAM_*常量，如下表所示：

常量名	说明
PDO_PARAM_NULL	代表SQL空数据类型
PDO_PARAM_INT	代表SQL整数类型
PDO_PARAM_STR	代表SQL字符串数据类型
PDO_PARAM_LOB	代表SQL大型数据类型
PDO_PARAM_BOOL	代表SQL布尔值数据类型

$length：数据类型的长度，可选
返回值：成功时返回TRUE，失败时返回FALSE。

<?php 
            //实例化PDO类 
      $db=new PDO("mysql:host=localhost;dbname=msgboard","root","123456"); 
      $db->query("set names 'gbk'");                     //设置编码 
      //预执行sql语句添加两参数 
      $objstatement=$db->prepare("insert into `message`(username,email,content) values (:username,:email,:content)"); 
      $name="name1";                                       //设置变量$name; 
      $mail="email1@email.com";                            //设置变量$mail;
      $mycontent="mycontent1";                             //设置变量$mycontent;    
      $objstatement->bindParam(":username",$name);         //绑定参数$name; 
      $objstatement->bindParam(":email",$mail);            //绑定变量$mail; 
      $objstatement->bindParam(":content", $mycontent) ;    //绑定变量$mycontent;
      $objstatement->execute();                          //插入第一条数据; 
       
      $name="name2";                                       //设置变量$name; 
      $mail="email2@email.com";                            //设置变量$mail; 
      $mycontent="mycontent2";                             //设置变量$mycontent;  
      $objstatement->bindParam(":username",$name);         //绑定参数$name 
      $objstatement->bindParam(":email",$mail);            //绑定变量$mail; 
      $objstatement->bindParam(":content", $mycontent) ;   //绑定变量$mycontent;

      $objstatement->execute();                          //插入第二条数据; 
?>  

使用PDO::prepare()方法预执行SQL语句，然后通过bindParam()方法绑定参数，最后执行SQL语句。

PDO错误处理

1、PDO::ERRMODE_SLIENT

默认模式，有错误时不进行任何操作，PDO只设置错误代码。开发人员可以通过PDO对象中的errorCode()和errorInfo()方法对语句和数据库对象进行检查。

2、PDO::ERRMODE_WARRING

处了设置错误代码外，PDO还将发出一条PHP传统的E_WARRING消息，可以使用常规的PHP错误处理程序捕获该警告。如果只是想看看发生了什么问题，而无意中断应用程序的流程，那么在调式或者测试当中，这种设置很有用。该模式的设置方法如下：

bool PDOStatement::setAttribute(PDO::ATTR_ERRMODE,PDD::ERRMODE_WARING)

3、PDO::ERRMODE_WARRING

处了设置错误代码外，PDO还将抛出一个PDOException并设置器属性，以反映错误代码和错误信息。SQL标准提供了一组用于SQL查询的诊断代码，成为SQLSTATE代码，可以使用PDO对象或PDOStatement对象中的errorCode()方法返回一个SQLSTATE代码。该模式的设置方法如下:

bool PDOStatement::setAttribute (PDO::ATTR_ERRMODE,PDD::ERRMODE_WARING)

下面是PDO设置错误代码的实现：

<?php 
   try {

$db=new PDO("mysql:host=localhost;dbname=msgboard","root","123456");//连接数据库 
    //设置错误模式 
    $db->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_WARNING); 
       }catch (Exception $e)                                   
    { 
        echo '连接失败:'.$e->getMessage();               //打印错误内容 
    } 
?>

PDO的事务处理的实例：

<?php       
             //实例化PDO类 
    $db=new PDO("mysql:host=127.0.0.1;dbname=dbname","root","123456");           
    try {        //设置错误模式 
        $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 
        $db->beginTransaction(); //开始事务 
        //执行语句 
        $db->exec("update `pdo` set `pay`=`pay`-200 where `id`=6");   
        $db->exec("update `pdo` set `pay`=`pay`+200 where `id`=1");   
        $db->commit();                          //事务提交 
    } catch (Exception $e) {   
        $db->rollBack();                    //事务回滚 
        echo "Failed: " . $e->getMessage();    //打印错误内容 
    } 
?> 

 创建ADOdb对象

使用ADOdb时必须包含一个adodb.inc.php，该文件是所有数据库所能使用到的共同的方法和函数。、

下面是连接数据库的代码：

<?php  
     include 'adodb5/adodb.inc.php';                //引入adodb类  
    
     $db=NewADOConnection("mysql");
     $db->Connect("localhost","root","123456","msgboard");
     $db->Execute("set names GBK");
 
     $id=19;
     $rs=$db->Execute("select * from message where id=?",array($id));
     print_r($rs->fields);
?>

注意Connect为非持久性连接，如果需要持久性连接则使用PConnect()创建持久连接。

ADO 4.51以后引入了DSN(Data Source Name)初始化方式，具体如下所示：

<?php 
    include 'adodb5/adodb.inc.php';   //引入adodb类 
    $dsn="mysql://root:123456@localhost/msgboard";  //设置DSN 
    $db=NewADOConnection($dsn);           //连接数据库 
?> 

遍历结果集的时候使用ADODB_FETCH_MODE常量可以设置不同的遍历模式，也可以使用setFetchMode()设置不同的遍历模式。

常见遍历模式如下表所示：

遍历模式	说明
ADO_FETCH_NUM	每行按照字段位置索引的数组，从0开始
ADO_FETCH_BOTH	NUM和ASSOC的直接结合
ADO_FETCH_ASSOC	代表SQL字符串数据类型

对搜索结果集排序范围内取值

selectLimit($sql,$numrows=-1,$offset=-1,$inputarr=false)

 参数说明：

$sql：需要执行SQL语句变量
$numrows：返回几行数据
$offset：从第几条记录开始读取数据(可选)
$inputarr：选项值(可选)

下面是ADOdb selectLimit()的实现

<?php  
     include 'adodb5/adodb.inc.php';            //引入adodb类  
     $db=NewADOConnection("mysql");             //设置连接数据库类型  
     $db->Connect("localhost","root","123456","msgboard");//连接数据库  
     $db->Execute("set names 'GBK'");           //设置编码  
     $rs1=$db->selectLimit("select * from `message`");//取limit两条记录  
     echo '$rs1记录数'.$rs1->RecordCount();      //返回sql语句所影响的记录数3;  
     echo "<br/>";  
       
     $rs2=$db->selectLimit("select * from `message`","2");//取limit两条记录  
     echo '$rs2记录数'.$rs2->RecordCount();      //返回sql语句所影响的记录数 2;   
     echo "<br/>";  
       
     //取limit一条记录,从第两条开始取  
     $rs3=$db->selectLimit("select * from `message`","1","1");  
     echo '$rs3记录数'.$rs3->RecordCount();       //返回sql语句所影响的记录数1;  
?>  

预执行SQL语句

使用prepare()可以预执行SQL语句，引入问好绑定参数，可以使用Execute()方法的第二个参数以数组的方式添加参数值，如下代码所示：

<?php  
     include 'adodb5/adodb.inc.php';              //初始化引入adodb类  
     $db=NewADOConnection("mysql");                //设置连接数据库类型  
     $db->Connect("localhost","root","123456","msgboard");//连接数据库  
     $db->Execute("set names 'GBK'");                    //设置编码  
       
     //预执行Insert语句,引入绑定参数"?"  
     $objstatement=$db->prepare("insert into `message`(username,email,content) values (?,?,?)");  
     $db->Execute($objstatement,array("name1","email1","mycontent1")); //插入一条数据  
       
     $db->Execute($objstatement,array("name2","email2","mycontent2")); //插入另一条数据  
?> 

上面是使用prepare()预执行SQL插入操作，然后通过Execute()方法添加参数，添加两次不同的数据。

 自动执行AutoExecute()方法

使用AutoExecute方法可以简化事情的处理，能够自动生成相应的INSERT或者UPDATE语句并执行。

AutoExecute($table, $arrFiled, $mode, $where=false, $forceUpdate=true, $magicq=false)

参数说明：

$table：表名
$arrField：数据数组
$mode:指定执行模式
$where:指定where条件
具体的实现如下：

<?php  
     include 'adodb5/adodb.inc.php';            //初始化引入adodb类  
     $db=NewADOConnection("mysql");             //设置连接数据库类型  
     $db->Connect("localhost","root","123456","msgboard");//连接数据库  
     $db->Execute("set names 'GBK'");           //设置编码  
     $values['username']="myname";                    //设置列name值  
     $values['email']="myemail";  //设置列pay值  
     $values['content']="mycontent";
     //进行自动执行插入数据操作  
     $db->AutoExecute("pdo",$values,"INSERT");  
?> 

上面是使用AutoExecute()方法将$values中的数据插入到PDO数据表中
下面来看ADOdb执行自动修改语句的实现：

<?php  
     include 'adodb5/adodb.inc.php';            //初始化引入adodb类  
     $db=NewADOConnection("mysql");             //设置连接数据库类型  
     $db->Connect("localhost","root","123456","msgboard");//连接数据库  
     $db->Execute("set names 'GBK'");           //设置编码  
     $values['username']="update";                    //设置列name值  
     $values['email']="myemail";  //设置列pay值  
     $values['content']="mycontent";
     //进行自动执行插入数据操作  
     $db->AutoExecute("adodb",$values,"UPDATE","id=1");  
?> 

使用AutoExecute()方法自动修改了id等于1的数据。

ADOdb其他的常用功能

1、rs2html()函数

ADOdb的rs2html将传入ADORecordSet对象并转换为HTML表格数据，注意转化时必须引入tohtml.inc.php
格式：
rs2html($adorecordset,[$tableheader_attributes],[$col_titles])
参数说明：
$adorecordset:记录集变量名
$tableheader_attribute:设置表格头部信息（可选）
$col_title：列名（可选）。
接下来通过下面示例来看rs2html()函数的功能。

<?php  
    include 'adodb5/tohtml.inc.php';     //引入tohtml.php  
    include 'adodb5/adodb.inc.php';      //引入adodb类  
    $db=NewADOConnection("mysql");       //设置连接数据库类型  
    $db->Connect("localhost","root","123456","msgboard");//连接数据库  
    $db->Execute("set names 'GBK'");     //设置编码  
    $sql="select * from `msgboard`";        //sql查询语句  
    $rs=$db->Execute($sql);              //执行sql语句  
    rs2html($rs);                        //输出内容  
?> 

在浏览器中可以看到rs2html()函数自动将数据转换为HTML表格数据。

2、ADOdb实现自动分页效果

分页时必须引入adodb-pager.ini.php文件，其封装了一个分页的类。为了能够在分页之间传输数据，应该使用session控制，使用session_start()启动session。

下面通过示例来看实现分页操作的实现

<?php  
     include 'adodb5/adodb.inc.php';                  //引入adodb类  
     include 'adodb5/adodb-pager.inc.php';            //引入分页组件  
     $db=NewADOConnection("mysql");                //设置连接数据库类型  
     $db->Connect("localhost","root","123456","msgboard");//连接数据库  
     $db->Execute("set names 'GBK'");                    //设置编码      
     session_start();                                //启用session  
     $sql="select * from `msgboard`";                   //sql查询语句  
     $pager=new ADODB_Pager($db, $sql);              //构造ADOdb分页函数  
     $pager->Render($rows_per_page=2);          //显示分页，并设置每页显示两条数据  
     ?>  

首先构造了ADOConnection和ADODB_Pager对象，分别用于数据库连接和数据分页的对象。然后使用ADODB_Pager对象进行分页，使用Render()方法指定每页所显示的记录数，如果没有指定值，则默认每页显示10条记录。

 3、ADOdb缓存应用

使用CacheExecute()函数可以开启缓存，使用缓存前必须使用$ADODB_CACHE_DIR常量设置缓存存放路径。CacheExecute()有两个参数：第一个是缓存文件将被保留的时间，以秒计时；第二个参数是SQL声明。第一个参数是可选的，如果没有限定时间，那么默认是3600s。缓存文件被命名为adodb_*.cache，用户可以在文件系统中安全的将其删除。需要注意的是要使用缓存方法，需要将PHP的参数magic_quotes_runtime设置为off。用户可以根据需要，在运行时修改它的值：set_magic_quotes_runtime(0)；也可以在任何时候，通过调用CacheFlush()函数删除缓存。

格式：

CacheExecute([$secs2cache,] $sql, $inputarr=false)

参数说明：

$secs2cache:缓存时间

$sql：使用缓存的SQL语句

下面是ADOdb缓存应用的实现：

<?php  
    include 'adodb5/tohtml.inc.php';     //引入tohtml.php  
    include 'adodb5/adodb.inc.php';      //引入adodb类  
    $db=NewADOConnection("mysql");       //设置连接数据库类型  
    $db->Connect("localhost","root","123456","msgboard");//连接数据库  
    $db->Execute("set names 'GBK'");     //设置编码  
    
    $ADODB_CACHE_DIR='cache';
    $sql="select * from `message`";        //sql查询语句  
    $rs=$db->CacheExecute(60,$sql);        //执行sql语句，缓存60s
    rs2html($rs);                        //输出内容  
?>

首先引入adodb类和tohtml类，连接数据库；接着设置缓存路径，使用CacheExecute()函数执行SQL语句，并且设置缓存时间为60s；最后使用rs2html()输出内容。

4、缓存查询内容

使用CacheSelectLimit()函数可以缓存SQL查询排序语句。

格式：

参数说明：
$sql：需要执行的SQL语句变量
$numrows：返回数据的数量
$offset：偏移量（从第几条开始返回）
$inputarr：数据数组
$secs2cache：缓存时间（可选）
接下来看ADOdb查询缓存内容的实现

<?php 
     include 'adodb5/adodb.inc.php';                    //引入adodb类 
     $db=NewADOConnection("mysql");                     //设置连接数据库类型 
     $db->Connect("localhost","root","123456","msgboard");//连接数据库 
     $db->Execute("set names 'GBK'");                    //设置编码 
     $ADODB_CACHE_DIR="cache";                          //设置缓存路径 
     $db->cacheSecs=60;                                 //设置缓存时间 
     $rs=$db->cacheSelectLimit("select * from `message`",10);//缓存排序查询,获取前10条的数据 
     if($rs)                                          //if条件 
     { 
        while(!$rs->EOF)                             //循环$rs结果集 
        { 
         print_r($rs->fields); 
         $rs->MoveNext();                            //指针向下移动 
        } 
     }   
?>

ADOdb的事务处理

ADOdb开始事务

当对象开始第一个事务操作时，BeginTrans()函数会先把autoCommit模式关闭。在MySql中SQL语法为SET AUTOCOMMIT=0，在MySql中使用事务必须不能使用老式的MyISAM类型的表。一般使用InnoDB类型的表来使用MySql的事务功能。如果事务没有提交（即没有执行COMMIT命令），数据库连接关闭时它会自动回滚。

ADOdb事务提交

使用CommitTrans()提交事务

ADOdb事务回滚

使用RollbackTrans()回滚事务

ADOdb的事务实例如下：

<?php 
     include 'adodb5/adodb.inc.php';                    //引入adodb类 
     $db=NewADOConnection("mysqli");                    //设置连接数据库类型 
     $db->Connect("localhost","root","123456","msgboard");//连接数据库 
     $db->Execute("set names 'GBK'");                    //设置编码 
     //开始一个事务，如果开始失败将返回false，将执行条件里的内容。 
     if($db->StartTrans()==false) 
     { 
        echo "ADOdb事务开始失败"; 
     } 
    $db->Execute("update `adodb` set `pay`=`pay`-200 where `id`=2");//第1条SQL语句 
    $db->Execute("update `adodb` set `pay`=`pay`+200 where `id`=3");//第2条SQL语句 
     $db->CompleteTrans();                              //提交事务 
?>

上例中连接说数据库MySql时使用了mysqli，而不能直接使用MySql，这是ADOdb的限制。如有一条失败，则全部返回。