php增刪改查封裝

首先創建一個名為“DB”的類；然后在“DB”類的構造方法中去連接數據庫；再根據連接實例進行編寫增刪改查操作；最后將“DB”類進行實例化并設置為全局變量即可。

封裝代碼：

<?php /**  * 數據庫配置信息  */ define('DB_HOST','127.0.0.1');            //服務器 define('DB_USER','root');                 //數據庫用戶名 define('DB_PASSWORD','123456');           //數據庫密碼 define('DB_NAME','TEST');                 //默認數據庫 define('DB_CHARSET','utf8');              //數據庫字符集 define('TIMEZONE',"PRC");                 //時區設置 date_default_timezone_set(TIMEZONE); /**  * 類名：DB  * 說明：數據庫操作類  */ class DB {     public $host;            //服務器      public $conn;            //數據庫連接變量     /**      * DB類構造函數      */     public function DB($host=DB_HOST ,$username=DB_USER,$password=DB_PASSWORD,$db_name=DB_NAME)     {         $this->host = $host;         $this->username = $username;         $this->password = $password;         $this->db_name = $db_name;         $this->conn = mysql_connect($host,$username,$password) or die ('數據庫連接失敗！錯誤原因：'.mysql_error());          mysql_select_db($db_name)or die('數據庫選定失敗！錯誤原因：'.mysql_error());                  mysql_query("SET CHARACTER SET utf8");     }      /**      * 關閉數據連接      */     public function close()     {         mysql_close($this->conn);     }      /**      * @description調用方法用      * @param $sql      * @return array      */     public function QueryAll($sql)     {         $this->open();         $rs = mysql_query($sql,$this->conn);         $objList = array();         while($obj = mysql_fetch_object($rs))         {             if($obj)             {                 $objList[] = $obj;             }         }         $this->close();         return $objList;     }     /**      * description查詢全部返回Json格式，通訊用      * @param $sql      * @return string      */     public function QueryAllJson($sql)     {         echo $sql;         $this->open();         $rs = mysql_query($sql,$this->conn);         $objList = array();         $i=0;         while($obj = mysql_fetch_object($rs))         {             $objList[$i]=$obj;             $i++;         }         $this->close();         return json_encode(array("result"=>"success",'data'=>$objList));     }     /**      * @description 插入數據到數據庫中      * @param $tableName 表名      * @param array $columns 包含表中所有字段名的數組。默認空數組，則是全部有序字段名      * @param array $values  包含對應所有字段的屬性值的數組      * @return int      */     public function insertData($tableName,$columns=array(),$values=array())     {         $sql = 'insert into '.$tableName .'( ';         for($i = 0; $i < sizeof($columns);$i ++)         {             $sql .= $columns[$i];             if($i < sizeof($columns) - 1)             {                 $sql .= ',';             }         }         $sql .= ') values ( ';         for($i = 0; $i < sizeof($values);$i ++)         {             $sql .= "'".$values[$i]."'";             if($i < sizeof($values) - 1)             {                 $sql .= ',';             }         }         $sql .= ' )';         $this->open();         mysql_query($sql,$this->conn);         return true; //      $id = mysql_insert_id($this->conn);//取得上一步操作產生的ID(2) //      $this->close();(2) //      return $id;//(2)     }     /**      * 通過表中的某一屬性獲取數據      */     public function getDataByAtr($tableName,$atrName,$atrValue){         @$data = $this->QueryAll("SELECT * FROM ".$tableName." WHERE $atrName = '$atrValue'");         if(count($data)!=0)return $data;         return NULL;     }     /**      * description_      * 通過表中的"id"，刪除記錄      */     public function delete($tableName,$atrName,$atrValue){         echo $tableName;         $this->open();         $deleteResult = false;         if(mysql_query("DELETE FROM ".$tableName." WHERE $atrName = '$atrValue'")) $deleteResult = true;         $this->close();         if($deleteResult) return true;         else return false;     }     /**      * 更新表中的屬性值      */     public function updateParamById($tableName,$atrName,$atrValue,$key,$value){         $db = new DB();         $db->open();         if(mysql_query("UPDATE ".$tableName." SET $key = '$value' WHERE $atrName = '$atrValue' ")){  //$key不要單引號             $db->close();             return true;         }         else{             $db->close();             return false;         }     }     /*      * @description: 取得一個table的所有屬性名      * @param: $tbName 表名      * @return：字符串數組      */     public function fieldName($tableName){         $resultName=array();         $i=0;         $this->open();         $result = mysql_query("SELECT * FROM ".$tableName);         while ($property = mysql_fetch_field($result)){             $resultName[$i++]=$property->name;         }         $this->close();         return $resultName;     }  }

推薦教程：《PHP教程》