一个基于PDO的数据库操作类(新) + 一个PDO事务实例

<?php
/*
 *	作者：胡睿
 *	日期：2011/03/19
 *	
 *	20110319
 *		常用数据库操作，如：增删改查，获取单条记录、多条记录，返回最新一条插入记录id，返回操作记录行数等
 *	20110630
 *		整体修改方法，合并部分参数
 *		规范代码，一个方法里只有1个return语句
 */

	/*
		参数说明
		int			$debug			是否开启调试，开启则输出sql语句
		int			$mode			0	返回数组
									1	返回单条记录
									2	返回行数
		string		$table			数据库表
		string		$fields			需要查询的数据库字段，允许为空，默认为查找全部
		string		$sqlwhere		查询条件，允许为空
		string		$orderby		排序，允许为空，默认为id倒序
	 */
	function hrSelect($debug, $mode, $table, $fields="*", $sqlwhere="", $orderby="id desc"){
		global $pdo;
		if($debug){
			if($mode == 2){
				echo "select count(*) from $table where 1=1 $sqlwhere order by $orderby";
			}elseif($mode == 1){
				echo "select $fields from $table where 1=1 $sqlwhere";
			}else{
				echo "select $fields from $table where 1=1 $sqlwhere order by $orderby";
			}
			exit;
		}else{
			if($mode == 2){
				$rs = $pdo->query("select count(*) from $table where 1=1 $sqlwhere order by $orderby");
				$return = $rs->fetchColumn();
			}elseif($mode == 1){
				$rs = $pdo->query("select $fields from $table where 1=1 $sqlwhere");
				$return = $rs->fetch();
			}else{
				$rs = $pdo->query("select $fields from $table where 1=1 $sqlwhere order by $orderby");
				$return = $rs->fetchAll();
			}
			return $return;
		}
	}
	
	/*
		参数说明
		int			$debug			是否开启调试，开启则输出sql语句
		int			$mode			0	默认insert，无返回信息
									1	返回执行条目数
									2	返回最后一次插入记录的id
		string		$table			数据库表
		string		$fields			需要插入数据库的字段
		string		$values			需要插入数据库的信息，必须与$fields一一对应
	*/
	function hrInsert($debug, $mode, $table, $fields, $values){
		global $pdo;
		if($debug){
			echo "insert into $table ($fields) values ($values)";
			exit;
		}else{
			if($mode == 2){
				$return = $pdo->lastInsertId("insert into $table ($fields) values ($values)");
			}elseif($mode == 1){
				$return = $pdo->exec("insert into $table ($fields) values ($values)");
			}else{
				$pdo->query("insert into $table ($fields) values ($values)");
				exit;
			}
			return $return;
		}
	}
	
	/*
		参数说明
		int			$debug			是否开启调试，开启则输出sql语句
		int			$mode			0	默认update，无返回信息
									1	返回执行条目数
		string		$table			数据库表
		string		$set			需要更新的字段及内容，格式：a='abc',b=2,c='2010-10-10 10:10:10'
		string		$sqlwhere		修改条件，允许为空
	*/
	function hrUpdate($debug, $mode, $table, $set, $sqlwhere=""){
		global $pdo;
		if($debug){
			echo "update $table set $set where 1=1 $sqlwhere";
			exit;
		}else{
			if($mode==1){
				$return = $pdo->exec("update $table set $set where 1=1 $sqlwhere");
			}else{
				$pdo->query("update $table set $set where 1=1 $sqlwhere");
				exit;
			}
			return $return;
		}
	}
	
	/*
		参数说明
		int			$debug			是否开启调试，开启则输出sql语句
		int			$mode			0	默认delete，无返回信息
									1	返回执行条目数
		string		$table			数据库表
		string		$sqlwhere		删除条件，允许为空
	*/
	function hrDelete($debug, $mode, $table, $sqlwhere=""){
		global $pdo;
		if($debug){
			echo "delete from $table where 1=1 $sqlwhere";
			exit;
		}else{
			if($mode == 1){
				$return = $pdo->exec("delete from $table where 1=1 $sqlwhere");
			}else{
				$pdo->query("delete from $table where 1=1 $sqlwhere");
				exit;
			}
			return $return;
		}
	}
?>

	/*
		注意，数据库操作表类型必须为InnoDB，其他类型不支持事务
		PDO事务机制
		$pdo->beginTransaction();	--开启事务
		$pdo->commit();				--结束事务
		$pdo->rollBack();			--回滚操作
		
		示例，用try/catch包住db操作，当事务内的db操作出现中断，则执行回滚并抛出异常信息。
	*/
	try{
		$pdo->beginTransaction();
		hrInsert(0,1,"class","name,parentid","'god',0");	//可以正常执行
		hrInsert(0,0,0,"tb_searchlog","userid,code","4");	//出错
		$pdo->commit();
	}catch(Exception $e){
		$pdo->rollBack();
		echo "Failed: " . $e->getMessage();
	}