DB連接實(shí)例

<?php
require_once ‘DB.php‘;

$dsn = ‘mysql://username:password@localhost/dbname‘;
/**
也可以用以下的方式
$dsn = array(
    ‘phptype‘  => ‘pgsql‘,
    ‘username‘ => ‘someuser‘,
    ‘password‘ => ‘a(chǎn)passwd‘,
    ‘hostspec‘ => ‘localhost‘,
    ‘database‘ => ‘thedb‘,
);
*/
//$options是可選的
$options = array(
    ‘debug‘       => 2,
    ‘portability‘ => DB_PORTABILITY_ALL,
);
$db =& DB::connect($dsn, $options);
if (DB::isError($db)) {
    die($db->getMessage());
}

//設(shè)置數(shù)據(jù)庫(kù)的默認(rèn)查詢方式
$db->setFetchMode(DB_FETCHMODE_ASSOC);

//執(zhí)行一個(gè)普通的查詢語(yǔ)句
$res =& $db->query(‘SELECT * FROM products‘);
//取得一個(gè)SQL查詢的結(jié)果集行,列數(shù)
printf("共有%d行,%d列數(shù)據(jù)", $res->numRows(), $res->numCols());
//當(dāng)前表的結(jié)構(gòu)信息
echo ("<pre>");
print_r($db->tableInfo($res));
echo ("</pre>");

//執(zhí)行一個(gè)帶參數(shù)的查詢
$sql  = ‘select  *  from products where products_id < ?‘;
$data = 50;

$res =& $db->query($sql, $data);
//執(zhí)行含有多個(gè)參數(shù)的查詢
$sql  = ‘select * from products where products_volt < ? and products_capacity > ?‘;
$data = array(10, 4000);

$res =& $db->query($sql, $data);

// 記得永遠(yuǎn)要檢查執(zhí)行的動(dòng)作是否有錯(cuò)誤
if (DB::isError($res)) {
    die($res->getMessage());
}
//按默認(rèn)方式DB_FETCHMODE_ORDERED，循環(huán)顯示，輸出結(jié)果,這種方式下，只能以序號(hào)的方式來訪問數(shù)據(jù)字段
while ($row =& $res->fetchRow()) {
    echo $row[0] . "<br />\n";
}

//按DB_FETCHMODE_ASSOC方式，循環(huán)顯示，輸出結(jié)果,這種方式下，以字段名稱的方式來訪問數(shù)據(jù)字段
while ($row =& $res->fetchRow(DB_FETCHMODE_ASSOC)) {
    echo $row[‘id‘] . "\n";
}

//獲取指定范圍的行數(shù)據(jù)
$from = 50;

$resPage = 10;

$to = $from + $resPage;

foreach (range($from, $to) as $rowNum) {
    if (!$row =& $res->fetchRow($fetchmode, $rowNum)) {
        break;
    }
    echo $row[0] . "\n";
}
//釋放資源
$res->free();

//通過getAll()，可以獲取整個(gè)查詢的結(jié)果集
$result = $db->getAll("select * from tablename");
//得到UPDATE/INSERT/DELETE等語(yǔ)句,所影響的行數(shù)
$db->query(‘DELETE * FROM clients‘);
echo ‘I have deleted ‘ . $db->affectedRows() . ‘ clients‘;
//close database connection
$db->disconnect();
?>

Prepare/Execute使用詳解

當(dāng)要多次執(zhí)行一組查詢,只是有些參數(shù)不同時(shí)
INSERT INTO tle_name(col1, col2) VALUES(‘val1’, val2);
INSERT INTO tle_name(col1, col2) VALUES(‘val3’, val4);
……
或者你的語(yǔ)句要符合多個(gè)不同語(yǔ)法的數(shù)據(jù)庫(kù)時(shí)db1: INSERT INTO tbl_name (col1, col2) VALUES (expr1, expr2)
db2: INSERT INTO tbl_name SET col1=expr1, col2=expr2
可以使用prepare/execute語(yǔ)句,以提供更好的兼容性和可擴(kuò)展性能

