データベースを呼び出すphpクラス

class DataBase
{
 var $pConnect=FALSE;//長い接続を使用するかどうか
 var $mHost;//データベースホスト
 var $mDatabase
 var $; db ; //データベース
 var $mUser; // データベース ユーザー名
 var $mConn // クエリの実行結果のリソース ID command
 var $ num_rows; // エントリの数を返します
 var $insert_id; // クエリコマンドによって影響を受けた列の数を返します
 var $insert_id; INSERT、UPDATE、または DELETE による行数。
 // where なしで削除すると、0 を返します
 // コンストラクター関数
 public function __construct($host,$user,$pwd,$db)
 {
 $this->gt;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);//ショート接続
 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 functionexecute($sql){
 $this->result=mysql_query($sql);
 return $this->result;
 }
 /配列インデックスと関連付けを取得
 public function fetchArray($resultType=MYSQL_BOTH)
 {
 return mysql_fetch_array($this->result,$resultType);
 }

 //連想配列を取得
 public function fetchAssoc()
 {
 return mysql_fetch_assoc($this->result);
 }

 //数値インデックス配列を取得
 public function fetchIndexArray()
 {
 return mysql_fetch_row($this->result);
 }

 //オブジェクト配列を取得
 public function fetchObject()
 {
 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<$cnt)
 {
 $rs[]=mysql_db_name($rsPtr,$i);
 $i++;
 }
 return $rs ;
 }< ;/p>
 function dbhalt($errmsg){
 $msg="データベースに問題があります!";
 $msg=$errmsg;
 echo "$msg";
 die();
 }< /p>
 //削除
関数 delete($sql){
 $result=$this->execute($sql,$dbbase);
 $this-> ;affected_rows=mysql_affected_rows($this->dbLink);
 $this->free_result($result);
 return $this->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;
 }
 //
関数 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
?>



コードをコピー