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

发布时间:2022-04-30 发布网站:脚本宝典
脚本宝典收集整理的这篇文章主要介绍了自写的利用PDO对mysql数据库增删改查操作类脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。

前言

PDO一是PHP数据对象(PHP Data Object)的缩写。

并不能使用PDO扩展本身执行任何数据库操作,必须使用一个database-sPEcific PDO driver(针对特定数据库的PDO驱动)访问数据库服务器

PDO并不提供数据库抽象,它并不会重写sql或提供数据库本身缺失的功能,如果你需要这种功能,你需要使用一个更加成熟的抽象层。

最近在做项目时用到了PDO操作MysqL数据库,于是自己写了一个文件,命名为MysqL_class.PHP文件代码如下:

示例代码

<PRe class="brush:PHP;">

//私有变量声明
private $sql = NULL;//sql语句缓存
private $link = NULL;//数据库连接
private $result = NULL;//结果

/***

  • @ 名称:建立连接
  • @ 属性:私有
    ***/
    private function connect(){
    try {
    $this->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),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","openid='123'");//删除
    $MysqL->handle("update","nickname='def'","openid='123'");//更新
    $res = $MysqL->handle("select","*","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;//数据库类的实例化
?>

脚本宝典总结

以上是脚本宝典为你收集整理的自写的利用PDO对mysql数据库增删改查操作类全部内容,希望文章能够帮你解决自写的利用PDO对mysql数据库增删改查操作类所遇到的问题。

如果觉得脚本宝典网站内容还不错,欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签:mysqlmysqlpdo