数据库抽象层PDO和ADOdb

2023-10-11 19:20
文章标签 数据库 抽象 pdo adodb

本文主要是介绍数据库抽象层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语句，缓存60srs2html($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/archive/2013/03/13/2958239.html

这篇关于数据库抽象层PDO和ADOdb的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/190266。

相关文章

详谈redis跟数据库的数据同步问题

详谈redis跟数据库的数据同步问题

《详谈redis跟数据库的数据同步问题》文章讨论了在Redis和数据库数据一致性问题上的解决方案,主要比较了先更新Redis缓存再更新数据库和先更新数据库再更新Redis缓存两种方案,文章指出,删除R... 目录一、Redis 数据库数据一致性的解决方案1.1、更新Redis缓存、删除Redis缓存的区别二
阅读更多...
oracle数据库索引失效的问题及解决

oracle数据库索引失效的问题及解决

《oracle数据库索引失效的问题及解决》本文总结了在Oracle数据库中索引失效的一些常见场景,包括使用isnull、isnotnull、!=、、、函数处理、like前置%查询以及范围索引和等值索引... 目录oracle数据库索引失效问题场景环境索引失效情况及验证结论一结论二结论三结论四结论五总结ora
阅读更多...
C#实现文件读写到SQLite数据库

C#实现文件读写到SQLite数据库

《C#实现文件读写到SQLite数据库》这篇文章主要为大家详细介绍了使用C#将文件读写到SQLite数据库的几种方法,文中的示例代码讲解详细,感兴趣的小伙伴可以参考一下... 目录1. 使用 BLOB 存储文件2. 存储文件路径3. 分块存储文件《文件读写到SQLite数据库China编程的方法》博客中，介绍了文
阅读更多...
Android数据库Room的实际使用过程总结

Android数据库Room的实际使用过程总结

《Android数据库Room的实际使用过程总结》这篇文章主要给大家介绍了关于Android数据库Room的实际使用过程,详细介绍了如何创建实体类、数据访问对象（DAO）和数据库抽象类,需要的朋友可以... 目录前言一、Room的基本使用1.项目配置2.创建实体类（Entity）3.创建数据访问对象（DAO
阅读更多...
SQL Server数据库磁盘满了的解决办法

SQL Server数据库磁盘满了的解决办法

《SQLServer数据库磁盘满了的解决办法》系统再正常运行,我还在操作中,突然发现接口报错,后续所有接口都报错了,一查日志发现说是数据库磁盘满了,所以本文记录了SQLServer数据库磁盘满了的解... 目录问题解决方法删除数据库日志设置数据库日志大小问题今http://www.chinasem.cn天发
阅读更多...
Oracle数据库执行计划的查看与分析技巧

Oracle数据库执行计划的查看与分析技巧

《Oracle数据库执行计划的查看与分析技巧》在Oracle数据库中,执行计划能够帮助我们深入了解SQL语句在数据库内部的执行细节,进而优化查询性能、提升系统效率,执行计划是Oracle数据库优化器为... 目录一、什么是执行计划二、查看执行计划的方法（一）使用 EXPLAIN PLAN 命令（二）通过 S
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
MySQL数据库宕机，启动不起来，教你一招搞定！

MySQL数据库宕机，启动不起来，教你一招搞定！

作者介绍：老苏，10余年DBA工作运维经验，擅长Oracle、MySQL、PG、Mongodb数据库运维（如安装迁移，性能优化、故障应急处理等）公众号：老苏畅谈运维欢迎关注本人公众号，更多精彩与您分享。 MySQL数据库宕机，数据页损坏问题，启动不起来，该如何排查和解决，本文将为你说明具体的排查过程。 查看MySQL error日志 查看 MySQL error日志，排查哪个表（表空间
阅读更多...
深入理解数据库的 4NF：多值依赖与消除数据异常

深入理解数据库的 4NF：多值依赖与消除数据异常

在数据库设计中， "范式" 是一个常常被提到的重要概念。许多初学者在学习数据库设计时，经常听到第一范式（1NF）、第二范式（2NF）、第三范式（3NF）以及 BCNF（Boyce-Codd范式）。这些范式都旨在通过消除数据冗余和异常来优化数据库结构。然而，当我们谈到 4NF（第四范式）时，事情变得更加复杂。本文将带你深入了解 多值依赖 和 4NF，帮助你在数据库设计中消除更高级别的异常。 什么是
阅读更多...
DM8数据库安装后配置

DM8数据库安装后配置

1 前言 在上篇文章中，我们已经成功将库装好。在安装完成后，为了能够更好地满足应用需求和保障系统的安全稳定运行，通常需要进行一些基本的配置。下面是一些常见的配置项： 数据库服务注册：默认包含14个功能模块，将这些模块注册成服务后，可以更好的启动和管理这些功能；基本的实例参数配置：契合应用场景和发挥系统的最大性能；备份：有备无患；… 2 注册实例服务 注册了实例服务后，可以使用系统服务管理，
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2