使用prepare/execute語(yǔ)句,要分2個(gè)步驟
1. 用prepare()來準(zhǔn)備SQL語(yǔ)句:
假設(shè)你有一個(gè)類似于這樣的SQL語(yǔ)句
SELECT surname, name, age
FROM person
WHERE name = ‘name_to_find‘ AND age < age_limit
使用prepare()時(shí),你可以這樣來寫:
SELECT surname, name, age
FROM person
WHERE name = ? AND age < ?

其中的類似于JSP或其它語(yǔ)言中的參數(shù)變量,類似的還有:

2.execute() 把變量傳遞給prepare的SQL語(yǔ)句,然后執(zhí)行它,execute()需要2個(gè)參數(shù),一個(gè)是prepare()調(diào)用時(shí)指定的變量,另一個(gè)就是要傳遞給的變量(可以用數(shù)組)
一個(gè)簡(jiǎn)單的例子
<?php
// 假設(shè)你已經(jīng)有一個(gè)有效的數(shù)據(jù)庫(kù)連接變量$db …
$sth = $db->prepare(‘INSERT INTO numbers (number) VALUES (?)‘);
$db->execute($sth, 1);
$db->execute($sth, 8);
?>
一個(gè)保存圖象到數(shù)據(jù)庫(kù)的例子
假設(shè)數(shù)據(jù)庫(kù)中有一個(gè)test表,它的結(jié)構(gòu)如下:
CREATE TABLE `test` (

  `id` int(11) NOT NULL auto_increment,

  `name` varchar(100) default NULL,

  `image` blob,

  `description` text,

  `note` text,

  PRIMARY KEY  (`id`)

) TYPE=MyISAM
insert.php
<?php
require_once ‘DB.php‘;

$dsn = ‘mysql://username:password@localhost/test‘;
$options = array(
    ‘debug‘       => 2,
    ‘portability‘ => DB_PORTABILITY_ALL,
);
$db =& DB::connect($dsn, $options);
if (DB::isError($db)) {
    die($db->getMessage());
}
$db->setFetchMode(DB_FETCHMODE_ASSOC);

