PEAR DB 初学笔记

1、数据查询

i. DB_common::getAll() DB_FETCHMODE_ORDERED 、 DB_FETCHMODE_ASSOC 、 DB_FETCHMODE_OBJECT

ii. DB_common::getRow()

iii. DB_common::getAssoc()

iv. DB_common::getCol()

v. DB_common::getOne()

 <!--

 PHP PEAR DB类部分函数说明：更多函数可参考pear/db.php和pear/db/common.php

 connect()：数据库链接函数

 query()：SQL语句执行函数

 execute()：SQL语句执行函数，与query()函数使用方式略有不同，具体可参考pear/db/common.php文件

 setFetchMode()：设定返回记录集是数字索引数组还是关联数组或者对象

 numRows()：返回记录集有多少行

 numCols()：返回记录集有多少列

 free()：释放记录集

 disconnect()：关闭数据库链接

 affectedRows()：操作影响的记录行数

 isManip()：判断一个查询是数据处理还是数据定义操作

 -->

 <?php

 //引入PDB库

 require_once("DB.php");

 //设定访问的数据库、登录名、密码、主机

 $userName = 'root';

 $password = 'a12345';

 $hostName = 'localhost';

 $dbName = 'db_chengxl';

 //设定DSN参数，并进行数据库链接，我连接的数据库为Mysql

 $dsn = "mysql://$userName:$password@$hostName/$dbName";

 $dbCon = DB::connect($dsn);

 //错误处理

 if (DB::isError($dbCon)) {

     die ($dbCon->getMessage());

 }

 //创建数据表，并插入测试数据

 /*

 $sql = "CREATE TABLE cxl (" .

     "`id` INT( 11 ) UNSIGNED NOT NULL ," .

     "`name` VARCHAR( 30 ) CHARACTER SET gbk COLLATE gbk_chinese_ci NOT NULL ," .

     "`age` INT( 2 ) NOT NULL ," .

     "`birthday` VARCHAR( 30 ) CHARACTER SET gbk COLLATE gbk_chinese_ci NOT NULL ," .

     "`sex` INT( 1 ) NOT NULL ," .

     "PRIMARY KEY (  `id` )" .

     ") ENGINE = MYISAM CHARACTER SET gbk COLLATE gbk_chinese_ci";

 $result = $dbCon->query($sql);

 if (DB::isError($result)) {

     die ($result->getMessage());

 }

 $sql = "insert into cxl(id,name,age,birthday,sex) values(1,'cxl',1,'2009-05-13',1),(2,'cxl',1,'2009-05-13',1),(3,'cxl',1,'2009-05-13',1)";

 $result = $dbCon->query($sql);

 if (DB::isError($result)) {

     die ($result->getMessage());

 }*/

 //setFetchMode函数是PHP PEAR DB让用户设定返回记录集是数字索引数组还是关联数组或者对象，

 //此处我设定为关联数组的形式。默认DB_FETCHMODE_ORDERED模式，

 //其他两种模式为DB_FETCHMODE_ASSOC与DB_FETCHMODE_OBJECT

 //获取数据

 /*

 $dbCon->setFetchMode(DB_FETCHMODE_ASSOC);

 $sql = "select * from cxl";

 $result = $dbCon->query($sql);

 if (DB::isError($result)) {

     die ($result->getMessage());

 }

 for ($i = 0; $i < $result->numRows(); $i++) {

     $info = &$result->fetchRow();

     echo "name:" . $info['name'];

     echo "birthday:" . $info['birthday'] . "<br>";

 }

 */

 //总数

 /*

  * $colCount = $result->numCols();

  * echo "<tr><td colspan=\"".$colCount."\">共找到".$result->numRows()."位用户</td></tr>";

 */

 //function &getOne($query, $params = array())

 //执行查询，并返回结果集中第一行第一列的数据。$params是参数值，如果后端数据库支持，将调用prepare/execute来使用这些参数。

 /*

 $sql = "select * from cxl";

 $last = $dbCon->getOne($sql);

 if(DB::isError($last)){

     echo "出错:".DB::errorMessage($last);

 }

 echo "id:".$last;*/

 //function &getAll($query, $fetchmode = DB_FETCHMODE_DEFAULT, $params = array())

 //返回包含结果集中全部记录的数组。注意，如果你的结果集很大，不要使用这个函数。

 /*

   $sql ="select * from cxl limit 1000";

   $list = $dbCon->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 &getCol($query, $col = 0, $params = array())

 //执行查询，并返回包含结果集中指定字段列的值的数组。

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

 /*$sql = "select id ,age,name from cxl order by age desc limit 100";

 $row = $dbCon->getCol($sql,1);

 if(DB::isError($row)){

     echo "出错：".DB::errorMessage($row);

 }

 for($i=0;$i<count($row);$i++){

     echo "<tr>$row[$i]</tr>";

 }*/

 //function &getRow($query, $fetchmode = DB_FETCHMODE_DEFAULT, $params = array())

 //执行查询，请返回结果集的第一条记录。

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

 /*

 $sql = "select * from cxl order by id desc";

 $row = $dbCon->getRow($sql);

 if(DB::isError($row)){

     echo "出错:".DB::errorMessage($row);

 }

 for($i=0;$i<count($row);$i++){

     echo "<td>$row[$i]</td>";

 }

 */

 //function &getAssoc($query, $force_array = false, $params = array())

 //执行查询，并返回一个关联数组。

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

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

 /*

 $sql = "select id,name,age from cxl limit 100";

  $userinfo = $dbCon->getAssoc($sql);

 if (DB::isError($userinfo)) {

     die("错误！" . DB::errorMessage($userinfo));

 }

 //var_dump($userinfo);

 if (empty($userinfo)) {

     echo "warning:NO users!";

     return;

 }

     $info = $userinfo['2'];

     if (empty($info)) {

         echo "没有这个用户信息！";

     }

     print_r($info);

     //var_dump($info);

 */

 //自动增长（Sequences）

 //Sequences 为数据行提供独一无二的ID标识。如果熟悉MySQL之类的话，可以把它想象为AUTO_INCREMENT.它非常简单，

 //首先你获取一个ID，然后在这个ID所在的行插入你所需要记录的数据。可以为你的表设置更多的Sequences，

 //只需要保证在任何特殊的表中都使用一样的sequence就行。

 // Get an ID (if the sequence doesn't exist, it will be created)

 $id = $dbCon->nextId(cxl);

 $sql = "insert into cxl(id,name,age,birthday,sex) values($id,'cxl',1,'2009-05-13',1)";

 // Use the ID in your INSERT query

  //$res = $dbCon->query("INSERT INTO cxl (id,name) VALUES ($id,'foo')");

  $res = $dbCon->query($sql);

 if(DB::isError($res)){

     echo "出错：".DB::errorMessage($res);

 }

 echo "<tr><td>当前插入数据的ID:$id</td></tr>";

 //释放

 $result->free();

 //关闭连接

 $dbCon->disconnect();

 ?>

