柠檬铺

立即咨询

柠檬铺

一个功能还算完整的数据库操作类

 

  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.     &
nbsp;   $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.       &nb
sp;     $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,<
span class="vars">$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<
/span> "字段数：".$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.             <
/span>$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. ?>   

 

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

Grow your business fast with

Suku

Subscribe Now