PDO를 사용하여 mysql 데이터베이스를 추가, 삭제, 수정 및 쿼리하는 단계에 대한 자세한 설명

이번에는 mysql 데이터베이스에서 PDO 추가, 삭제, 수정 및 동작 확인 단계에 대해 자세히 설명하겠습니다. mysql 데이터베이스에서 PDO 추가, 삭제, 수정 및 동작 확인 시 주의 사항은 무엇입니까? 실제 사례이므로 살펴보겠습니다.

머리말

PDO는 PHP Data Object의 약자입니다.

PDO 확장 자체를 사용하여 데이터베이스 작업을 수행할 수 없습니다. 데이터베이스 서버에 액세스하려면 데이터베이스별 PDO 드라이버(특정 데이터베이스용 PDO 드라이버)를 사용해야 합니다.

PDO는 데이터베이스 추상화를 제공하지 않습니다. SQL을 다시 작성하거나 데이터베이스 자체에 누락된 기능을 제공하지 않습니다. 이 기능이 필요한 경우 보다 성숙한 추상화 계층을 사용해야 합니다.

최근 프로젝트 작업 시 PDO를 사용해 mysql 데이터베이스를 운영했기 때문에 mysql_class.php라는 클래스 파일을 작성했습니다. 파일 코드는 다음과 같습니다.

샘플 코드

<?php class mysql{
 //常量声明
 const DSN = "mysql:host=[数据库地址];dbname=[数据库名];charset=utf8";//数据库地址与数据库名及编码
 const USERNAME = "[数据库用户名]";//用户名
 const PASSWD = "[数据库密码]";//密码
 //私有变量声明
 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()."<hr>");
  }
 }
 /*******************************************************************************
  * @ 名称：执行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()."<hr>");
  }
 }
 /*******************************************************************************
  * @ 名称：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."<hr>";
   }
  }//遍历查询结果数组
 *******************************************************************************/
 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;//数据库类的实例化
?>

이 기사의 사례를 읽은 후 마스터했습니다. 더 흥미로운 방법을 보려면 PHP 중국어 웹사이트의 다른 관련 기사를 주목하세요!

추천 도서:

php 네임스페이스 사용에 대한 자세한 설명

Laravel 5.5 코어 아키텍처 사용에 대한 자세한 설명

위 내용은 PDO를 사용하여 mysql 데이터베이스를 추가, 삭제, 수정 및 쿼리하는 단계에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!