当前位置:首页 > PHP教程 > php类库 > 列表

php mysql完整数据库连接类

发布:smiling 来源: PHP粉丝网  添加日期:2014-09-11 13:29:54 浏览: 评论:0 
  1. class mysql { 
  2.  private $db_host//数据库主机 
  3.  private $db_user//数据库用户名 
  4.  private $db_pwd//数据库用户名密码 
  5.  private $db_database//数据库名 
  6.  private $conn//数据库连接标识; 
  7.  private $result//执行query命令的结果资源标识 
  8.  private $sql//sql执行语句 
  9.  private $row//返回的条目数 
  10.  private $coding//数据库编码,gbk,utf8,gb2312 
  11.  private $bulletin = true; //是否开启错误记录 
  12.  private $show_error = false; //测试阶段,显示所有错误,具有安全隐患,默认关闭 
  13.  private $is_error = false; //发现错误是否立即终止,默认true,建议不启用,因为当有问题时用户什么也看不到是很苦恼的 
  14.  
  15.  /*构造函数*/ 
  16.  public function __construct($db_host$db_user$db_pwd$db_database$conn$coding) { 
  17.   $this->db_host = $db_host
  18.   $this->db_user = $db_user
  19.   $this->db_pwd = $db_pwd
  20.   $this->db_database = $db_database
  21.   $this->conn = $conn
  22.   $this->coding = $coding
  23.   $this->connect(); 
  24.  } 
  25.  
  26.  /*数据库连接*/ 
  27.  public function connect() { 
  28.   if ($this->conn == "pconn") { 
  29.    //永久链接 
  30.    $this->conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd); 
  31.   } else { 
  32.    //即使链接 
  33.    $this->conn = mysql_connect($this->db_host, $this->db_user, $this->db_pwd); 
  34.   } 
  35.  
  36.   if (!mysql_select_db($this->db_database, $this->conn)) { 
  37.    if ($this->show_error) { 
  38.     $this->show_error("数据库不可用:"$this->db_database); 
  39.    } 
  40.   } 
  41.   mysql_query("set names $this->coding"); 
  42.  } 
  43.  
  44.  /*数据库执行语句,可执行查询添加修改删除等任何sql语句*/ 
  45.  public function query($sql) { 
  46.   if ($sql == "") { 
  47.    $this->show_error("sql语句错误:""sql查询语句为空"); 
  48.   } 
  49.   $this->sql = $sql
  50.  
  51.   $result = mysql_query($this->sql, $this->conn); 
  52.  
  53.   if (!$result) { 
  54.    //调试中使用,sql语句出错时会自动打印出来 
  55.    if ($this->show_error) { 
  56.     $this->show_error("错误sql语句:"$this->sql); 
  57.    } 
  58.   } else { 
  59.    $this->result = $result
  60.   } 
  61.   return $this->result; 
  62.  } 
  63.  
  64.  /*创建添加新的数据库*/ 
  65.  public function create_database($database_name) { 
  66.   $database = $database_name
  67.   $sqldatabase = 'create database ' . $database
  68.   $this->query($sqldatabase); 
  69.  } 
  70.  
  71.  /*查询服务器所有数据库*/ 
  72.  //将系统数据库与用户数据库分开,更直观的显示? 
  73.  public function show_databases() { 
  74.   $this->query("show databases"); 
  75.   echo "现有数据库:" . $amount = $this->db_num_rows($rs); 
  76.   echo "<br />"
  77.   $i = 1; 
  78.   while ($row = $this->fetch_array($rs)) { 
  79.    echo "$i $row[database]"
  80.    echo "<br />"
  81.    $i++; 
  82.   } 
  83.  } 
  84.  
  85.  //以数组形式返回主机中所有数据库名 
  86.  public function databases() { 
  87.   $rsptr = mysql_list_dbs($this->conn); 
  88.   $i = 0; 
  89.   $cnt = mysql_num_rows($rsptr); 
  90.   while ($i < $cnt) { 
  91.    $rs[] = mysql_db_name($rsptr$i); 
  92.    $i++; 
  93.   } 
  94.   return $rs
  95.  } 
  96.  
  97.  /*查询数据库下所有的表*/ 
  98.  public function show_tables($database_name) { 
  99.   $this->query("show tables"); 
  100.   echo "现有数据库:" . $amount = $this->db_num_rows($rs); 
  101.   echo "<br />"
  102.   $i = 1; 
  103.   while ($row = $this->fetch_array($rs)) { 
  104.    $columnname = "tables_in_" . $database_name
  105.    echo "$i $row[$columnname]"
  106.    echo "<br />"
  107.    $i++; 
  108.   } 
  109.  } 
  110.  
  111.  /* 
  112.  mysql_fetch_row()    array  $row[0],$row[1],$row[2] 
  113.  mysql_fetch_array()  array  $row[0] 或 $row[id] 
  114.  mysql_fetch_assoc()  array  用$row->content 字段大小写敏感 
  115.  mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感 
  116.  */ 
  117.  
  118.  /*取得结果数据*/ 
  119.  public function mysql_result_li() { 
  120.   return mysql_result($str); 
  121.  } 
  122.  
  123.  /*取得记录集,获取数组-索引和关联,使用$row['content'] */ 
  124.  public function fetch_array($resultt="") { 
  125.   if($resultt<>""){ 
  126.    return mysql_fetch_array($resultt); 
  127.   }else
  128.   return mysql_fetch_array($this->result); 
  129.   } 
  130.  } 
  131.  
  132.  //获取关联数组,使用$row['字段名'] 
  133.  public function fetch_assoc() { 
  134.   return mysql_fetch_assoc($this->result); 
  135.  } 
  136.  
  137.  //获取数字索引数组,使用$row[0],$row[1],$row[2] 
  138.  public function fetch_row() { 
  139.   return mysql_fetch_row($this->result); 
  140.  } 
  141.  
  142.  //获取对象数组,使用$row->content 
  143.  public function fetch_object() { 
  144.   return mysql_fetch_object($this->result); 
  145.  } 
  146.  
  147.  //简化查询select 
  148.  public function findall($table) { 
  149.   $this->query("select * from $table"); 
  150.  } 
  151.  
  152.  //简化查询select 
  153.  public function select($table$columnname = "*"$condition = ''$debug = '') { 
  154.   $condition = $condition ? ' where ' . $condition : null; 
  155.   if ($debug) { 
  156.    echo "select $columnname from $table $condition"
  157.   } else { 
  158.    $this->query("select $columnname from $table $condition"); 
  159.   } 
  160.  } 
  161.  
  162.  //简化删除del 
  163.  public function delete($table$condition$url = '') { 
  164.   if ($this->query("delete from $table where $condition")) { 
  165.    if (!emptyempty ($url)) 
  166.     $this->get_admin_msg($url'删除成功!'); 
  167.   } 
  168.  } 
  169.  
  170.  //简化插入insert 
  171.  public function insert($table$columnname$value$url = '') { 
  172.   if ($this->query("insert into $table ($columnname) values ($value)")) { 
  173.    if (!emptyempty ($url)) 
  174.     $this->get_admin_msg($url'添加成功!'); 
  175.   } 
  176.  } 
  177.  
  178.  //简化修改update 
  179.  public function update($table$mod_content$condition$url = '') { 
  180.   //echo "update $table set $mod_content where $condition"; exit(); 
  181.   if ($this->query("update $table set $mod_content where $condition")) { 
  182.    if (!emptyempty ($url)) 
  183.     $this->get_admin_msg($url); 
  184.   } 
  185.  } 
  186.  
  187.  /*取得上一步 insert 操作产生的 id*/ 
  188.  public function insert_id() { 
  189.   return mysql_insert_id(); 
  190.  } 
  191.  
  192.  //指向确定的一条数据记录 
  193.  public function db_data_seek($id) { 
  194.   if ($id > 0) { 
  195.    $id = $id -1; 
  196.   } 
  197.   if (!@ mysql_data_seek($this->result, $id)) { 
  198.    $this->show_error("sql语句有误:""指定的数据为空"); 
  199.   } 
  200.   return $this->result; 
  201.  } 
  202.  
  203.  // 根据select查询结果计算结果集条数 
  204.  public function db_num_rows() { 
  205.   if ($this->result == null) { 
  206.    if ($this->show_error) { 
  207.     $this->show_error("sql语句错误""暂时为空,没有任何内容!"); 
  208.    } 
  209.   } else { 
  210.    return mysql_num_rows($this->result); 
  211.   } 
  212.  } 
  213.  
  214.  // 根据insert,update,delete执行结果取得影响行数 
  215.  public function db_affected_rows() { 
  216.   return mysql_affected_rows(); 
  217.  } 
  218.  
  219.  //输出显示sql语句 
  220.  public function show_error($message = ""$sql = "") { 
  221.   if (!$sql) { 
  222.    echo "<font color='red'>" . $message . "</font>"
  223.    echo "<br />"
  224.   } else { 
  225.    echo "<fieldset>"
  226.    echo "<legend>错误信息提示:</legend><br />"
  227.    echo "<div style='font-size:14px; clear:both; font-family:verdana, arial, helvetica, sans-serif;'>"
  228.    echo "<div style='height:20px; background:#000000; border:1px #000000 solid'>"
  229.    echo "<font color='white'>错误号:12142</font>"
  230.    echo "</div><br />"
  231.    echo "错误原因:" . mysql_error() . "<br /><br />"
  232.    echo "<div style='height:20px; background:#ff0000; border:1px #ff0000 solid'>"
  233.    echo "<font color='white'>" . $message . "</font>"
  234.    echo "</div>"
  235.    echo "<font color='red'><pre>" . $sql . "</pre></font>"
  236.    $ip = $this->getip(); 
  237.    if ($this->bulletin) { 
  238.     $time = date("y-m-d h:i:s"); 
  239.     $message = $message . "rn$this->sql" . "rn客户ip:$ip" . "rn时间 :$time" . "rnrn"
  240.  
  241.     $server_date = date("y-m-d"); 
  242.     $filename = $server_date . ".txt"
  243.     $file_path = "error/" . $filename
  244.     $error_content = $message
  245.     //$error_content="错误的数据库,不可以链接"; 
  246.     $file = "error"//设置文件保存目录 
  247.  
  248.     //建立文件夹 
  249.     if (!file_exists($file)) { 
  250.      if (!mkdir($file, 0777)) { 
  251.       //默认的 mode 是 0777,意味着最大可能的访问权 
  252.       die("upload files directory does not exist and creation failed"); 
  253.      } 
  254.     } 
  255.  
  256.     //建立txt日期文件 
  257.     if (!file_exists($file_path)) { 
  258.  
  259.      //echo "建立日期文件"; 
  260.      fopen($file_path"w+"); 
  261.  
  262.      //首先要确定文件存在并且可写 
  263.      if (is_writable($file_path)) { 
  264.       //使用添加模式打开$filename,文件指针将会在文件的开头 
  265.       if (!$handle = fopen($file_path'a')) { 
  266.        echo "不能打开文件 $filename"
  267.        exit
  268.       } 
  269.  
  270.       //将$somecontent写入到我们打开的文件中。 
  271.       if (!fwrite($handle$error_content)) { 
  272.        echo "不能写入到文件 $filename"
  273.        exit
  274.       } 
  275.  
  276.       //echo "文件 $filename 写入成功"; 
  277.  
  278.       echo "——错误记录被保存!"
  279.  
  280.       //关闭文件 
  281.       fclose($handle); 
  282.      } else { 
  283.       echo "文件 $filename 不可写"
  284.      } 
  285.  
  286.     } else { 
  287.      //首先要确定文件存在并且可写 
  288.      if (is_writable($file_path)) { 
  289.       //使用添加模式打开$filename,文件指针将会在文件的开头 
  290.       if (!$handle = fopen($file_path'a')) { 
  291.        echo "不能打开文件 $filename"
  292.        exit
  293.       } 
  294.  
  295.       //将$somecontent写入到我们打开的文件中。 
  296.       if (!fwrite($handle$error_content)) { 
  297.        echo "不能写入到文件 $filename"
  298.        exit
  299.       } 
  300.  
  301.       //echo "文件 $filename 写入成功"; 
  302.       echo "——错误记录被保存!"
  303.  
  304.       //关闭文件 
  305.       fclose($handle); 
  306.      } else { 
  307.       echo "文件 $filename 不可写"
  308.      } 
  309.     } 
  310.  
  311.    } 
  312.    echo "<br />"
  313.    if ($this->is_error) { 
  314.     exit
  315.    } 
  316.   } 
  317.   echo "</div>"
  318.   echo "</fieldset>"
  319.  
  320.   echo "<br />"
  321.  } 
  322.  
  323.  //释放结果集 
  324.  public function free() { 
  325.   @ mysql_free_result($this->result); 
  326.  } 
  327.  
  328.  //数据库选择 
  329.  public function select_db($db_database) { 
  330.   return mysql_select_db($db_database); 
  331.  } 
  332.  
  333.  //查询字段数量 
  334.  public function num_fields($table_name) { 
  335.   //return mysql_num_fields($this->result); 
  336.   $this->query("select * from $table_name"); 
  337.   echo "<br />"
  338.   echo "字段数:" . $total = mysql_num_fields($this->result); 
  339.   echo "<pre>"
  340.   for ($i = 0; $i < $total$i++) { 
  341.    print_r(mysql_fetch_field($this->result, $i)); 
  342.   } 
  343.   echo "</pre>"
  344.   echo "<br />"
  345.  } 
  346.  
  347.  //取得 mysql 服务器信息 
  348.  public function mysql_server($num = '') { 
  349.   switch ($num) { 
  350.    case 1 : 
  351.     return mysql_get_server_info(); //mysql 服务器信息 
  352.     break
  353.  
  354.    case 2 : 
  355.     return mysql_get_host_info(); //取得 mysql 主机信息 
  356.     break
  357.  
  358.    case 3 : 
  359.     return mysql_get_client_info(); //取得 mysql 客户端信息 
  360.     break
  361.  
  362.    case 4 : 
  363.     return mysql_get_proto_info(); //取得 mysql 协议信息 
  364.     break
  365.  
  366.    default : 
  367.     return mysql_get_client_info(); //默认取得mysql版本信息 
  368.   }//开源代码phpfensi.com 
  369.  } 
  370.  
  371.  //析构函数,自动关闭数据库,垃圾回收机制 
  372.  public function __destruct() { 
  373.   if (!emptyempty ($this->result)) { 
  374.    $this->free(); 
  375.   } 
  376.   mysql_close($this->conn); 
  377.  } //function __destruct(); 
  378.  
  379.  /*获得客户端真实的ip地址*/ 
  380.  function getip() { 
  381.   if (getenv("http_client_ip") && strcasecmp(getenv("http_client_ip"), "unknown")) { 
  382.    $ip = getenv("http_client_ip"); 
  383.   } else 
  384.    if (getenv("http_x_forwarded_for") && strcasecmp(getenv("http_x_forwarded_for"), "unknown")) { 
  385.     $ip = getenv("http_x_forwarded_for"); 
  386.    } else 
  387.     if (getenv("remote_addr") && strcasecmp(getenv("remote_addr"), "unknown")) { 
  388.      $ip = getenv("remote_addr"); 
  389.     } else 
  390.      if (isset ($_server['remote_addr']) && $_server['remote_addr'] && strcasecmp($_server['remote_addr'], "unknown")) { 
  391.       $ip = $_server['remote_addr']; 
  392.      } else { 
  393.       $ip = "unknown"
  394.      } 
  395.   return ($ip); 
  396.  } 
  397.  function inject_check($sql_str) { //防止注入 
  398.   $check = eregi('select|insert|update|delete|'|/*|*|../|./|union|into|load_file|outfile', $sql_str); 
  399.   if ($check) { 
  400.    echo "输入非法注入内容!"; 
  401.    exit (); 
  402.   } else { 
  403.    return $sql_str; 
  404.   } 
  405.  } 
  406.  function checkurl() { //检查来路 
  407.   if (preg_replace("/https?://([^:/]+).*/i", "1"$_server['http_referer']) !== preg_replace("/([^:]+).*/""1"$_server['http_host'])) { 
  408.    header("location: http://www.phpfensi.com"); 
  409.    exit(); 
  410.   } 
  411.  } 
  412.  
  413. }

Tags: mysql连接类 php数据库连接类

分享到: