自写的使用PDO对mysql数据库的增删改查操作类

摘要：最近在做项目时用到了操作数据库，于是自己写了一个类文件，命名为文件代码如下常量声明数据库地址数据库名数据库地址与数据库名及编码数据库用户名用户名数据库密码密码私有变量声明语句缓存数据库连接结果名称建立连接属性私有创建连接名称执行语句属性

最近在做项目时用到了PDO操作mysql数据库，于是自己写了一个类文件，命名为mysql_class.php文件代码如下：

link = new PDO(self::DSN, self::USERNAME, self::PASSWD, array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));//创建连接
        }
        catch (PDOException $e) {
            die ("Error!:".$e->getMessage()."
");
        }
    }
    
    /*******************************************************************************
     * @ 名称：执行sql语句
     * @ 属性：私有
     * @ 入口参数：无
     * @ 出口参数:执行成功返回真，否则返回假，查询语句存储结果集数组
    *******************************************************************************/
    private function sql(){
        try {
            $this->connect();
            $this->link->beginTransaction();//开启一个事务
            $prepare = $this->link->prepare($this->sql);//准备查询语句
            $prepare->execute();//执行查询语句并返回结果集
            $cmd = strtolower(substr(trim($this->sql),0,6));//截取命令字符
            if($cmd == "select"){
                $array = $prepare->fetch(PDO::FETCH_ASSOC);//获取结果集中的所有数据
                if(count($array)){
                    $this->result = NULL;
                    $this->result = $array;//存储结果集
                    return true;//查询到结果返回真
                }else{
                    return false;//否则返回假
                }
            }else if($cmd == "insert" || $cmd == "delete" || $cmd == "update"){
                if($prepare){
                    return true;//执行成功返回真
                }else{
                    return false;//否则返回假
                }
            }
            $this->link->commit(); //如果正确执行完成那么确认commit
        } catch (PDOException $e) {
            $this->link->rollBack();//如果执行中有错误的情况下回滚
            die ("Error!:".$e->getMessage()."
");
        }
    }
    
    /*******************************************************************************
     * @ 名称：sql语句处理
     * @ 属性：公有
     * @ 入口参数：cmd增删改查字符命令；dsname数据表名；first第一个参数；second第二个参数；
     * @ 出口参数：执行成功返回真，否则返回假，查询操作返回结果集数组
     * @ 使用示例：
        $mysql->handle("insert","abc","openid,nickname",""123","abc"");//增加
        $mysql->handle("delete","abc","openid="123"");//删除
        $mysql->handle("update","abc","nickname="def"","openid="123"");//更新
        $res = $mysql->handle("select","abc","*","openid="123"");//查询
        if(is_array($res) == true){
            foreach($res as $key=>$val){
                echo $key."=".$val."
";
            }
        }//遍历查询结果数组
    *******************************************************************************/
    public function handle($cmd,$dsname,$first,$second=NULL){
        switch($cmd){
            case "insert"://插入
                $this->sql = "insert into $dsname ($first) values ($second)";
                break;
            case "delete"://删除
                $this->sql = "delete from $dsname where $first";
                break;
            case "update"://更新
                $this->sql = "update $dsname set $first where $second";
                break;
            case "select"://查询
                $this->sql = "select $first from $dsname where $second";
                break;
            default:
                die ("Syntax Error!");//提示语法错误
                break;
        }
        
        $res = $this->sql();//执行sql语句
        if($res){
            if($cmd == "select"){
                return $this->result;//返回查询结果
            }else{
                return true;//执行成功返回真
            }
        }else{
            return false;//否则返回假
        }
        $this->link=NULL;;//关闭数据库
    }
}

$mysql = new mysql;//数据库类的实例化

?>