php_PHP チュートリアルで書かれた mysql 操作クラス

クラスDB{

プライベート $con;
 
 
 関数 __construct($mysql_data){
 
  $this->db_connect($mysql_data);
 
 }
 /**
* データベースに接続します
* @param array $mysql_data データベース接続情報 array('host'=>'ホスト: ポート','user'=>'ユーザー','pass'=>'パスワード','dbbase'=>'データベース','charset'=>'文字タイプ')
**/
 関数 db_​​connect($mysql_data){
 
  $host = $mysql_data['host'];
  $user = $mysql_data['user'];
  $pass = $mysql_data['pass'];
  $dbbase = $mysql_data['dbbase'];
  $charset= $mysql_data['charset'];
 
  $this->con = @mysql_connect($host,$user,$pass) または die('NO SERVER');
  if($this->con){
   mysql_select_db($dbbase,$this->con) または die('NO DATABASE:'.$dbbase);
  
    mysql_query('セット名'.$charset);
  }
 }
 
 
 /**
* SQL文を実行します
* @param string $sql 実行する必要があるSQL
* @return obj
**/
 関数クエリ($sql){
 
  return mysql_query($sql,$this->con);
 
 }

 /**
* クエリ結果を取得します
* @param string $sql 実行する必要があるSQL
* @return array array('id'=>'1','dd'=>'2');
**/
 関数 fetch_row($sql){
 
  $result = $this->query($sql);
 
  return mysql_fetch_assoc($result);
 }
 
 /**
* 結果の最初のフィールド値を取得します
* @param string $sql 実行する必要があるSQL
* @戻り文字列
**/
 関数 fetch_first($sql){
 
  $result = $this->query($sql);
 
  $result = mysql_fetch_array($result);
 
  $result[0] を返します;
 }
 
 
 /**
* 結果セットを返します
* @param string $sql 実行する必要があるSQL
* @param string $filed インデックスとして使用する必要があるフィールド
* @return array array(array('id'=>'1','dd'=>'2'),array('id'=>'1','dd'=>'2' ));
**/
 関数 fetch_result($sql,$field = null){
 
  $result = $this->query($sql);
  $ret_array = array();
 
  while($rows = mysql_fetch_assoc($result)){
  
   if($フィールド){
    $ret_array[$rows[$field]]= $rows;
   }その他{
    $ret_array[]= $rows;
   }
  
  }
 
  return $ret_array;
 }
 
 /**
* 新しいIDを取得してください
* @return int
**/
 関数 get_insertid(){
  mysql_insert_id() を返す;
 }
 
 /**
*単一のデータテーブルに挿入します
* @param array $Data array('フィールド 1'=>'値','フィールド 2'=>'値',)
* @param string $table テーブル名
**/
 関数挿入($Data,$table){
 
  //テーブル(字段，字段)に値を挿入(值，值)
 
  $key_array = implode(',',array_keys($Data));
  $key_val = ''.implode('','',array_values($Data)).'';
 
  $sql = "「.$table.」に挿入します。($key_array) 値($key_val)";
 
  return $this->query($sql);
 }
 
 
 
 /**
* 単一のテーブルを更新します
* @param array $Data array('フィールド 1'=>'値','フィールド 2'=>'値',)
* @param array $where array('フィールド 1'=>'値','フィールド 2'=>'値',) 更新が必要な条件
* @param string $table テーブル名 www.2cto.com
**/
 関数更新($Data,$table,$where){
  //テーブルセットを更新します 字段=值，字段=值 where key =value;
  $key_var = array();
 
  foreach($Data as $key=>$val){
  
   $key_var[] = $key."='".$val."'";
  }
 
  $key_var = implode(',',$key_var);
 
 
  $whe_var = array();
 
  foreach($where as $key=>$val){
  
   $whe_var[] = $key."='".$val."'";
  }
 
  $whe_var = implode(' および ',$whe_var);
 
  if($whe_var){
   $whe_var = ' where '.$whe_var;
  }
 
  $sql = "".$table を更新します。" set ".$key_var.$whe_var;
  return $this->query($sql);
  // $sql を返します;
  
 }
}