http://www.nowamagic.net/librarys/veda/detail/317
?
Zend_Db_Adapter 是 zendframework 的数据库抽象层 API,基于 pdo,你可以使用 Zend_Db_Adapter 连接和处理多种数据库,包括 microsoft SQL Server,MySql,SQLite 等等。要针对不同的数据库实例化一个 Zend_Db_Adapter 对象,需要将 adapter 的名字和描述数据库连接的参数数组作为参数,静态调用 Zend_Db::factory() 方法。例如,连接到一个数据库名称为"test",用户名为"root"的本地 MySQL 数据库,可以进行如下操作:
<?php require_once 'Zend/Db.php'; $params = array ( 'host' => 'localhost', 'username' => 'root', 'password' => '', 'dbname' => 'test' ); $db = Zend_Db::factory('PDO_MYSQL', $params); ?>
?
直接查询数据
一旦你得到了一个 Zend_Db_Adapter 实例,你可以直接执行 sql 语句进行查询。Zend_Db_Adapter 传送这些 sql 语句到底层的 PDO 对象,由PDO 对象组合并执行他们,在有查询结果的情况下,返回一个 PDOStatement 对象以便对结果进行处理。
数据库如下:
?PHP代码:
<?php require_once 'Zend/Db.php'; $params = array ( 'host' => 'localhost', 'username' => 'root', 'password' => '', 'dbname' => 'test' ); $db = Zend_Db::factory('PDO_MYSQL', $params); // 创建一个$db 对象,然后查询数据库 // 使用完整的sql 语句直接进行查询. $sql = $db->quoteInto( 'SELECT * FROM test WHERE id = ?', '3' ); $result = $db->query($sql); // 使用PDOStatement 对象$result 将所有结果数据放到一个数组中 $rows = $result->fetchAll(); ?> <pre> <?php print_r($rows); ?> </pre>
?程序运行结果:
Array ( [0] => Array ( [id] => 3 [name] => C ) )
?你可以将数据自动的绑定到你的查询中。这意味着你在查询中可以设定多个指定的占位符,然后传送一个数组数据以代替这些占位符。这些替换的数据是自动进行加引号处理的,为防止数据库攻击提供了更强的安全性。
<?php // 创建一个$db 对象,然后查询数据库. // 这一次,使用绑定的占位符. $result = $db->query( 'SELECT * FROM example WHERE date > :placeholder', array('placeholder' => '2006-01-01') ); // 使用PDOStatement 对象$result 将所有结果数据放到一个数组中 $rows = $result->fetchAll(); ?>
?或者,你也可以手工设置 sql 语句和绑定数据到 sql 语句。这一功能通过 prepare() 方法得到一个设定好的PDOStatement 对象,以便直接进行数据库操作。
<?php // 创建一个$db 对象,然后查询数据库. // 这次, 设定一个PDOStatement 对象进行手工绑定. $stmt = $db->prepare('SELECT * FROM example WHERE date > :placeholder'); $stmt->bindValue('placeholder', '2006-01-01'); $stmt->execute(); // 使用PDOStatement 对象$result 将所有结果数据放到一个数组中 $rows = $stmt->fetchAll(); ?>
?
事务处理
默认情况下,PDO(因此Zend_Db_Adapter 也是)是采用自动 commit 模式。也就是说,所有的数据库操作执行时就做了 commit 操作。假如你试图执行事务处理,最简单的是调用 beginTransaction() 方法,然后选择 commit 或者 rollback。之后,Zend_Db_Adapter 会回到自动 commit 模式下,直到你再次调用 beginTransaction() 方法。
<?php // 创建一个$db 对象, 然后开始做一个事务处理. $db->beginTransaction(); // 尝试数据库操作. // 假如成功,commit 该操作; // 假如, roll back. try { $db->query(...); $db->commit(); } catch (Exception $e) { $db->rollBack(); echo $e->getMessage(); } ?>
?
插入数据行
为了方便起见,你可以使用 insert() 方法将要插入的数据绑定并创建一个 insert 语句(绑定的数据是自动进行加引号处理以避免数据库攻击的)返回值并不是最后插入的数据的id,这样做的原因在于一些表并没有一个自增的字段;相反的,这个插入的返回值是改变的数据行数(通常情况为1)。假如你需要最后插入的数据id,可以在 insert 执行后调用lastInsertId()方法。
<?php// // INSERT INTO round_table // (noble_title, first_name, favorite_color) // VALUES ("King", "Arthur", "blue"); // // 创建一个$db 对象, 然后... // 以"列名"=>"数据"的格式格式构造插入数组,插入数据行 $row = array ( 'noble_title' => 'King', 'first_name' => 'Arthur', 'favorite_color' => 'blue', ); // 插入数据的数据表 $table = 'round_table'; // i 插入数据行并返回行数 $rows_affected = $db->insert($table, $row); $last_insert_id = $db->lastInsertId(); ?>
?
更新数据行
为了方便起见,你可以使用 update() 方法确定需要 u