จากนั้นทำการแก้ไขไฟล์ php.ini และเพิ่มไดเรคทอรี /usr/local/lib/php4/pear ไปใน include_path ถ้าเราไม่ต้องการแก้ไขไฟล์ php.ini เราสามารถใช้คำสั่ง ini_set('include_path', 'path_to_pear'); ใน source code ของเราได้

รูปแบบ DNS connection string ที่สมบูรณ์ คือ

phptype(dbsyntax)://username:password@protocol+hostspec/database

แต่เราสามารถใช้ DNS ในรูปแบบต่างๆ เหล่านี้ได้

         
mysql  -> MySQL
pgsql  -> PostgreSQL
ibase  -> InterBase
msql   -> Mini SQL
mssql  -> Microsoft SQL Server
oci8   -> Oracle 7/8/8i
odbc   -> ODBC (Open Database Connectivity)
sybase -> SyBase
ifx    -> Informix
fbsql  -> FrontBase               

<?php
...

//เมื่อเราติดต่อ database และได้ DB object มาแล้ว เราสามารถดึงข้อมูลจาก database ได้ดังนี้
$sql = "select * from clients";

//ถ้าเราดึงข้อมูลโดยใช้คำสั่ง SELECT เราจะได้ DB Result object กลับมาจากการใช้คำสั่ง $db->query ถ้าเราไม่ได้ใช้ SELECT เราจะได้ค่า DB_OK กลับมาแทน และถ้าไม่สามารถดึงข้อมูลได้ เราจะได้ค่า DB Error object กลับมา
$result = $db->query($sql);

//อย่าลืมเช็คค่า $result ที่ได้มาไม่ได้ error โดยใช้
if (DB::isError($result))
{
    die($result->getMessage());
}
...
?>

<?php
...

//หลังจากที่เราได้ DB Result object แล้ว สามารถอ่านข้อมูลในแต่ละแถวไปเรื่อยจนกว่าจะหมด
while ($row = $result->fetchRow())
{
    $id = $row[0];
}
?>

<?php
...

while ($result->fetchInto($row))
{
    $id = $row[0];
}
?>

<?php
$res = $db->query('select id, name, email from users');
$row = $res->fetchRow($mode);

// การใช้ $mode = DB_FETCHMODE_ORDERED เราจะได้ array ที่เรียงตามลำดับข้อมูล
$row = array
(
    0 => <column "id" data>,
    1 => <column "name" data>,
    2 => <column "email" data>
);
$id = $row[0];

// การใช้ $mode = DB_FETCHMODE_ASSOC จะได้ array ที่มีความสัมพันธ์กับชื่อคอลัมน์ เป็นคีย์ของ array
$row = array
(
    'id' => <column "id" data>,
    'name' => <column "name" data>,
    'email' => <column "email" data>
);
$id = $row['id'];

// การใช้ $mode = DB_FETCHMODE_OBJECT จะได้ DB_ROW object พร้อมกับชื่อคอลัมน์เป็น property
$row = db_row Object
(
    [id] => <column "id" data>,
    [name] => <column "name" data>,
    [email] => <column "email" data>
);
$id = $row->id;
?>

<?php
...

// 1) กำหนด mode ต่อการเรียกข้อมูลแต่ละครั้ง
while ($row = $result->fetchRow(DB_FETCHMODE_ASSOC))
{
    [..]
}

while ($result->fetchInto($row, DB_FETCHMODE_ASSOC))
{
    [..]
}

// 2) กำหนด mode สำหรับการเรียกทุกครั้ง
$db = DB::connect($dsn);

// การกำหนดเช่นนี้ จะเป็นการกำหนด default fetch mode สำหรับ Pear DB ในทุกครั้งที่ดึงข้อมูล
$db->setFetchMode(DB_FETCHMODE_ASSOC);
$result = $db->query(…);
while ($row = $result->fetchRow())
{
    $id = $row['id'];
}
?>

<?php
...

// กำหนดแถวที่ต้องการเริ่ม fetch
$from = 50;

// กำหนดจำนวนแถวต่อ page
$res_per_page = 10;

