PHP封裝(增刪改查)
阿新 • • 發佈：2020-08-03
db.class.php 主要方法
<?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 $username; //資料庫使用者名稱 public $password; //資料密碼 public $db_name; //資料庫名 public $conn; //資料庫連線變數 /** * DB類建構函式 */ public functionDB($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; } /** * 開啟資料庫連線 */ public function open() {$this->conn = mysql_connect($this->host,$this->username,$this->password)or die ('資料庫連線失敗！</br>錯誤原因：'.mysql_error()); mysql_select_db($this->db_name)or die('資料庫選定失敗！</br>錯誤原因：'.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; } }
user.class.php 操作
<?php require_once("./db.class.php"); class User{ /** * description_插入資料到XX * @param $tableName * @param $name * @param $password * @return int */ public function insert($tableName,$name,$password){ $db = new DB(); $resultId = $db->insertData("$tableName",array('name','password'),array($name,$password)); return $resultId; } /** * @description根據ID或XXX查詢一條資料，user所查詢的表，id是欄位名 * @param $table * @param $name * @param $value * @return array|null */ public static function getUserById($table,$name,$value){ $db = new DB(); return $db->getDataByAtr("$table",'$name',$value); } /** * @description根據name查詢一條資料 * @param $name * @return array|null */ public static function getUserByName($name){ $db = new DB(); @$data = $db->QueryAll("SELECT * FROM user WHERE name = '".$name."'"); if(count($data)!=0)return $data; else return null; } /** * @description_獲取全部資料，調方法使用 * @param $tableName * @return null */ public static function QueryAll($tableName){ $db = new DB(); @$data = $db->QueryAll("select * FROM"." ".$tableName); if(count($data)!=0) echo $data; else return null; } /** * @description_獲取全部資料，通訊使用 * @param $tableName */ public static function QueryAllJson($tableName){ $db = new DB(); @$data = $db->QueryAllJson("SELECT * FROM ".$tableName.""); if(count($data)!=0) echo $data; else echo false; } /** * description分頁查詢，返回Json格式。通訊用，echo * @param $start * @param $count */ public static function QueryWithPage($start,$count){ $db = new DB(); @$data = $db->QueryAllJson("select id,name,password from user order by id limit"." ".$start.",".$count); if(count($data)!=0) echo $data; else echo false; } /** * @description_刪除資料，根據ID，user是表名，id是.... * @param $tableName * @param $name * @param $value * @return bool */ public static function deleteByUid($tableName,$name,$value){ $db = new DB(); if($db->delete("$tableName","$name",$value)) return true; else return false; } }
test.php 測試
<?php header("Content-Type:text/html; charset=utf8"); require_once("./user.class.php"); $user = new User(); //$user->insert('asssss'); //$user->getUserById(1); //$userA = User::getUserById(1); //$userB = User::QueryWithPage(6,10); //$userB = User::QueryAllJson('user'); //$user=$user->insert('user','www','sd'); //$userB = User::deleteByUid('user','id',7); //foreach ($user as $u) { // echo json_encode(array("result"=>"success","date"=>"asd")); //} //建構函式被註釋掉了，如果有建構函式