php增删改查封装

php增删改查封装

首先创建一个名为“DB”的类；然后在“DB”类的构造方法中去连接数据库；再根据连接实例进行编写增删改查操作；最后将“DB”类进行实例化并设置为全局变量即可。

封装代码：

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);
    }

    
    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;
    }
    
    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));
    }
    
    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;
    }
    
    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;
 }
    }
    
    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教程》

以上就是php增删改查封装的详细内容，更多请关注考高分网其它相关文章！