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

前言

PDO一是PHP数据对象（PHP Data Object）的缩写。

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

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

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

示例代码

rush: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;//数据库类的实例化
?>

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对编程之家的支持。