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