<?phpclass 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;//數據庫類的實例化?>