// กำหนดแถวสุดท้ายที่ต้องการ fetch สำหรับ page นี้
$to = $from + $res_per_page;
foreach (range($from, $to) as $rownum)
{
    if (!$row = $res->fetchRow($fetchmode, $rownum))
    {
        break;
     }
    $id = $row[0];
    ...
}
?>

<?php
require_once 'DB.php';
$db = DB::connect('pgsql://postgres@unix+localhost/clients_db');

// getOne จะดึงข้อมูล result แรกของคอลัมน์แรกจาก query
$numrows = $db->getOne('select count(id) from clients');

// getRow จะ fetch ข้อมูลแถวแรก และส่งกลับมาเป็น array
$sql = 'select name, address, phone from clients where id=1';
if (is_array($row = $db->getRow($sql)))
{
    list($name, $address, $phone) = $row;
}

// getCol จะส่งค่า array ที่เป็นข้อมูลของคอลัมน์ที่ต้องการ เราสามารถใส่เลขที่คอลัมน์ที่ต้องการเป็นพารามิเตอร์ตัวที่สองได้ จากคำสั่งนี้เราจะได้ผลลัพธ์ของ array คือ
// $all_client_names = array('Stig', 'Jon', 'Colin');
$all_client_names = $db->getCol('select name from clients');

// สำหรับ getAssoc() และ getAll() สามารถอ่านรายละเอียดได้จาก pear/DB/common.php

?>

<?php
...
$db = DB::connect($dsn);
$sql = 'select * from clients';
$res = $db->query($sql);

// อย่าลืมเช็คค่า result ที่ได้กลับมาว่าเป็น Pear Error object หรือเปล่า ถ้าได้ข้อความ เช่น "DB_error: database not capable" หมายความว่า database backend ของเราไม่สนับสนุนการทำงานนี้

// จำนวนแถว
echo $res->numRows();

// จำนวนคอลัมน์
echo $res->numCols();

