欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  后端开发

数据库连接操作类

程序员文章站 2022-06-13 09:43:07
...
数据库连接操作类
  1. class mysql
  2. {
  3. private $_link;
  4. public function __construct($dbhost,$dbuser,$dbpassword,$dbname,$charset='utf8')
  5. {
  6. $this->_link = mysql_connect($dbhost,$dbuser,$dbpassword,true); /*连接数据库*/
  7. $this->_link or $this->errmsg('Can\'t connect to MySQL server!'); /*是否连接成功*/
  8. if ($this->version() > '4.1') { /*检查数据库版本*/
  9. $this->query('set names '.$charset); /*设置数据库编码*/
  10. }
  11. mysql_select_db($dbname,$this->_link) or $this->errmsg('Can\'t select the database!'); /*打开数据库*/
  12. }
  13. /*执行数据库操作*/
  14. public function query($sql)
  15. {
  16. $result = mysql_query($sql,$this->_link);
  17. $result or $this->errmsg('Execute sql sentence error!');
  18. return $result;
  19. }
  20. /*返回根据从结果集取得的行生成的数组*/
  21. /*MYSQL_BOTH 得到一个同时包含关联和数字索引的数组 (如同 mysql_fetch_array())*/
  22. /*MYSQL_ASSOC 得到一个同时包含关联和数字索引的数组 (如同 mysql_fetch_assoc())*/
  23. /*MYSQL_NUM 得到一个同时包含关联和数字索引的数组 (如同 mysql_fetch_row())*/
  24. public function fetch_array($result,$type = MYSQL_BOTH)
  25. {
  26. return mysql_fetch_array($result,$type);
  27. }
  28. /*返回根据所取得的行生成的对象*/
  29. public function fetch_object($result)
  30. {
  31. return mysql_fetch_object($result);
  32. }
  33. /*取得前一次 MySQL 操作所影响的记录行数*/
  34. public function affected_rows()
  35. {
  36. return mysql_affected_rows($this->_link);
  37. }
  38. /* 释放结果内存*/
  39. public function free_result($result)
  40. {
  41. return mysql_free_result($result);
  42. }
  43. /* 取得结果集中行的数目*/
  44. public function num_rows($result)
  45. {
  46. return mysql_num_rows($result);
  47. }
  48. /* 取得结果集中字段的数目*/
  49. public function num_fields($result)
  50. {
  51. return mysql_num_fields($result);
  52. }
  53. /*取得上一步 INSERT 操作产生的 ID*/
  54. public function insert_id()
  55. {
  56. return mysql_insert_id($this->_link);
  57. }
  58. /* 发出mysql执行错误*/
  59. private function errmsg($msg)
  60. {
  61. $message = 'A mysql error has occurred!
    ';
  62. $message .= 'Error Number:'. mysql_errno($this->_link) .'
    ';
  63. $message .= 'Error Description:'. $msg . mysql_error($this->_link) .'
    ';
  64. $message .= 'Error Time:'. date('Y-m-d H:i:s');
  65. exit($message);
  66. }
  67. /*返回连接的标识*/
  68. public function link_id()
  69. {
  70. return $this->_link;
  71. }
  72. /*返回数据库服务器版本*/
  73. public function version() {
  74. return mysql_get_server_info($this->_link);
  75. }
  76. /*获得客户端真实的IP地址*/
  77. function getip() {
  78. if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown")) {
  79. $ip = getenv("HTTP_CLIENT_IP");
  80. } else
  81. if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")) {
  82. $ip = getenv("HTTP_X_FORWARDED_FOR");
  83. } else
  84. if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown")) {
  85. $ip = getenv("REMOTE_ADDR");
  86. } else
  87. if (isset ($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")) {
  88. $ip = $_SERVER['REMOTE_ADDR'];
  89. } else {
  90. $ip = "unknown";
  91. }
  92. return ($ip);
  93. }
  94. }
复制代码