PEAR:创建中间的数据库应用层2

创建|数据|数据库

function errorMessage($dbcode)
返回DB错误文本信息。

function &raiseError($code = DB_ERROR, $mode = false, $level = false,$debuginfo = false, $nativecode = false)
抛出一个错误。这个函数由DB来调用。

function setFetchMode($fetchmode)
设置缺省的fetch模式。

fetchmod有以下几种:
DB_FETCHMODE_DEFAULT :使用缺省的模式
DB_FETCHMODE_ORDERED :每条记录的数据列使用数字索引,从0开始
DB_FETCHMODE_ASSOC :每条记录的数据列使用字段名索引,同查询中的字段名一致
DB_FETCHMODE_FLIPPED:如果结果集是多维的,多条记录多个字段,一般来说返回一个2维数组,第一维是记录号,标明是第几条记录,第2维的数组则使用字段名或数字索引。DB_FETCHMODE_FLIPPED则会交换这个顺序,也就是说,第一层是字段名,第2维才是记录号.

function setOption($option, $value)
设置后端数据库选项。$options,$value分别是选项名和相应的值。

一般不用直接调用,在DB_Common及其子类的构建函数中会调用这个函数。

function getOption($option)
取得某个option的值

function prepare($query)
为execute()准备编译一个查询。对于某些后端数据库,这是通过仿真来实现的。返回编译后的查询句柄,出错则返回一个DB_Error对象。

function execute($stmt, $data = false)
执行编译后的查询。$stmt是由prepare返回的句柄。$data是参数数据,如果你使用的是参数查询,$data将要包含每个?参数的值

例子:
<?php
  /**
   * 下面是执行一个删除查询,从文章表中将指定用户的文章记录删除
   */
  $sql = "delete from artilce where article.userid =$userid";
  $qh = $db->prepare($sql);
  if(DB::isError($qh)){
     return $qh;
  }
  $result = $db->execute($qh);
  return $result;
?>

function executeEmulateQuery($stmt, $data = false)
返回一个实际的查询字符串,供仿真prepare,execute的时候使用,内部函数。如果出错,则返回DB_Error对象

function executeMultiple( $stmt, &$data )
在同一个查询句柄上执行多个查询。$data必需是一个从0开始的数组,这个函数将 依次使用数组中的每一行数据来调用execute。这个函数一般用于参数查询。你可执行一次 查询的编译,然后将不同的参数值放入$data数组,然后就可一次同时执行查询了。需要注意,如果中间某个查询出错,剩余的查询不会继续进行而是返回错误。

function modifyQuery($query)
内部函数,用于后端数据库修正查询,后端数据库实现这个函数,然后返回进行优化和修正后查询串。例子:这是DB_mysql的实现,
<?php
   function modifyQuery($query)
    {
        if ($this->options['optimize'] == 'portability') {
            // "DELETE FROM table" gives 0 affected rows in MySQL.
            // This little hack lets you know how many rows were deleted.
            if (preg_match('/^\s*DELETE\s+FROM\s+(\S+)\s*$/i', $query)) {
                $query = preg_replace('/^\s*DELETE\s+FROM\s+(\S+)\s*$/',
                                      'DELETE FROM \1 WHERE 1=1', $query);
            }
        }
        return $query;
    }
?>

function &query($query)
执行一个查询,查询成功,如果是有结果集的查询,则回一个DB_Result对象,如果没有结果集的查询则返回DB_OK。

出错则返回DB_Error对象。

function &getOne($query, $params = array())
执行查询,并返回结果集中第一行第一列的数据。$params是参数值,如果后端数据库支持,将调用prepare/execute来使用这些参数。

例子:
<?php
$sql = "select id,date from article where  userid= $userid orderby date";
$last = $db->getOne($sql);
if(DB::isError($last)){
   echo "出错:".DB::errorMessage($last);
}
echo "id:".$last;
?>

function &getRow($query, $fetchmode = DB_FETCHMODE_DEFAULT, $params = array())
执行查询,请返回结果集的第一条记录。

$fetchmod 指定fetch模式,如果省略,使用缺省模式。

