数据库抽象层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的限制。如有一条失败,则全部返回。

原文地址:https://www.cnblogs.com/shudonghe/p/2958239.html