Detailed explanation of the steps for adding, deleting, modifying and querying mysql database using PDO-PHP Tutorial-php.cn

Home

Backend Development

PHP Tutorial

Detailed explanation of the steps for adding, deleting, modifying and querying mysql database using PDO

May 18, 2018 pm 02:42 PM

mysql database step

This time I will bring you a detailed explanation of the steps for adding, deleting, modifying, and querying operations of PDO on mysql database. What are the precautions for PDO adding, deleting, modifying, and querying operations on mysql database? The following is a practical case. Let’s take a look. .

Preface

PDO is the abbreviation of PHP Data Object.

You cannot use the PDO extension itself to perform any

database operations, you must use a database-specific PDO driver (PDO driver for a specific database) to access the database server.

PDO does not provide database abstraction. It does not rewrite SQL or provide functions missing from the database itself. If you need this function, you need to use a more mature abstraction layer.

Recently I used PDO to operate mysql database when working on a project, so I wrote a class file myself and named it mysql_class.php. The file code is as follows:

Sample code

100

101

102

103

104

105

106

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

Copy after login

I believe you have mastered the method after reading the case in this article. For more exciting information, please pay attention to other related articles on the php Chinese website!