一个基于PDO的数据库操作类 一个PDO事务实例_php技巧_脚本之家

query from $table where 1=1 $sqlwhere order by $orderby”); $return =
$rs->fetchColumn(); }elseif{ $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{ echo
“insert into $table values “; exit; }else{ if{ $return =
$pdo->lastInsertId(“insert into $table values ; }elseif{ $return =
$pdo->exec(“insert into $table values ; }else{ $pdo->query(“insert
into $table 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{ echo “update $table set
$set where 1=1 $sqlwhere”; exit; }else{ if{ $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{ echo “delete from $table where 1=1
$sqlwhere”; exit; }else{ if{ $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{ $pdo->rollBack(); echo “Failed: ” .
$e->getMessage(); } 代码下载:点击下载

复制代码 代码如下:

发表评论