改造自discuz的MySQL查询类

MySQL查询类对于很多刚刚接触MySQL数据库的新人来说可能还比较陌生，下面就为您介绍改造自discuz的MySQL查询类，希望可以让您对MySQL查询类有更多的了解。

 
 
 
    
  
  
  
  1.   
  
  
  2. /**  
    3.   
  
  
  3. * mysql查询类  
    4.   
  
  
  4. *  
    5.   
  
  
  5. */  
    6.   
  
  
  6. class dbQuery {  
    7.   
  
  
  7. /**  
    8.   
  
  
  8. * 查询总次数  
    9.   
  
  
  9. *  
    10.   
  
  
  10. * @var int  
    11.   
  
  
  11. */  
    12.   
  
  
  12. var $querynum = 0;  
    13.   
  
  
  13. /**  
    14.   
  
  
  14. * 连接句柄  
    15.   
  
  
  15. *  
    16.   
  
  
  16. * @var object  
    17.   
  
  
  17. */  
    18.   
  
  
  18. var $link;  
    19.   
  
  
  19.  
    20.   
  
  
  20. /**  
    21.   
  
  
  21. * 构造函数  
    22.   
  
  
  22. *  
    23.   
  
  
  23. * @param string $dbhost 主机名  
    24.   
  
  
  24. * @param string $dbuser 用户  
    25.   
  
  
  25. * @param string $dbpw 密码  
    26.   
  
  
  26. * @param string $dbname 数据库名  
    27.   
  
  
  27. * @param int $pconnect 是否持续连接  
    28.   
  
  
  28. */  
    29.   
  
  
  29. function dbQuery($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0) {  
    30.   
  
  
  30. if($pconnect) {  
    31.   
  
  
  31. if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {  
    32.   
  
  
  32. $this->halt('Can not connect to MySQL server');  
    33.   
  
  
  33. }  
    34.   
  
  
  34. } else {  
    35.   
  
  
  35. if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {  
    36.   
  
  
  36. $this->halt('Can not connect to MySQL server');  
    37.   
  
  
  37. }  
    38.   
  
  
  38. }  
    39.   
  
  
  39. if($this->version() > '4.1') {  
    40.   
  
  
  40. global $dbcharset;  
    41.   
  
  
  41. if($dbcharset) {  
    42.   
  
  
  42. mysql_query("SET character_set_connection=$dbcharset, character_set_results=$dbcharset, character_set_client=binary", $this->link);  
    43.   
  
  
  43. }  
    44.   
  
  
  44. if($this->version() > '5.0.1') {  
    45.   
  
  
  45. mysql_query("SET sql_mode=''", $this->link);  
    46.   
  
  
  46. }  
    47.   
  
  
  47. }  
    48.   
  
  
  48. if($dbname) {  
    49.   
  
  
  49. mysql_select_db($dbname, $this->link);  
    50.   
  
  
  50. }  
    51.   
  
  
  51. }  
    52.   
  
  
  52. /**  
    53.   
  
  
  53. * 选择数据库  
    54.   
  
  
  54. *  
    55.   
  
  
  55. * @param string $dbname  
    56.   
  
  
  56. * @return   
    57.   
  
  
  57. */  
    58.   
  
  
  58. function select_db($dbname) {  
    59.   
  
  
  59. return mysql_select_db($dbname, $this->link);  
    60.   
  
  
  60. }  
    61.   
  
  
  61. /**  
    62.   
  
  
  62. * 取出结果集中一条记录  
    63.   
  
  
  63. *  
    64.   
  
  
  64. * @param object $query  
    65.   
  
  
  65. * @param int $result_type  
    66.   
  
  
  66. * @return array  
    67.   
  
  
  67. */  
    68.   
  
  
  68. function fetch_array($query, $result_type = MYSQL_ASSOC) {  
    69.   
  
  
  69. return mysql_fetch_array($query, $result_type);  
    70.   
  
  
  70. }  
    71.   
  
  
  71.  
    72.   
  
  
  72. /**  
    73.   
  
  
  73. * 查询SQL  
    74.   
  
  
  74. *  
    75.   
  
  
  75. * @param string $sql  
    76.   
  
  
  76. * @param string $type  
    77.   
  
  
  77. * @return object  
    78.   
  
  
  78. */  
    79.   
  
  
  79. function query($sql, $type = '') {  
    80.   
  
  
  80.  
    81.   
  
  
  81. $func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?  
    82.   
  
  
  82. 'mysql_unbuffered_query' : 'mysql_query';  
    83.   
  
  
  83. if(!($query = $func($sql, $this->link)) && $type != 'SILENT') {  
    84.   
  
  
  84. $this->halt('MySQL Query Error', $sql);  
    85.   
  
  
  85. }  
    86.   
  
  
  86. $this->querynum++;  
    87.   
  
  
  87. return $query;  
    88.   
  
  
  88. }  
    89.   
  
  
  89. /**  
    90.   
  
  
  90. * 取影响条数  
    91.   
  
  
  91. *  
    92.   
  
  
  92. * @return int  
    93.   
  
  
  93. */  
    94.   
  
  
  94. function affected_rows() {  
    95.   
  
  
  95. return mysql_affected_rows($this->link);  
    96.   
  
  
  96. }  
    97.   
  
  
  97. /**  
    98.   
  
  
  98. * 返回错误信息  
    99.   
  
  
  99. *  
    100.   
  
  
  100. * @return array  
    101.   
  
  
  101. */  
    102.   
  
  
  102. function error() {  
    103.   
  
  
  103. return (($this->link) ? mysql_error($this->link) : mysql_error());  
    104.   
  
  
  104. }  
    105.   
  
  
  105. /**  
    106.   
  
  
  106. * 返回错误代码  
    107.   
  
  
  107. *  
    108.   
  
  
  108. * @return int  
    109.   
  
  
  109. */  
    110.   
  
  
  110. function errno() {  
    111.   
  
  
  111. return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());  
    112.   
  
  
  112. }  
    113.   
  
  
  113. /**  
    114.   
  
  
  114. * 返回查询结果  
    115.   
  
  
  115. *  
    116.   
  
  
  116. * @param object $query  
    117.   
  
  
  117. * @param string $row  
    118.   
  
  
  118. * @return mixed  
    119.   
  
  
  119. */  
    120.   
  
  
  120. function result($query, $row) {  
    121.   
  
  
  121. $query = @mysql_result($query, $row);  
    122.   
  
  
  122. return $query;  
    123.   
  
  
  123. }  
    124.   
  
  
  124. /**  
    125.   
  
  
  125. * 结果条数  
    126.   
  
  
  126. *  
    127.   
  
  
  127. * @param object $query  
    128.   
  
  
  128. * @return int  
    129.   
  
  
  129. */  
    130.   
  
  
  130. function num_rows($query) {  
    131.   
  
  
  131. $query = mysql_num_rows($query);  
    132.   
  
  
  132. return $query;  
    133.   
  
  
  133. }  
    134.   
  
  
  134. /**  
    135.   
  
  
  135. * 取字段总数  
    136.   
  
  
  136. *  
    137.   
  
  
  137. * @param object $query  
    138.   
  
  
  138. * @return int  
    139.   
  
  
  139. */  
    140.   
  
  
  140. function num_fields($query) {  
    141.   
  
  
  141. return mysql_num_fields($query);  
    142.   
  
  
  142. }  
    143.   
  
  
  143. /**  
    144.   
  
  
  144. * 释放结果集  
    145.   
  
  
  145. *  
    146.   
  
  
  146. * @param object $query  
    147.   
  
  
  147. * @return bool  
    148.   
  
  
  148. */  
    149.   
  
  
  149. function free_result($query) {  
    150.   
  
  
  150. return mysql_free_result($query);  
    151.   
  
  
  151. }  
    152.   
  
  
  152. /**  
    153.   
  
  
  153. * 返回自增ID  
    154.   
  
  
  154. *  
    155.   
  
  
  155. * @return int  
    156.   
  
  
  156. */  
    157.   
  
  
  157. function insert_id() {  
    158.   
  
  
  158. return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);  
    159.   
  
  
  159. }  
    160.   
  
  
  160. /**  
    161.   
  
  
  161. * 从结果集中取得一行作为枚举数组  
    162.   
  
  
  162. *  
    163.   
  
  
  163. * @param object $query  
    164.   
  
  
  164. * @return array  
    165.   
  
  
  165. */  
    166.   
  
  
  166. function fetch_row($query) {  
    167.   
  
  
  167. $query = mysql_fetch_row($query);  
    168.   
  
  
  168. return $query;  
    169.   
  
  
  169. }  
    170.   
  
  
  170. /**  
    171.   
  
  
  171. * 从结果集中取得列信息并作为对象返回  
    172.   
  
  
  172. *  
    173.   
  
  
  173. * @param object $query  
    174.   
  
  
  174. * @return object  
    175.   
  
  
  175. */  
    176.   
  
  
  176. function fetch_fields($query) {  
    177.   
  
  
  177. return mysql_fetch_field($query);  
    178.   
  
  
  178. }  
    179.   
  
  
  179. /**  
    180.   
  
  
  180. * 返回mysql版本  
    181.   
  
  
  181. *  
    182.   
  
  
  182. * @return string  
    183.   
  
  
  183. */  
    184.   
  
  
  184. function version() {  
    185.   
  
  
  185. return mysql_get_server_info($this->link);  
    186.   
  
  
  186. }  
    187.   
  
  
  187. /**  
    188.   
  
  
  188. * 关闭连接  
    189.   
  
  
  189. *  
    190.   
  
  
  190. * @return bool  
    191.   
  
  
  191. */  
    192.   
  
  
  192. function close() {  
    193.   
  
  
  193. return mysql_close($this->link);  
    194.   
  
  
  194. }  
    195.   
  
  
  195. /**  
    196.   
  
  
  196. * 输出错误信息  
    197.   
  
  
  197. *  
    198.   
  
  
  198. * @param string $message  
    199.   
  
  
  199. * @param string $sql  
    200.   
  
  
  200. */  
    201.   
  
  
  201. function halt($message = '', $sql = '') {  
    202.   
  
  
  202. echo $message . ' ' . $sql;  
    203.   
  
  
  203. exit;  
    204.   
  
  
  204. }  
    205.   
  
  
  205. }  
    206.   
  
  
  206. ?>   
    207.   
  
  
  207.  
    208.

【编辑推荐】

MySQL查询缓存变量的相关解释

MySQL条件查询语句的用法

MySQL无重复查询的实现

五种常用的MySQL命令行

MySQL命令行乱码问题的解决

当前题目：改造自discuz的MySQL查询类
链接URL：http://www.shufengxianlan.com/qtweb/news44/355644.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

网站营销知识

分类信息网站

德阳做网站　　 　免费收录网站　　 　成都石膏隔墙板　　 　网络营销推广　　 　成都企业网站建设　　 　营销网站建设　　 　LED亮化工程　　 　小谭建站　　 　成都网站推广公司　　 　香港云主机　　 　广汉网站建设　　 　鸿艺文化　　 　电信服务器托管　　 　眉山服务器租用　　 　做网站设计　　 　成都网页制作　　 　SSL认证　　 　品牌网站建设　　 　成都ssl证书认证　　 　蜀锦在线