データベース操作のPHPクラス

 /*
 * 著者 Molong
 * 時刻 2010 年 12 月 2 日 15:50:35
 */

 $db = new mysql($db_host,$db_user,$db_password, $db_table, $db_conn,$pre,$coding);

 プライベート $db_user;
 プライベート $db_table;
 データベース接続識別; result; //実行するクエリコマンドの結果リソース識別
 private $sql; //SQL 実行ステートメント
 private $prefix; //データベースエンコーディング、GBK、UTF8、gb2312

 function __construct; ($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding){

 $this->db_host = $db_host;
 $this->db_user = $db_user; >db_password = $db_password;
 $this->db_table = $db_conn;
 $this->pre = $pre; ;
 $this->connect();

 }

 関数 connect(){

 $this->db_conn = @mysql_connect($this->db_host,$this->db_user, $this- >db_password) または die($this->show_error("データベース リンク エラー。データベース リンクの構成を確認してください。 "));
 if(!mysql_select_db($this->db_table,$this->db_conn)){

 echo "データ テーブルが見つかりません: ".$this->db_table;
 }
 mysql_select_db($ this->db_table,$this->db_conn);
 $this->query("SET NAMES $this->coding");
 }

 /*SQL ステートメントを実行する関数*/
 function query ($sql){

 if(emptyempty($sql)){
 $this->show_error("SQL ステートメントを空にすることはできません。");
 }else{
 $this->sql = $sql;
 }
 $result = mysql_query($this->sql,$this->db_conn);

 return $this->result = $result; }

 /*新しいデータベースを作成して追加します*/
 public function create_database($database_name){
 $database=$database_name;
 $sqlDatabase = 'データベースを作成します '.$database; - >query($sqlDatabase);
 }

 // 選択クエリの結果に基づいて結果セット項目の数を計算します
 public function db_num_rows(){
 if($this->result==null){
 if($this->show_error){
 $this->show_error("SQL ステートメントエラー!");
 }
 }else{
 return mysql_num_rows($this->result);

 /*すべてのサーバー データベースをクエリします*/
 //より直感的に表示するには、システム データベースとユーザー データベースを分離しますか?
 public function show_databases(){
 $this->query("show Databases");
 echo "Existingデータベース:".$ amount =$this->db_num_rows($rs);
 echo "";
 $i=1;
 while($row = $this->fetch_array($rs) )){
 echo "$i $row[Database]";
 echo ""
 $i++; }
 }

 // ホスト内のすべてのデータベース名を配列形式で返します
 public関数データベース()
 {
 $rsPtr=mysql_list_dbs($this->db_conn);
 $cnt=mysql_num_rows($rsPtr)
 {
 $rs []=mysql_db_name($ rsPtr,$i);
 $i++;
 return print_r($rs); }

 /*データベース内のすべてのテーブルをクエリします*/
 function show_tables($database_name) this->query( "show tables");
 echo "既存のデータベース:".$amount = $this->db_num_rows($rs);
 echo ""; ;
 while($ row = $this->fetch_array($rs)){
 $columnName="Tables_in_".$database_name;
 echo "";
 $i++;
 }
 }

 /*
 mysql_fetch_row() 配列 $row[0],$row[1],$row[2]
 mysql_fetch_array() 配列 $row[0] または $ row[id]
 mysql_fetch_assoc() 配列は $row->content フィールドの大文字と小文字を区別します
 mysql_fetch_object() オブジェクトは $row[id],$row[content] フィールドの大文字と小文字を区別します
 */
 /*レコードセットを取得します。配列インデックスと関連付けを取得します。 $row['content'] を使用します */
 public function fetch_array()
 {
 return @mysql_fetch_array($this->result)
 }

 // 関連付け配列を取得します。 use $row[' フィールド名']
 public function fetch_ass()
 {
 return @mysql_fetch_assoc($this->result)
 }

 // 数値インデックス配列を取得し、$row[0],$ を使用しますrow[1],$row [2]
 public function fetch_row()
 {
 return @mysql_fetch_row($this->result)
 }

 // オブジェクト配列を取得し、$row->content を使用します
 public function fetch_Object()
 {
 return @mysql_fetch_object($this->result);
 }

 //簡略化されたクエリ select
 public function findall($table){
 $table = $this->fulltablename($ table);
 $this->query("select * from $table");
 }

 public function select($table,$columnName,$condition){
 $table = $this->fulltablename($ table);
 if(emptyempty( $columnName)){
 $columnName = "*" }
 $this->query("SELECT $columnName FROM $table $condition");

 // 簡略化挿入
 関数 insert($table ,$arr){
 $table = $this->fulltablename($table);
 $sql = "INSERT INTO $table ";
 if(!is_array($arr)){
 $this->show_error( "パラメータ配列を入力してください。");
 }else{
 $k = "";
 $v = "";
 foreach($arr as $key => $value){
 $k .= "`$key`,";
 $v .= "'".$value."',"
 }
 }
 $sql = $sql." (".substr($k,0,-1).") VALUES (".substr($v,0,-1).")";
 $this->query($sql);
 }
 //化された更新
 function update($table,$arr,$where){
 $table = $this->fulltablename($table);
 $sql = "UPDATE $table SET "; ($arr)){
 $this->show_error("请输入パラメータ数组！");
 }else{
 foreach($arr as $key => $value){
 $sql .= " `".$key."` = '".$value."' ,";
 }
 }
 $sql = substr($sql,0,-1)." where ".$where;
 return $this->query($sql);
 }
 // 簡略化された削除
 関数 delete($ table ,$where = ""){
 $table = $this->fulltablename($table);
 if(emptyempty($where)){
 $this->show_error("条件を空にすることはできません!") ;
 }else{
 $where = " where ".$where;
 $sql = "$table ".$where から削除します
 //echo $sql; return $this->query($sql ) ;
 }

 //前の INSERT 操作によって生成された ID を取得します
 public function insert_id(){
 return mysql_insert_id();
 }

 // プレフィックス付きデータテーブル
 public function fulltablename($table){
 return $ table = $this->pre.$table;
 }

 //フィールドの数を問い合わせる
 public function num_fields($table){
 $table = $this->fulltablename($table); $ this ->query("select * from $table");
 echo "";
 echo "フィールド数: ".$total = mysql_num_fields($this->result); "; </li>
<li> for ($i=0; $i print_r(mysql_fetch_field($this->result,$i) ); </li>
<li> } </li>
<li> echo " ;";
 echo "";
 }

 //MySQL サーバー情報を取得
 public function mysql_server($num=''){
 switch ($num){
 case 1:
 return mysql_get_server_info (); //MySQL サーバー情報

 case 2 :
 return mysql_get_host_info(); // MySQL ホスト情報を取得

 case 3 :
 return mysql_get_client_info() // ;

 ケース 4:
 return mysql_get_proto_info(); //MySQL プロトコル情報を取得する

 デフォルト:
 return mysql_get_client_info() // デフォルトで mysql のバージョン情報を取得する
 }
 }

 // 、自動的にデータベース、ガベージ コレクション メカニズムを閉じる
 /*public function __destruct()
 {
 if(!empty($this->result)){
 $this->free() }
 mysql_close($this - >$db_conn);
 }*/

 /*クライアントの実際のIPアドレスを取得*/
 function getip(){
 if(getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "不明"))
 {
 $ip = getenv("HTTP_CLIENT_IP");
 }
 else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){
 $ip = getenv ("HTTP_X_FORWARDED_FOR");
 }
 else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
 {
 $ip = getenv("REMOTE_ADDR"); if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")){
 $ip = $_SERVER['REMOTE_ADDR']
; }
 else{
 $ip = "unknown";
 }
 return($ip); }

 function show_error($str){
 echo ""
 }

 }


 コードをコピーします







PHP