一个基于PDO的数据库操作类

View Code 
<?php
/*
    作者：胡睿
    日期：2011/03/19
    电邮：hooray0905@foxmail.com
    
    20110319
    常用数据库操作，如：增删改查，获取单条记录、多条记录，返回最新一条插入记录id，返回操作记录行数等
*/
    /*
        参数说明
        int            $debug        是否开启调试，开启则输出sql语句
        int            $getcount    是否记数，返回值为行数
        int            $getrow        是否返回值单条记录
        string        $table        数据库表
        string        $fields        需要查询的数据库字段，允许为空，默认为查找全部
        string        $sqlwhere    查询条件，允许为空
        string        $orderby    排序，允许为空，默认为id倒序
    */
    function hrSelect($debug,$getcount,$getrow,$table,$fields="*",$sqlwhere="",$orderby="id desc"){
        global$pdo;
        if($debug){
            if($getcount){
                echo"select count(*) from $table where 1=1 $sqlwhere order by $orderby";
            }else{
                echo"select $fields from $table where 1=1 $sqlwhere order by $orderby";
            }
            exit;
        }else{
            if($getcount){
                $rs=$pdo->query("select count(*) from $table where 1=1 $sqlwhere order by $orderby");
                return$rs->fetchColumn();
            }elseif($getrow){
                $rs=$pdo->query("select $fields from $table where 1=1 $sqlwhere order by $orderby");
                return$rs->fetch();
            }else{
                $rs=$pdo->query("select $fields from $table where 1=1 $sqlwhere order by $orderby");
                return$rs->fetchAll();
            }
        }
    }
    
    /*
        参数说明
        int            $debug            是否开启调试，开启则输出sql语句
        int            $execrow        是否开启返回执行条目数
        int            $lastinsertid    是否开启返回最后一条插入记录id
        string        $table            数据库表
        string        $fields            需要插入数据库的字段
        string        $values            需要插入数据库的信息，必须与$fields一一对应
    */
    function hrInsert($debug,$execrow,$lastinsertid,$table,$fields,$values){
        global$pdo;
        if($debug){
            echo"insert into $table ($fields) values ($values)";
            exit;
        }elseif($execrow){
            return$pdo->exec("insert into $table ($fields) values ($values)");
        }elseif($lastinsertid){
            return$pdo->lastInsertId("insert into $table ($fields) values ($values)");
        }else{
            $pdo->query("insert into $table ($fields) values ($values)");
        }
    }
    
    /*
        参数说明
        int            $debug        是否开启调试，开启则输出sql语句
        int            $execrow    是否开启执行并返回条目数
        string        $table        数据库表
        string        $set        需要更新的字段及内容，格式：a='abc',b=2,c='2010-10-10 10:10:10'
        string        $sqlwhere    修改条件，允许为空
    */
    function hrUpdate($debug,$execrow,$table,$set,$sqlwhere=""){
        global$pdo;
        if($debug){
            echo"update $table set $set where 1=1 $sqlwhere";
            exit;
        }elseif($execrow){
            return$pdo->exec("update $table set $set where 1=1 $sqlwhere");
        }else{
            $pdo->query("update $table set $set where 1=1 $sqlwhere");
        }
    }
    
    /*
        参数说明
        int            $debug        是否开启调试，开启则输出sql语句
        int            $execrow    是否开启返回执行条目数
        string        $table        数据库表
        string        $sqlwhere    删除条件，允许为空
    */
    function hrDelete($debug,$execrow,$table,$sqlwhere=""){
        global$pdo;
        if($debug){
            echo"delete from $table where 1=1 $sqlwhere";
            exit;
        }elseif($execrow){
            return$pdo->exec("delete from $table where 1=1 $sqlwhere");
        }else{
            $pdo->query("delete from $table where 1=1 $sqlwhere");
        }
    }
?>