例子:
<?php
$sql = "select * from articles order by date desc";
$row = $db->getRow($sql);
if(DB::isError($row)){
   echo "出错:".DB::errorMessage($row);
}
for($i=0;$i<count($row;$i++){
   echo "<td>$row[$i]</td>";
}

?>

function &getCol($query, $col = 0, $params = array())
执行查询,并返回包含结果集中指定字段列的值的数组。

$col是要返回的列的索引,可以是整数,或者是关键字段名。

例子:
<?php
$sql = "select id,userid,date from articles order by date desc limit 100";
//只返回用户列表
$row = $db->getCol($sql,1);
if(DB::isError($row)){
   echo "出错:".DB::errorMessage($row);
}

for($i=0;$i<count($row;$i++){
   echo "<tr>$row[$i]</tr>";
}

?>

function &getAssoc($query, $force_array = false, $params = array())
执行查询,并返回一个关联数组。

$force_arry 强制返回数组。如果true,那么即使你的结果集里只有2个字段,那么关键字段对应的值也是一个只有一个元素的

数组。如果false,那么关键字段对应的值是一个标量了。

注意,这个关联数组有些特别:
如果你查询的是"select userid,name,reg_date from user",记录集是:
userid     name       reg_date
test       testor     2001-07-05
test2      teest2     2001-07-06
那么返回的数组是这样的:
array( 'test' => array('testor','2001-0705'),
       'test2'=> array('teest2','2001-07-06'
     )

例子:

<?php
$sql = "select userid,name,reg_date,last_login from users limit 100";
$userinfo = $db->getAssoc($sql);
if(DB::isError($userinfo)){
    die "错误!".DB::errorMessage($userinfo);
}
if(empty($userinfo)){
   echo "warning:NO users!";
   return;
}
/*现在,userinfo里面保存有用户的信息*/
function getUserInfo($user_id=''){
  $info = $userinfo[$user_id];
  if (empty($info){
     echo "没有这个用户信息!";
  }
  return $info;
}
?>

function &getAll($query, $fetchmode = DB_FETCHMODE_DEFAULT, $params = array())
返回包含结果集中全部记录的数组。注意,如果你的结果集很大,不要使用这个函数。

例子:
<?php
  $sql ="select * from users limit 1000";
  $list = $db->getAll($sql);
  if(DB::isError($list)){
     die "数据库错误:".DB::errorMessage($list);
  }
  for ($i=0;$i<count($list);$i++){
       $user = $list[$i];
       echo "<tr>";
       for($j=0;$j<count($user);$j++){
           echo "<td>".$user[$j]."</td>";
       }
       echo "</tr>";
  }
?>

function autoCommit($onoff=false)
指定是否自动提交事务。有的后端数据库不支持。

function commit()
提交当前事务

function rollback()
回滚当前事务

function numRows($result)
返回结果集中的记录数

function affectedRows()
返回上一次查询操作的记录数

function nextId($seq_name, $ondemand = true)
返回指定的sequence的下一个值

function createSequence($seq_name)
创建一个Sequence

function dropSequence($seq_name)
删除一个Sequence

五、 更进一步,创建你自己的中间数据库应用层
到此,我们对于DB类的功能已经有了更深的了解。我们可以基于DB类来创建你自己的数据库应用层了。也许你会问,我为什么还要创建新的类,直接在我的应用程序中使用DB不好么?答案是,当然可以,但是我不推荐。

首先,虽然DB的功能很强大,但是仍然是过于底层的,你的类应该是面向应用的。你的这个数据库层应该屏蔽不需要使用的功能和函数,同时,也要提供一些更'高级'的方法,比如,你的应用程序不应该去联接数据库,释放资源,这些应该是透明的。那么这些工作就要由你的这个类来完成了。

其次,DB仍有一些缺陷,一旦找到比它更好的,你可以迅速地升级。你所要改的只是这个类的方法如何实现,你的应用程序的其他模块不会为此受到影响。

在你设计自己的类的时候,希望能够一些准则:

提供基本的自由的查询接口。包括query,execute.分别对应有结果集和无结果集的查询。
不要使用特定数据库的某些特性,即使因为放弃使用这些特征会给你增加不少的代码量。
尽量屏蔽一些数据库的操作细节,比如连接数据库,释放资源等等。
六、 DB的不足
上面我们讨论了DB的优点和一些使用的方法与技巧。但是,任何事物都不是十全十美的,DB类更是如此,由于DB乃至PEAR的开发时间并不长,因此DB并没有最终全部完成,其中也或多或少地存在一些BUG或者设计上的问题,需要我们在使用中去发现和修正。

MYSQL的问题
问题1:前段我在开发一个项目中,发现DB的MYSQL类有一个问题,那就是当你connect的时候,MYSQL类自动将当前数据库设置为$DSN中的数据库名。以后使用query的时候,都是使用当前数据库。下面是原来connect的代码:
  if ($dsninfo["database"]) {
            if (!mysql_select_db($dsninfo["database"], $conn)) {
                return $this->raiseError(); // XXX ERRORMSG
            }
        }

这导致了一个后来令我费解的问题:

我的项目需要我连接2个数据,假设分别是user和test。test是我的主要数据库,但是我要从第一个数据库中user中取得用户信息,同时test中保存用户的权限信息。我为此做了一个中间的类CV_DB,用来实现我的数据库层。在CV_DB的创建函数中,我连接到指定的数据库,从而我可以这样使用:

$db1 = new CV("user");

$db2 = new CV("test");

后面当我执行,查询某个用户的信息的时候,出现了"该表不存在"的DB错误。但实际上这个表是存在的。最后,我发现原来是DB/mysql.php的问题,因为它的查询使用的是,mysql_query,而不是mysql_db_query,当我连接到第2个数据库的时候,MYSQL的当前数据库变成了第2个,这时我再执行针对第一个数据库的查询,当然会出错。

解决方式有2个,在创建CV的时候不连接到数据库,查询的时候连接,查询完毕后断开。或者,修改DB/Mysql.php。我选择后者,我将上面几行注释,然后将SimpleQuery中的mysql_query 替换成mysql_db_query.

问题2:mysql没有execute,因此它继承使用了DB_common中模拟方式,但是不幸地是,这带来了新的问题,在一些更新查询中,所要更新的数据有? &这2个特殊字符的时候,会出现问题,因为prepare认为这是参数查询的字符,将进行分析,导致无法更新数据。

解决方式也有2个:替换?和&,但是这样要考虑的事情很多。或者:直接使用simpleQuery或者query。

我选择后者,由于我的其他类只和CV――我这个中间数据库应用类打交道,于是,我在CV的execute方法中做了判断,如果是后端数据库是mysql,那么我直接调用simpleQuery,否则,调用后端数据库的prepare和execute。这样,实际的后端数据库对于我项目中的其他应用类是透明的,我可以简单地做相应的调整,这也是我设计数据库应用层的初衷。

DB的开发状态
DB目前仍在不断地开发当中,在DB/下面有一个文件STATUS,它描述了DB类的功能和各个后端数据库的实现情况,下面是PHP4.0.6这个发布中的开发情况:
"x" - 已经实现,但尚未测试implemented, but without tests
"t" - 已经实现,但是一个或多个测试没有通过implemented, but one or more tests fail
"T" - 实现并通过全部测试implemented, passing all tests
"e" - 仿真实现,没有测试emulated, without tests
"E" - 仿真实现,通过全部测试emulated, passing all tests
"n" - 返回 "not capable",没有这个能力提供该项功能
"-" - 没有实现
                   fbsql      ifx      mssql      oci8     pgsql
FEATURE              |  ibase  |  msql   |   mysql |   odbc  |  sybase
simpleQuery          x    x    x    x    x    T    T    x    T    x
numCols              x    x    x    x    x    T    T    x    T    x
numRows              x    n    n    x    x    T    E    n    T    n
errorNative          x    n    x    n    n    T    x    x    T    n
prepare/execute      e    x    e    e    e    E    T    e    E    e
sequences            e    n    n    n    n    E    T    n    T    n
affectedRows         x    n    x    n    n    T    T    n    T    n
fetch modes          x    x    x    x    x    T    T    x    T    x
fetch absolute rows  x    n    x    x    x    x    n    x    x    x
transactions         x    x    n    n    n    n    x    x    x    n
auto-commit          x    x    n    n    n    n    x    x    x    n
error mapping        x    -    e    -    -    T    T    x    E    -
tableInfo            x    n    n    n    n    T    n    n    n    n

七、参考资源
ADODB另一个非常好操纵数据库的PHP程序,DB的绝好的替代者

关于作者
潘凡(Night Sailer):北京赛迪数据有限公司工程师。主要研究兴趣是Perl,PHP与XML的应用,PHP的MVC开发模式,PERL-GTK的使用。您可以通过 E-mail:nightsailer@hotmail.com 跟他联系。  

时间: 2024-10-06 02:39:05

PEAR:创建中间的数据库应用层2的相关文章

PEAR:创建中间的数据库应用层1

创建|数据|数据库    内容: 一. 什么是DB类 二. 为什么要设计抽象的中间数据层 三. DB的使用入门 四. DB_Common 使用参考 五. 更进一步,创建你自己的中间数据库应用层 六. DB的不足 七.参考资源 关于作者 相关内容: 1.用PEAR来写你的下一个php程序 2.常用模块 3.使用PHPDoc轻松建立你的PEAR文档 潘凡 (nightsailer@hotmail.com)北京赛迪网信息技术有限公司2001 年 8 月 对于PHP的应用程序来说,90%以上需要和数据库

mysql-在MYSQL中不能创建并显示数据库

问题描述 在MYSQL中不能创建并显示数据库 我在cmd命令行模式下输入:mysql -uroot;提示成功登录数据库,查询都有哪些数据库:结果我上一次创建的数据库没有显示然后输入create database user;提示:ERROR 1044(42000):Access denied for user ''@'localhost' to database 'user'; 解决方案 没遇到过你这种情况,我也是在网上找到的,你试一试管不管用吧. 方法一:1.关闭mysql # service

创建逻辑备用数据库

创建|数据|数据库 下面的是Logical Standby Database的配置步骤. (下面用到的一些文件的位置都是临时性的,还得做一定的修改) 将主数据库置为FORCE LOGGING模式.在主数据库创建之后做如下操作: SQL>ALTER DATABASE FORCE LOGGING;   确认主数据库是归档的并定义好本地归档.如下: SQL >ALTER SYSTEM SET LOG_ARCHIVE_DEST_1='LOCATION=e:\oracle\oradata\orcl\ar

创建物理备用数据库

创建|数据|数据库   创建物理备用数据库 在创建物理备用数据库之前先查看主数据库的一些信息和对主数据库做好配置. 将主数据库置为FORCE LOGGING模式.在主数据库创建之后做如下操作: SQL>ALTER DATABASE FORCE LOGGING; 确认主数据库是归档的并定义好本地归档.如下: SQL >ALTER SYSTEM SET LOG_ARCHIVE_DEST_1='LOCATION=e:\oracle\oradata\orcl\archive  MANDATORY' S

phpmyadmin教程:使用phpmyadmin创建用户、数据库表的方法

phpmyadmin作为管理Mysql数据库的利器,越来越受到PHP网站开发建设者的欢迎,在此之前我介绍了两篇phpmyadmin入门教程:phpmyadmin3安装配置图解教程和允许phpmyadmin空密码登录的配置方法,今天继续phpmyadmin教程学习,介绍如何使用phpmyadmin创建添加新用户进行用户权限设置以及如何使用phpmyadmin创建数据库表的方法. 在使用phpmyadmin管理Mysql数据库之前,请确保Mysql服务已启动,即 1 net start mysql

动态创建SQL Server数据库、表、存储过程

server|创建|存储过程|动态|数据|数据库 下面是利用SQL语句创建数据库.表.存储过程.视图.索引.规则.修改表.查看数据等的方法.所要增加的控件如下: Imports System.DataImports System.Data.SqlClient Public Class Form1  Inherits System.Windows.Forms.Form  Private ConnectionString As String = "Data Source=.;Initial Cata

用ASP.Net MVC快速创建一个电影数据库应用程

Stephen Walther 从头开始到结束建立了整个数据驱动ASP.NET MVC应用程序.这个教程对于那些刚刚接 触ASP.NET MVC框架以及想要获得一种建立ASP.NET MVC应用程序的过程的新人是一个很好的介绍. 这 个教程的目的就是给你一种"它会是什么样子"去创建ASP.NET MVC应用程序的理念.在这一课中,从开始到结 束,我将直接建立一个完整ASP.NET MVC应用程序.我向你展示如何建立一个简单的数据驱动应用程序,演示如 何列出,创建和编辑数据库记录. 为简

Android创建或升级数据库时执行的语句

  Android创建或升级数据库时执行的语句,如果是创建或升级数据库,请使用带List参数的构造方法,带SQL语句的构造方法将在数据库创建或升级时执行.

Oracle Data Guard创建物理Standby数据库

Oracle Data Guard创建物理Standby数据库 创建物理备库 机器名 a1 a2 IP: 192.168.1.10 192.168.1.20 Net_Name a1 a2 SID a1 a2 DB_UNIQUE_NAME a1 a2 注:主节点上创建数据库a1,备节点上只安装oracle软件不创建任何数据库; 1.配置listener.ora 主节点listener.ora: SID_LIST_LISTENER= (SID_LIST= (SID_DESC= (GLOBAL_DBN