使用单例模式实现mysql类

3. defined('ACC')||exit('Access Denied');
4. // 封装mysql操作类,包括连接功能,及查询功能.
5. class mysql extends absdb{
6. protected static $ins = null;
7. protected $host; // 主机名
8. protected $user; // 用户名
9. protected $passwd; // 密码
10. protected $db; // 数据库名
11. protected $port; // 端口
12. protected $conn = null;
13. // 在内部操作,获得一个对象
14. public static function getIns() {
15. if(self::$ins === null) {
16. self::$ins = new self();
17. }
18. $conf = conf::getIns();
19. self::$ins->host = $conf->host;
20. self::$ins->user = $conf->user;
21. self::$ins->passwd = $conf->pwd;
22. self::$ins->db = $conf->db;
23. self::$ins->port = $conf->port;
24. self::$ins->connect();
25. self::$ins->select_db();
26. self::$ins->setChar();
27. return self::$ins;
28. }
29. // 不让外部做new操作,
30. protected function __construct() {
32. }
33. // 连接数据库
34. public function connect() {
35. $this->conn = @mysql_connect($this->host,$this->user,$this->passwd,$this->port);
36. if(!$this->conn) {
37. $error = new Exception('数据库连不上',9);
38. throw $error;
39. }
40. }
41. // 发送sql查询
42. public function query($sql) {
43. $rs = mysql_query($sql,$this->conn);
44. if(!$rs) {
45. log::write($sql);
46. }
47. return $rs;
48. }
49. // 封装一个getAll方法
50. // 参数:$sql
51. // 返回: array,false
52. public function getAll($sql) {
53. $rs = $this->query($sql);
54. if(!$rs) {
55. return false;
56. }
57. $list = array();
58. while($row = mysql_fetch_assoc($rs)) {
59. $list[] = $row;
60. }
61. return $list;
63. }
64. // 封装一个getRow方法
65. // 参数:$sql
66. // 返回: array,false
67. public function getRow($sql) {
68. $rs = $this->query($sql);
69. if(!$rs) {
70. return false;
71. }
72. return mysql_fetch_assoc($rs);
73. }
74. // 封装一个getOne方法,
75. // 参数: $sql
76. // 返回: int,str(单一的值)
77. public function getOne($sql) {
78. $rs = $this->query($sql);
79. if(!$rs) {
80. return false;
81. }
82. $tmp = mysql_fetch_row($rs);
83. return $tmp[0];
84. }
85. // 封装一个afftect_rows()方法
86. // 参数:无
87. // 返回 int 受影响行数
88. public function affected_rows() {
89. return mysql_affected_rows($this->conn);
90. }
91. // 返回最新生成的auto_increment列的值
92. public function last_id() {
93. return mysql_insert_id($this->conn);
94. }
95. // 选库函数
96. public function select_db() {
97. $sql = 'use ' . $this->db;
98. return $this->query($sql);
99. }
100. // 设置字符集的函数
101. public function setChar() {
102. $sql = 'set names utf8';
103. return $this->query($sql);
104. }
105. // 自动生成insert语句,update语句并执行
106. public function autoExecute($data,$table,$act='insert',$where='') {
108. if($act == 'insert') {
109. $sql = 'insert into ' . $table . ' (';
110. $sql .= implode(',',(array_keys($data)));
111. $sql .= ') values (\'';
112. $sql .= implode("','",array_values($data));
113. $sql .= "')";
114. } else if($act == 'update') {
115. if(!trim($where)) {
116. return false;
117. }
119. $sql = 'update ' . $table . ' set ';
120. foreach($data as $k=>$v) {
121. $sql .= $k;
122. $sql .= '=';
123. $sql .= "'".$v."',";
124. }
126. $sql = substr($sql,0,-1);
127. $sql .= ' where ';
128. $sql .= $where;
129. } else {
130. return false;
131. }
132. //return $sql;
133. return $this->query($sql);
135. }
136. }

复制代码

mysql