一個php呼叫資料庫的類別

class DataBase
{
 var $pConnect=FALSE;//是否使用長連接
 var $mHost;//資料庫主機
 var $mDatabase;
 var $db; //資料庫
 var $mUser;//資料庫使用者名稱
 var $mPwd;//資料庫使用者密碼
 var $mConn;//連線標識
 var $result;// 執行query指令的結果資源識別
 var $num_rows;// 傳回的條目數
 var $insert_id;// 傳回最後一次使用INSERT 指令的ID
 var $affected_rows;// 傳回query指令所影響的列數目
 // INSERT、UPDATE 或DELETE 所影響的欄位(row) 數目。
 // delete 如果不帶where，那麼則回傳0
 //建構子
 public function __construct($host,$user,$pwd,$db)
 {
 $this ->mHost=$host;
 $this->mUser=$user;
 $this->mPwd=$pwd;
 $this->db=$db;
 }

 //資料庫連線
 public function connect()
 {
 if($this->pConnect)
 $this->mConn=mysql_pconnect($this->mHost,$this- >mUser,$this->mPwd);//長連線
 else
 $this->mConn=mysql_connect($this->mHost,$this->mUser,$this->mPwd);// short connect
 if(!$this->mConn) $this->dbhalt("無法連接資料庫!");
 if($this->db=="") $this->db=$this->dbDatabase;

 if(!mysql_select_db($this->db,$this->mConn))
 $this->dbhalt("資料庫不可用! ");
 } // eof#dbconnect()
 //更改資料庫
 public function dbChange($db){
 $this->db=$db ;
 $this->connect();
 }
 //執行SQL語句,傳回結果資源id
 public function execute($sql){
 $this->result=mysql_query($sql);
 return $this->result;
 }
 //取得陣列-索引與關聯
 public function fetchArray ($resultType=MYSQL_BOTH)
 {
 return mysql_fetch_array($this->result,$resultType);
 }

 //取得關聯陣列
 public function fetchAss(unction) 🎜> {
 return mysql_fetch_assoc($this->result);
 }

 //取得數字索引陣列
 public function fetchIndexArray()
 {result);
 }

 //取得物件陣列
 public function fetchObject()
 {
 return mysql_fetch_object($this->result);
 return mysql_fetch_object($this->result);

 }

 //回傳記錄行數
 function numRows()
 {
 return mysql_num_rows($this->result);
 }
 //回傳主機中所有資料庫名稱
 public function dbNames()
 {
 $rsPtr=mysql_list_dbs($this->mConn);
 $i=0;
 $cnt= mysql_num_rows($rsPtr);
 while($i {
 $rs[]=mysql_db_name($rsPtr,$i);
 $i++;
 }
 }
 return $rs;
 }
 function dbhalt($errmsg){
 $msg="資料庫有問題!";
 $msg=$errmsg;
 echo"$msg";
 die();
 }
 //刪除
 function delete($sql){
 $result=$this- >execute($sql,$dbbase);
 $this->affected_rows=mysql_affected_rows($this->dbLink);
 $this->free_result($result);
 return $this->affected_rows>affected_rows>affected_rows>affected_rows ;
 }
 //增加
 function insert($sql){
 $result=$this->execute($sql,$dbbase);
 $this->insert_id=mysql_insert_id($this->dbLink);
 $this->free_result($result);
 return $this->insert_id;
 }
 //改
 function update($sql){
 $result=$this->execute($sql,$dbbase);
 $this->affected_rows=mysql_affected_rows($this->dbLink );
 $this->free_result($result);
 return $this->affected_rows;
 }

 //關閉連線
 function dbclose(){
 mysql_close($this->dbLink);
  }
}// end class
?>

呼叫範例：

include "class_database.php";
$mydb= new DataBase("localhost","root","123456","test");
$mydb->connect();
$mydb->e​​xecute("set names GBK");
 $mydb->e​​xecute("select * from usrs");
print_r($mydb->dbNames());
?>