数据库抽象层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。

相关文章

Oracle数据库定时备份脚本方式(Linux)

Oracle数据库定时备份脚本方式(Linux)

《Oracle数据库定时备份脚本方式(Linux)》文章介绍Oracle数据库自动备份方案,包含主机备份传输与备机解压导入流程,强调需提前全量删除原库数据避免报错,并需配置无密传输、定时任务及验证脚本... 目录说明主机脚本备机上自动导库脚本整个自动备份oracle数据库的过程（建议全程用root用户）总结
阅读更多...
虚拟机Centos7安装MySQL数据库实践

虚拟机Centos7安装MySQL数据库实践

《虚拟机Centos7安装MySQL数据库实践》用户分享在虚拟机安装MySQL的全过程及常见问题解决方案,包括处理GPG密钥、修改密码策略、配置远程访问权限及防火墙设置,最终通过关闭防火墙和停止Net... 目录安装mysql数据库下载wget命令下载MySQL安装包安装MySQL安装MySQL服务安装完成
阅读更多...
MySQL进行数据库审计的详细步骤和示例代码

MySQL进行数据库审计的详细步骤和示例代码

《MySQL进行数据库审计的详细步骤和示例代码》数据库审计通过触发器、内置功能及第三方工具记录和监控数据库活动,确保安全、完整与合规,Java代码实现自动化日志记录,整合分析系统提升监控效率,本文给大... 目录一、数据库审计的基本概念二、使用触发器进行数据库审计1. 创建审计表2. 创建触发器三、Java
阅读更多...
SQL server数据库如何下载和安装

SQL server数据库如何下载和安装

《SQLserver数据库如何下载和安装》本文指导如何下载安装SQLServer2022评估版及SSMS工具,涵盖安装配置、连接字符串设置、C#连接数据库方法和安全注意事项,如混合验证、参数化查... 目录第一步：打开官网下载对应文件第二步：程序安装配置第三部：安装工具SQL Server Manageme
阅读更多...
C#连接SQL server数据库命令的基本步骤

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用：如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.
阅读更多...
Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

《Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式》本文详细介绍如何使用Java通过JDBC连接MySQL数据库,包括下载驱动、配置Eclipse环境、检测数据库连接等关键步骤,... 目录一、下载驱动包二、放jar包三、检测数据库连接JavaJava 如何使用 JDBC 连接 mys
阅读更多...
MySQL数据库中ENUM的用法是什么详解

MySQL数据库中ENUM的用法是什么详解

《MySQL数据库中ENUM的用法是什么详解》ENUM是一个字符串对象,用于指定一组预定义的值,并可在创建表时使用,下面：本文主要介绍MySQL数据库中ENUM的用法是什么的相关资料,文中通过代码... 目录mysql 中 ENUM 的用法一、ENUM 的定义与语法二、ENUM 的特点三、ENUM 的用法1
阅读更多...
Java中调用数据库存储过程的示例代码

Java中调用数据库存储过程的示例代码

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友... 目录一、存储过程概述二、Java调用存储过程的基本javascript步骤三、Java调用存储过程示
阅读更多...
Go语言数据库编程GORM 的基本使用详解

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁
阅读更多...
嵌入式数据库SQLite 3配置使用讲解

嵌入式数据库SQLite 3配置使用讲解

《嵌入式数据库SQLite3配置使用讲解》本文强调嵌入式项目中SQLite3数据库的重要性,因其零配置、轻量级、跨平台及事务处理特性,可保障数据溯源与责任明确,详细讲解安装配置、基础语法及SQLit... 目录0、惨痛教训1、SQLite3环境配置（1）、下载安装SQLite库（2）、解压下载的文件（3）、
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2