php增刪改查封裝源代碼

這篇文章給大家分享的是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增刪改查封裝的具體代碼，如果在日常工作遇到這個問題，希望你能通過這篇文章解決問題。如果想了解更多相關內容，歡迎關注億速云行業資訊頻道！