$sth = $db->prepare("INSERT test(name, image) VALUES(?, &)");
$db->execute($sth, array(‘jxyuhua‘, ‘D://websamples//PEAR//Database//welcome.jpg‘));


if (DB :: isError($db)) {
    die($db->getMessage());
}

//$res->free();
$db->disconnect();
?>
存入數(shù)據(jù)庫(kù)之后(注意內(nèi)容大小的限制),你就可以再將內(nèi)容取出來顯示了
顯示的例子
image.php
<?php
require_once ‘DB.php‘;

$dsn = ‘mysql://username:password@localhost/test‘;
$options = array(
    ‘debug‘       => 2,
    ‘portability‘ => DB_PORTABILITY_ALL,
);
$db =& DB::connect($dsn, $options);
if (DB::isError($db)) {
    die($db->getMessage());
}
$db->setFetchMode(DB_FETCHMODE_ASSOC);

$res = $db->query("select image from test where name = ? order by name", $_REQUEST[‘name‘]);

if (DB :: isError($res)) {
    die($res->getMessage());
}
while ($row = $res->fetchRow()) {
    $data = $row[‘image‘];
}
header("Content-type: image/jpeg"); //如果是其它的圖象格式,如GIF,要做相應(yīng)的更改image/gif
echo ($data);
$res->free();
$db->disconnect();
?>
DB允許你一次進(jìn)行一組數(shù)據(jù)庫(kù)操作,例如,你要一次性地插入/更新一批數(shù)據(jù),
<?php
//假設(shè)數(shù)據(jù)庫(kù)已經(jīng)連接
$alldata = array(array(1, ‘one‘, ‘en‘),
                 array(2, ‘two‘, ‘to‘),
                 array(3, ‘three‘, ‘tre‘),
                 array(4, ‘four‘, ‘fire‘));
$sth = $db->prepare(‘INSERT INTO numbers VALUES (?, ?, ?)‘);
foreach ($alldata as $row) {
    $db->execute($sth, $row);
}
?>
以上語(yǔ)句將執(zhí)行等效于下面的SQL語(yǔ)句功能:
INSERT INTO numbers VALUES (‘1‘, ‘one‘, ‘en‘)

INSERT INTO numbers VALUES (‘2‘, ‘two‘, ‘to‘)

INSERT INTO numbers VALUES (‘3‘, ‘three‘, ‘tre‘)

INSERT INTO numbers VALUES (‘4‘, ‘four‘, ‘fire‘)

如果你想更省事一點(diǎn),可以使用executeMultiple()
<?php
//假設(shè)數(shù)據(jù)庫(kù)已經(jīng)連接
$alldata = array(array(1, ‘one‘, ‘en‘),
                 array(2, ‘two‘, ‘to‘),
                 array(3, ‘three‘, ‘tre‘),
                 array(4, ‘four‘, ‘fire‘));
$sth = $db->prepare(‘INSERT INTO numbers VALUES (?, ?, ?)‘);
$db->executeMultiple($sth, $alldata);
?>

有沒有這樣的經(jīng)歷,當(dāng)你在一個(gè)表中加了(或刪除)一些字段之后,你原來的SQL語(yǔ)句就必須要重新寫過,這樣是不是很煩人?
例如,你有一個(gè)user表,它有3個(gè)字段(id, name, country),你以前的INSERT/UPDATE語(yǔ)句:
INSERT INTO user (id, name, country) VALUES (?, ?, ?)

UPDATE user SET id=?, name=?, country=? WHERE ...

當(dāng)你增加了一個(gè)字段(假設(shè)是birthday)之后,你就必須重新你以前的INSERT/UPDATE語(yǔ)句,而這很有可能會(huì)導(dǎo)至BUG的出現(xiàn)(假設(shè)你漏改了某些地方).
現(xiàn)在讓我們來看看怎樣用autoPrepare()/autoExecute()來解決這個(gè)問題
1. autoPrepare()
用autoPrepare(),你不必列出INSERT/UPDATE的詳細(xì)語(yǔ)句,而只要指定它的基本信息
resource autoPrepare (string $table, array $table_fields, integer $mode = DB_AUTOQUERY_INSERT [, string $where = FALSE])
$table               表名
$table_fields        要進(jìn)行操作的字段名列表(數(shù)組類型)
$mode                (DB_AUTOQUERY_INSERT || DB_AUTOQUERY_UPDATE)
$where               WHERE語(yǔ)句,用于過濾數(shù)據(jù)

<?php
// 假設(shè)你已經(jīng)有一個(gè)有效的數(shù)據(jù)庫(kù)連接變量$db …
$table_name   = ‘user‘;
$table_fields = array(‘id‘, ‘name‘, ‘country‘);

$sth = $db->autoPrepare($table_name, $table_fields,
                        DB_AUTOQUERY_INSERT);

if (DB::isError($sth)) {
    die($sth->getMessage());
}
$table_values = array(1, ‘Fabien‘, ‘France‘);

$res =& $db->execute($sth, $table_values);

if (DB::isError($res)) {
    die($res->getMessage());
}
?>
在這個(gè)例子中,autoPrepare()會(huì)把它自動(dòng)翻譯成
INSERT INTO user (id, name, country) VALUES (?, ?, ?)

然后再自動(dòng)調(diào)用prepare()
注意:如果你使用DB_AUTOQUERY_UPDATE, 記得指定$where條件,否則將更新所有的數(shù)據(jù).
2.autoExecute()
autoExecute()是autoPrepare()和execute()的混合體,它可以方便地執(zhí)行INSERT/UPDATE
DB_Result autoExecute (string $table, array $fields_values [, integer $mode = DB_AUTOQUERY_INSERT [, string $where = FALSE]])
$table               表名
$table_fields        要進(jìn)行操作的字段名列表(數(shù)組類型)
$mode                (DB_AUTOQUERY_INSERT || DB_AUTOQUERY_UPDATE)
$where               WHERE語(yǔ)句,用于過濾數(shù)據(jù)
<?php
// 假設(shè)你已經(jīng)有一個(gè)有效的數(shù)據(jù)庫(kù)連接變量$db …
$table_name = ‘user‘;

$fields_values = array(
    ‘id‘      => 1,
    ‘name‘    => ‘Fabien‘,
    ‘country‘ => ‘France‘
);

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

if (DB::isError($res)) {
    die($res->getMessage());
}
?>
它執(zhí)行等效于下面的語(yǔ)句
INSERT INTO user (id, name, country)  VALUES (1, ‘Fabien‘, ‘France‘)