程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> PHP綜合 >> 數據庫操作類(完整)

數據庫操作類(完整)

編輯:PHP綜合

給大家推薦一個功能還算完整的數據庫操作類

  1. <?php    
  2. /*   
  3. *   Author  墨龍   
  4. *   Time    2010年12月2日 15:50:35    
  5. */    
  6.     
  7. $db = new mysql($db_host,$db_user,$db_passWord,$db_table,$db_conn,$pre,$coding);    
  8.     
  9. class MySQL{    
  10.         
  11.     private    $db_host;    
  12.     private    $db_user;    
  13.     private    $db_passWord;    
  14.     private    $db_table;    
  15.     private    $db_conn;           //數據庫連接標識;    
  16.     private    $result;         //執行query命令的結果資源標識    
  17.     private    $sql;      //sql執行語句    
  18.     private    $pre;      //數據庫表前綴      
  19.     private    $coding;  //數據庫編碼,GBK,UTF8,gb2312    
  20.         
  21.         
  22.     function __construct($db_host,$db_user,$db_passWord,$db_table,$db_conn,$pre,$coding){    
  23.             
  24.         $this->db_host     = $db_host;    
  25.         $this->db_user     = $db_user;    
  26.         $this->db_passWord = $db_passWord;    
  27.         $this->db_table    = $db_table;    
  28.         $this->db_conn     = $db_conn;    
  29.         $this->pre         = $pre;    
  30.         $this->coding      = $coding;    
  31.         $this->connect();    
  32.         
  33.     }    
  34.         
  35.     function connect(){    
  36.             
  37.         $this->db_conn = @MySQL_connect($this->db_host,$this->db_user,$this->db_passWord) or dIE($this->show_error("數據庫鏈接錯誤,請檢查數據庫鏈接配置!"));    
  38.         if(!MySQL_select_db($this->db_table,$this->db_conn)){    
  39.                 
  40.             echo "沒有找到數據表:".$this->db_table;    
  41.         }    
  42.         MySQL_select_db($this->db_table,$this->db_conn);    
  43.         $this->query("SET NAMES $this->coding");    
  44.     }    
  45.         
  46.     /*執行SQL語句的函數*/    
  47.     function query($sql){    
  48.             
  49.         if(emptyempty($sql)){    
  50.             $this->show_error("你的sql語句不能為空!");    
  51.         }else{              
  52.             $this->sql = $sql;    
  53.         }    
  54.         $result = MySQL_query($this->sql,$this->db_conn);    
  55.             
  56.         return $this->result = $result;    
  57.     }    
  58.         
  59.     /*創建添加新的數據庫*/    
  60.     public function create_database($database_name){    
  61.         $database=$database_name;    
  62.         $sqlDatabase = 'create database '.$database;    
  63.         return $this->query($sqlDatabase);    
  64.     }    
  65.             
  66.     // 根據select查詢結果計算結果集條數     
  67.     public function db_num_rows(){     
  68.          if($this->result==null){    
  69.             if($this->show_error){    
  70.                 $this->show_error("sql語句錯誤!");    
  71.             }               
  72.          }else{    
  73.             return  MySQL_num_rows($this->result);     
  74.          }    
  75.     }    
  76.         
  77.     /*查詢服務器所有數據庫*/    
  78.     //將系統數據庫與用戶數據庫分開,更直觀的顯示?    
  79.     public function show_databases(){    
  80.         $this->query("show databases");    
  81.         echo "現有數據庫:".$amount =$this->db_num_rows($rs);    
  82.         echo "<br />";    
  83.         $i=1;    
  84.         while($row = $this->fetch_array($rs)){               
  85.             echo "$i $row[Database]";               
  86.             echo "<br />";    
  87.             $i++;    
  88.         }    
  89.     }    
  90.         
  91.     //以數組形式返回主機中所有數據庫名     
  92.     public function databases()     
  93.     {     
  94.         $rsPtr=MySQL_list_dbs($this->db_conn);     
  95.         $i=0;     
  96.         $cnt=MySQL_num_rows($rsPtr);     
  97.         while($i<$cnt)     
  98.         {     
  99.           $rs[]=MySQL_db_name($rsPtr,$i);     
  100.           $i++;     
  101.         }     
  102.         return print_r($rs);     
  103.     }    
  104.         
  105.         
  106.     /*查詢數據庫下所有的表*/    
  107.     function show_tables($database_name){    
  108.         $this->query("show tables");    
  109.         echo "現有數據庫:".$amount = $this->db_num_rows($rs);    
  110.         echo "<br />";    
  111.         $i=1;    
  112.         while($row = $this->fetch_array($rs)){    
  113.             $columnName="Tables_in_".$database_name;    
  114.             echo "$i $row[$columnName]";    
  115.             echo "<br />";    
  116.             $i++;    
  117.         }    
  118.     }    
  119.     
  120.     /*   
  121.     MySQL_fetch_row()    array  $row[0],$row[1],$row[2]   
  122.     MySQL_fetch_array()  array  $row[0] 或 $row[id]   
  123.     MySQL_fetch_assoc()  array  用$row->content 字段大小寫敏感   
  124.     MySQL_fetch_object() object 用$row[id],$row[content] 字段大小寫敏感   
  125.     */    
  126.     /*取得記錄集,獲取數組-索引和關聯,使用$row['content'] */    
  127.     public function fetch_array()      
  128.     {           
  129.         return @MySQL_fetch_array($this->result);     
  130.     }       
  131.         
  132.     //獲取關聯數組,使用$row['字段名']    
  133.     public function fetch_ass()     
  134.     {     
  135.         return @MySQL_fetch_assoc($this->result);     
  136.     }    
  137.             
  138.     //獲取數字索引數組,使用$row[0],$row[1],$row[2]    
  139.     public function fetch_row()     
  140.     {     
  141.         return @MySQL_fetch_row($this->result);     
  142.     }    
  143.         
  144.     //獲取對象數組,使用$row->content     
  145.     public function fetch_Object()     
  146.     {     
  147.         return @MySQL_fetch_object($this->result);     
  148.     }    
  149.         
  150.     //簡化查詢select    
  151.     public function findall($table){    
  152.         $table = $this->fulltablename($table);    
  153.         $this->query("select * from $table");    
  154.     }    
  155.         
  156.     public function select($table,$columnName,$condition){    
  157.         $table = $this->fulltablename($table);    
  158.         if(emptyempty($columnName)){    
  159.             $columnName = "*";    
  160.         }    
  161.         $this->query("SELECT $columnName FROM $table $condition");    
  162.     }    
  163.         
  164.     //簡化的insert    
  165.     function insert($table,$arr){    
  166.         $table = $this->fulltablename($table);    
  167.         $sql = "INSERT INTO $table ";    
  168.         if(!is_array($arr)){    
  169.             $this->show_error("請輸入參數數組!");    
  170.         }else{    
  171.         $k = "";    
  172.         $v = "";    
  173.         foreach($arr as $key => $value){    
  174.             $k .= "`$key`,";    
  175.             $v .= "'".$value."',";    
  176.         }    
  177.         }    
  178.         $sql = $sql." (".substr($k,0,-1).") VALUES (".substr($v,0,-1).")";    
  179.         $this->query($sql);    
  180.     }    
  181.     //簡化的update    
  182.     function update($table,$arr,$where){    
  183.         $table = $this->fulltablename($table);    
  184.         $sql = "UPDATE $table SET ";    
  185.         if(!is_array($arr)){    
  186.             $this->show_error("請輸入參數數組!");    
  187.         }else{    
  188.         foreach($arr as $key => $value){    
  189.             $sql .= " `".$key."` = '".$value."' ,";    
  190.         }    
  191.         }    
  192.         $sql = substr($sql,0,-1)." where ".$where;    
  193.         return $this->query($sql);    
  194.     }    
  195.     //簡化的delete    
  196.     function delete($table,$where = ""){    
  197.         $table = $this->fulltablename($table);    
  198.         if(emptyempty($where)){    
  199.             $this->show_error("條件不能為空!");    
  200.         }else{    
  201.             $where = " where ".$where;    
  202.         }    
  203.         $sql = "DELETE FROM $table ".$where;    
  204.         //echo $sql;    
  205.         return $this->query($sql);    
  206.     }    
  207.         
  208.     //取得上一步 INSERT 操作產生的 ID    
  209.     public function insert_id(){    
  210.         return MySQL_insert_id();    
  211.     }    
  212.         
  213.     //加上前綴的數據表    
  214.     public function fulltablename($table){    
  215.         return $table = $this->pre.$table;    
  216.     }    
  217.         
  218.     //查詢字段數量    
  219.     public function num_fIElds($table){    
  220.         $table = $this->fulltablename($table);       
  221.         $this->query("select * from $table");    
  222.         echo "<br />";    
  223.         echo "字段數:".$total = MySQL_num_fIElds($this->result);    
  224.         echo "<pre>";    
  225.         for ($i=0; $i<$total; $i++){    
  226.             print_r(MySQL_fetch_fIEld($this->result,$i) );    
  227.         }    
  228.         echo "</pre>";    
  229.         echo "<br />";    
  230.     }    
  231.         
  232.     //取得 MySQL 服務器信息    
  233.     public function MySQL_server($num=''){    
  234.         switch ($num){    
  235.             case 1 :    
  236.             return MySQL_get_server_info(); //MySQL 服務器信息       
  237.             break;    
  238.                 
  239.             case 2 :    
  240.             return MySQL_get_host_info();   //取得 MySQL 主機信息    
  241.             break;    
  242.                 
  243.             case 3 :    
  244.             return MySQL_get_clIEnt_info(); //取得 MySQL 客戶端信息    
  245.             break;    
  246.                 
  247.             case 4 :    
  248.             return MySQL_get_proto_info();  //取得 MySQL 協議信息    
  249.             break;    
  250.                 
  251.             default:    
  252.             return MySQL_get_clIEnt_info(); //默認取得MySQL版本信息    
  253.         }    
  254.     }    
  255.         
  256.     //析構函數,自動關閉數據庫,垃圾回收機制    
  257.     /*public function __destruct()   
  258.     {   
  259.         if(!empty($this->result)){    
  260.             $this->free();   
  261.         }   
  262.         MySQL_close($this->$db_conn);   
  263.     }*/    
  264.         
  265.     /*獲得客戶端真實的IP地址*/    
  266.     function getip(){     
  267.         if(getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))    
  268.         {    
  269.             $ip = getenv("HTTP_CLIENT_IP");     
  270.         }    
  271.         else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){    
  272.             $ip = getenv("HTTP_X_FORWARDED_FOR");     
  273.         }    
  274.         else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))    
  275.         {    
  276.             $ip = getenv("REMOTE_ADDR");     
  277.         }    
  278.         else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")){    
  279.         $ip = $_SERVER['REMOTE_ADDR'];     
  280.         }    
  281.         else{    
  282.             $ip = "unknown";            
  283.         }    
  284.         return($ip);    
  285.     }    
  286.             
  287.     function show_error($str){          
  288.         echo "<script language='Javascript'> alert('".$str."');history.back(-1);</script>";    
  289.     }    
  290.         
  291. }    
  292. ?>   
  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved