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

mysql数据库连接操作类

发布:smiling 来源: PHP粉丝网  添加日期:2014-09-11 10:02:37 浏览: 评论:0 

分享一篇可以记录错误日志的mysql数据库连接类文件,实例代码如下:

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

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

分享到: