数据库连接操作类

数据库连接操作类

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

复制代码