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

相关文章

Python调用Orator ORM进行数据库操作

Python调用Orator ORM进行数据库操作

《Python调用OratorORM进行数据库操作》OratorORM是一个功能丰富且灵活的PythonORM库,旨在简化数据库操作,它支持多种数据库并提供了简洁且直观的API,下面我们就... 目录Orator ORM 主要特点安装使用示例总结Orator ORM 是一个功能丰富且灵活的 python O
阅读更多...
使用 sql-research-assistant进行 SQL 数据库研究的实战指南(代码实现演示)

使用 sql-research-assistant进行 SQL 数据库研究的实战指南(代码实现演示)

《使用sql-research-assistant进行SQL数据库研究的实战指南(代码实现演示)》本文介绍了sql-research-assistant工具,该工具基于LangChain框架,集... 目录技术背景介绍核心原理解析代码实现演示安装和配置项目集成LangSmith 配置（可选）启动服务应用场景
阅读更多...
使用Navicat工具比对两个数据库所有表结构的差异案例详解

使用Navicat工具比对两个数据库所有表结构的差异案例详解

《使用Navicat工具比对两个数据库所有表结构的差异案例详解》：本文主要介绍如何使用Navicat工具对比两个数据库test_old和test_new,并生成相应的DDLSQL语句,以便将te... 目录概要案例一、如图两个数据库test_old和test_new进行比较：二、开始比较总结概要公司存在多
阅读更多...
MySQL数据库函数之JSON_EXTRACT示例代码

MySQL数据库函数之JSON_EXTRACT示例代码

《MySQL数据库函数之JSON_EXTRACT示例代码》：本文主要介绍MySQL数据库函数之JSON_EXTRACT的相关资料,JSON_EXTRACT()函数用于从JSON文档中提取值,支持对... 目录前言基本语法路径表达式示例示例 1: 提取简单值示例 2: 提取嵌套值示例 3: 提取数组中的值注意
阅读更多...
查询SQL Server数据库服务器IP地址的多种有效方法

查询SQL Server数据库服务器IP地址的多种有效方法

《查询SQLServer数据库服务器IP地址的多种有效方法》作为数据库管理员或开发人员,了解如何查询SQLServer数据库服务器的IP地址是一项重要技能,本文将介绍几种简单而有效的方法,帮助你轻松... 目录使用T-SQL查询方法1：使用系统函数方法2：使用系统视图使用SQL Server Configu
阅读更多...
SQL Server数据库迁移到MySQL的完整指南

SQL Server数据库迁移到MySQL的完整指南

《SQLServer数据库迁移到MySQL的完整指南》在企业应用开发中,数据库迁移是一个常见的需求,随着业务的发展,企业可能会从SQLServer转向MySQL,原因可能是成本、性能、跨平台兼容性等... 目录一、迁移前的准备工作1.1 确定迁移范围1.2 评估兼容性1.3 备份数据二、迁移工具的选择2.1
阅读更多...
Python中连接不同数据库的方法总结

Python中连接不同数据库的方法总结

《Python中连接不同数据库的方法总结》在数据驱动的现代应用开发中,Python凭借其丰富的库和强大的生态系统,成为连接各种数据库的理想编程语言,下面我们就来看看如何使用Python实现连接常用的几... 目录一、连接mysql数据库二、连接PostgreSQL数据库三、连接SQLite数据库四、连接Mo
阅读更多...
Oracle数据库如何切换登录用户(system和sys)

Oracle数据库如何切换登录用户(system和sys)

《Oracle数据库如何切换登录用户(system和sys)》文章介绍了如何使用SQL*Plus工具登录Oracle数据库的system用户,包括打开登录入口、输入用户名和口令、以及切换到sys用户的... 目录打开登录入口登录system用户总结打开登录入口win+R打开运行对话框，输php入：sqlp
阅读更多...
数据库使用之union、union all、各种join的用法区别解析

数据库使用之union、union all、各种join的用法区别解析

《数据库使用之union、unionall、各种join的用法区别解析》：本文主要介绍SQL中的Union和UnionAll的区别,包括去重与否以及使用时的注意事项,还详细解释了Join关键字,... 目录一、Union 和Union All1、区别：2、注意点：3、具体举例二、Join关键字的区别&php
阅读更多...
查询Oracle数据库表是否被锁的实现方式

查询Oracle数据库表是否被锁的实现方式

《查询Oracle数据库表是否被锁的实现方式》本文介绍了查询Oracle数据库表是否被锁的方法,包括查询锁表的会话、人员信息,根据object_id查询表名,以及根据会话ID查询和停止本地进程,同时,... 目录查询oracle数据库表是否被锁1、查询锁表的会话、人员等信息2、根据 object_id查询被
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2