2、数据插入、更新：autoExecute()

 <?php

 //引入PDB库

 require_once("DB.php");

 //设定访问的数据库、登录名、密码、主机

 $db = &DB::connect('mysql://root:a12345@localhost/db_chengxl');

 //错误处理

 if (DB::isError($db)) {

     die ($db->getMessage());

 }

 $table_name = 'user';

 //插入的数据

 $fields_values = array(

     'id' => '1',

     'name' => 'Darlin',

     'country' => 'Acewill',

 );

 //修改的数据

 $fields1_values = array(

    // 'id' => '1',

    // 'name' => 'Darlin',

     'country' => 'ACEWILL'//这里填写希望修改后的数据,

 );

 //Using autoExecute() in insert mode

 //$res = $db->autoExecute($table_name, $fields_values, DB_AUTOQUERY_INSERT);

 //Using autoExecute() in update mode

 $res = $db->autoExecute($table_name, $fields1_values, DB_AUTOQUERY_UPDATE);

 //用这个方法没有效果

 //$res = $db->autoExecute($table_name, $fields_values, DB_AUTOQUERY_UPDATE, "country = 'Japan'");

 if (PEAR::isError($res)) {

     die($res->getMessage());

 } else {

     echo "操作成功!</br>";

 }

 ?>

以上资料均来源网络，

PHP PEAR DB类安装与使用实例详解：http://www.alixixi.com/program/a/2011101775410.shtml

PEAR：创建中间的数据库应用层1：http://www.alixixi.com/program/a/2008020831340.shtml

PEAR：创建中间的数据库应用层2：http://www.alixixi.com/program/a/2008020831341.shtml