// ข้อมูลตารางข้อมูล
print_r ($res->tableInfo();

// จำนวนแถวที่ถูกกระทบ
$sql = "delete from clients";

// การใช้คำสั่งนี้จะไม่มีการ return ค่า result object
$db->query($sql);
echo 'I have deleted ' .$db->affectedRows() . 'clients';
?>

<?php
...

// ได้ค่า ID (ถ้า sequence ที่เราเรียกไม่มีอยู่ มันจะถูกสร้างขึ้นมาอัตโนมัติ
$id = $db->nextID('mySequence');

// ใช้ ID ใน INSERT query
$res = $db->query("INSERT INTO myTable(id, text) VALUES ($id, 'foo')");
...
?>

<?php
...

// ตัวอย่าง code ต่อไปนี้ยังไม่ได้ทำการทดสอบ

// ตัวอย่างการ insert ข้อมูล
$alldata = array
(
    array(1, 'one', 'en'),
    array(2, 'two', 'to'),
    array(3, 'three', 'tre'),
    array(4, 'four', 'fire'),
);
$sth = $dbh->prepare("INSERT INTO numbers VALUES(?,?,?)");
foreach ($alldata as $row)
{
    $dbh->execute($sth, $row);
}

// ตัวอย่างการใส่ไฟล์ลงในตารางข้อมูล
$myfile = "/tmp/image.jpg";
$sth = $dbh->prepare('INSERT INTO images (?, &)');
$dbh->execute($sth, array("This is me", $myfile));

// สามารถใช้พารามิเตอร์แบบ array ใน getXxx ได้เช่นกัน
$ver = $dbh->getOne("SELECT stableversion FROM packages WHERE name = ?", array($package));
?>

/* จาก DB_(driver) object */

<?php
...

// ได้ค่า object
$db = DB.connect('mysql://user:pass@localhost/my_db');

// กำหนดตัวเลือก
$db->setErrorHandling();
$db->setFetchmode();

// ข้อมูล
$db->affectedRows();
$db->tableInfo();

// จัดการฐานข้อมูล
$db->query();

// fetch ข้อมูล
$db->nextId();
$db->getOne();
$db->getRow();
$db->getCol();
$db->getAssoc();
$db->getAll();

// คำสั่งที่เกี่ยวข้องกับการ execute
$db->quote();
$db->prepare();
$db->execute();
$db->executeMultiple();

// รายการ Transaction
$db->autoCommit();
$db->commit();
$db->rollback();

// Disconnection
$db->disconnect();

/* จาก DB_result objects */

// ได้ค่า object
$res = $db->query('select * from foo');

// fetch ข้อมูล
$res->fetchRow();
$res->fetchInto();

// ข้อมูล result
$res->numCols();
$res->numRows();
$res->tableInfo();

// Free
$res->free();

/* จาก DB_error objects */

// ได้ค่า object
$error = $db->query('select * from no_table');
$error->getMessage();
$error->getDebugInfo();
$error->toString();
?>

<?php

// ข้อความที่ต้องการรายงาน
error_reporting (E_ALL ^ E_NOTICE);

// function นี้จะจัดการเกี่ยวกับการรายงาน error ทั้งหมด
function my_error_handler ($errno, $errstr, $errfile, $errline)
{
    echo "In $errfile, line: $errline\n<br>$errstr";
}
set_error_handler ('my_error_handler');
$db = DB::connect('pgsql://postgres@localhost/no_db');
...
?>

<?php
require_once 'DB.php';

// กำหนด default action เมื่อเกิด error
PEAR::setErrorHandling(PEAR_ERROR_DIE);

// จากนี้ เราไม่ต้องเช็ค error อีกต่อไป
$db = DB::connect('pgsql://postgres@localhost/my_database');
$res = $db->query('select id from no_table');

// จากตรงนี้ การทำงานจะถูกยกเลิก และข้อความ error จะแสดงขึ้นมา
...
?>

<?php

// กำหนด application environment นั่นคือ ระบุ error ที่เราต้องการให้แสดงขึ้นมา
define ('DEBUG_ENV', true);

// Function นี้จะจัดการ error ทั้งหมดที่เกิดขึ้น
function handle_pear_error ($error_obj)
{
    // ใช้ในขณะที่กำลังพัฒนาโปรแกรม
    if (DEBUG_ENV)
    {
        die ($error_obj->getMessage()."\n".$error_obj->getDebugInfo());
    }
    // ใส่ข้อความที่เข้าใจง่าย เมื่อนำไปใช้งานจริง
    else
    {
        die('Sorry your request cannot be processed now. Try again later');
    }
}

require_once 'DB.php';

// เมื่อเกิด error จะเรียก function "handle_pear_error" ขึ้นมา
// เราสามารถใช้ object เป็น Pear error ก็ได้ เช่น
// setErrorHandling(PEAR_ERROR_CALLBACK, array($object, 'method_name');
PEAR::setErrorHandling(PEAR_ERROR_CALLBACK, 'handle_pear_error');
$db = DB::connect('pgsql://postgres@localhost/site_db');
$res = $db->query('select id from no_table');

// จากตรงนี้ การทำงานจะถูกยกเลิก และ function "handle_pear_error" จะถูกเรียกขึ้นมา โดยใช้ error object เป็น argument แรก
while ($row = $res->fetchRow())
{
    ...
}
...
?>

<?php
error_reporting (E_ALL ^ E_NOTICE);

// function นี้จะจัดการ error ที่ถูก report จาก PHP ทั้งหมด
function php_error_handler ($errno, $errstr, $errfile, $errline)
{
    die ("In $errfile, line: $errline\n<br>$errstr");
}
set_error_handler ('php_error_handler');

// function นี้จะดักจับ error ที่เกิดจาก Pear
// แปลงให้เป็น PHP error และส่งมาที่ php_error_handler
function pear_error_handler ($err_obj)
{
    $error_string = $err_object->getMessage() . '<br>' . $error_obj->getDebugInfo();
    trigger_error ($error_string, E_USER_ERROR);
}
require 'DB.php';
PEAR::setErrorHeadling (PEAR_ERROR_CALLBACK, 'pear_error_handler');

// จัดการกับ error ที่เกิดขึ้น
$db = DB::connect('pgsql://postgres@localhost/no_db');
...
?>