自己写的数据库pdo操作类，显摆一下

先说好，麻烦各位手下留情，头破血流的写了这么一个类，鄙视的话请温柔些。主要觉得DB类里有面向对象，有PDO，有sql语句，还有 try...catch.这些都是刚教的，融合融合写在一起也加深下理解，写到后面写嗨了，就真想写个以后一直能用的类，现在这个样子还算满意。有写的不合适的地方，大家多提意见，其他的我选择性忽略。

多说几句废话，好多同学刚开始的学面向对象的时候都很懵，我也一样，然后我就不耻下问的去问度娘，度娘说了一大堆废话，翻来覆去的总是那几句。在我心生恨意，低头不语的时候，忽然悟了，不是悟了什么是面向对象，是悟了度娘为什么要把这几句废话翻来覆去的说。原来重点不在于什么是面向对象，而在于你是不是 “明白”面向对象。好吧！我也开始废话了。我的意思是说，如果你从来没有吃过盐，那不论我怎么解释什么是咸，你都不会“明白”对吧。人总是喜欢用比较的方式来理解一个新事物，当发现这个事物居然在经验中没有合适比较的东西时候，就会有点懵，就会不“明白”。就像要用个模板来，套的住的部分能“明白”，套不住的部分，通过比较区别也能“明白”。现在面向对象编程没有合适模板来套，就傻了。有人说，别废话！敢不敢来直接点的。好吧，直接的答案就是把模板能套的都套上去，把没有模板套的变成模板。“这个东西就是这样！”，“你不停的练把它记住就好了”。这两句话熟悉不？你们老师有木有给你们说过，其实目的就是让你把不“明白”的东西练熟，记牢。然后你就“明白”了。

度娘翻来覆去的废话也是想给我说明这个道理吧！明白了这个道理后，我把老师写的DB类敲了6遍，其他类也没放过，然后写了下面的类。额，我意思不是下面类全抄老师的，大部分都是我自己思路哇！算了，不解释，解释就是掩饰是吧？要真不解释就是默认对吧？恩，我懂。。。

开始贴代码，把数据库连接，用户名，密码什么的一改就能用，你会的。连接建立后，echo一下对象就有各种属性，方法说明了。也希望大家能在面向对象的康庄大道上一路狂飚，嗨不嗨自己知道。。。。。

3. class db
4. {
5. public $DB=null;
6. public $DB_TYPE="mysql";
7. public $DB_HOST="localhost";
8. public $DB_NAME="db49";
9. public $DB_USER="root";
10. public $DB_PWD="123";
11. public $DB_CHARSET="utf8";
12. public $allTableNames=array();
13. private $tableName=null;
14. private $stmt=null;
15. private $fields=array();
16. public $pk=null;
20. //类实例化传参数的格式为(数据库类别,主机地址,数据库名,用户名,密码,字符集,如留空将按默认连接)
21. public function __construct($type="mysql",$host="localhost",$dbname="db49",$user="root",$pass="123456",$charset="utf8"){
22. //$cons=func_get_args();
23. //var_dump($type);
24. //var_dump($host);
25. //var_dump($name);
26. //exit;
27. $this->DB_TYPE=$type;
28. $this->DB_HOST=$host;
29. $this->DB_NAME=$dbname;
30. $this->DB_USER=$user;
31. $this->DB_PWD=$pass;
32. $this->DB_CHARSET=$charset;
33. $this->connect();
34. $this->DB->setAttribute(PDO::ATTR_EMULATE_PREPARES,true);
35. $this->DB->query('SET NAMES'.$this->charset);
36. $this->getTablesName();
37. $this->DB->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
38. $this->DB->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY ,true);
39. $this->DB->setAttribute(PDO::ATTR_AUTOCOMMIT,0);
42. }
44. public function __destruct(){
45. $this->close();
47. }
49. public function close(){
50. $this->DB=null;
51. }
55. private function connect(){
56. try{
57. $this->DB=new PDO($this->DB_TYPE.":host=".$this->DB_HOST.";dbname=".$this->DB_NAME,$this->DB_USER,$this->DB_PWD);
58. }catch(PDOException $e){
59. die("数据库连接错误:".$e->getMessage());
60. }
61. }
64. //获取表名
65. public function getTablesName(){
66. try{
67. $this->stmt=$this->DB->query('show tables');
68. //var_dump($this->DB->errorinfo());
69. while($row=$this->stmt->fetch(PDO::FETCH_NUM)){
70. $this->allTableNames[]=$row[0];
71. }
72. return $this->allTableNames;
73. $this->stmt=null;
74. }catch(PDOException $e){
75. die("获取数据库表名失败".$e->getMessage());
76. }
78. }
81. //设定使用的表名
82. public function usetable($tname){
83. try{
84. if(in_array($tname,$this->allTableNames)){
85. $this->tableName=$tname;
86. $this->stmt=$this->DB->query("desc ".$this->tableName);
87. $this->fieldsall=$this->stmt->fetchAll(PDO::FETCH_ASSOC);
88. foreach ($this->fieldsall as $row){
89. $this->fields[]=$row['Field'];
90. if($row['Key']=="PRI"){
91. $this->pk=$row['Field'];
92. }
93. }
94. $table['tablename']=$this->tableName;
95. $table['prikey']=$this->pk;
96. return $table;
97. $this->stmt=null;
98. }else{
99. echo "数据库未找到:在库'".$this->allTableNames."'中查找表'".$tname."'失败";
100. }
101. }catch(PDOException $e){
102. die("获取数据库字段失败".$e->getMessage());
103. }
104. }
108. //查看已设定的表的所有字段
109. public function seefields(){
110. foreach ($this->fields as $row){
112. echo "字段名:".$row['Field']." ,类型:".$row['Type']." ,是否为空:".$row['Null']." ,是否为主键:".$row['Key']." ,默认值:".$row['Default']." ,额外设定:".$row['Extra']."
     ";
113. }
115. }
119. //插入方法,传入变量格式为("字段名","值","字段名2","值2".....)
120. public function insert($post=array()){
121. //var_dump(func_get_args());
122. //var_dump($post);
123. $param=func_get_args();
124. //var_dump($param);
125. if(!empty($param)){
126. if(count($param)%2!=0){
127. echo "对不起,参数传递需要成对";
128. exit;
129. }
130. for($i=0;$i
131. if($i%2==0){
132. $fields[]=$param[$i];
133. }else{
134. $value[]=$param[$i];
135. }
136. }
137. for($i=0;$i
138. if(in_array($fields[$i],$this->fields) && $fields[$i]!=$this->pk){
139. $fieldslist[]=$fields[$i];
140. $valuelist[]=$value[$i];
141. }else{
142. continue;
143. }
144. }
146. }
148. try{
149. $sql="insert into `{$this->tableName}` (`".implode('`,`',$fieldslist)."`) values('".implode("','",$valuelist)."')";
150. $this->DB->beginTransaction();
151. $stmtrow=$this->DB->exec($sql);
152. $this->DB->commit();
153. return $stmtrow;
154. }catch(PDOException $e){
155. $this->DB->rollback();
156. die("插入字段失败:".$e->getMessage());
158. }
159. }
163. //where字句设定为传入变量的第一项,其后所有传入参数为set字句的选项,格式为"字段名=值",
164. public function update(){
165. $param=func_get_args();
166. //var_dump(func_get_args());
167. //将where语句从数组中提取出来
168. $tWhere=$param[0];
169. //将where语句的值加上前单引号,后单引号在sql语句拼装时加上
170. $tWhere=str_replace("=","='",$tWhere);
171. //将where语句从数组中删除,剩下的都是set的语句
172. array_shift($param);
173. //将数组中的语句拼装成set语句
174. $tSet=implode("',",$param);
175. //将set语句的值加上前单引号
176. $tSet=str_replace("=","='",$tSet);
177. //测试传入的where字句是否正确
178. $sqltest="select * from `{$this->tableName}` where ".$tWhere."'";
179. try{
180. $stmt=$this->DB->query($sqltest);
181. if($stmt->rowCount()<=0){
182. throw new Exception("where语句设定有误");
183. }
184. }catch(Exception $e){
185. die( $e->getMessage());
186. }
187. //拼装更新用sql语句
188. $sql="update `{$this->tableName}` set ".$tSet."' where ".$tWhere."'";
189. try{
190. $this->DB->beginTransaction();
191. $stmtrow=$this->DB->exec($sql);
192. $this->DB->commit();
193. return $stmtrow;
194. }catch(PDOException $e){
195. $this->DB->rollback();
196. die("更新失败:".$e->getMessage());
198. }
199. }
201. //接受传入的主键值为删除依据
202. public function del($id){
203. //拼装sql语句
204. $sql="delete from `{$this->tableName}` where {$this->pk}='{$id}'";
205. echo $sql;
206. try{
207. $stmt=$this->DB->exec($sql);
208. if($stmt<=0){
209. throw new Exception ("从新检查键值");
210. }
211. return $stmt;
212. }catch(Exception $e){
213. die("删除键值为:".$id."失败,失败原因:".$e->getMessage());
214. }
215. }
218. //传入参数为(用逗号分隔的字段名或*号,where字句,order by字句,limit字句,如果中间没有条件,用双引号留空)
219. public function select($fields,$where,$order,$limit){
220. $sql="select {$fields} FROM {$this->tableName}";
221. if($where!=""){
222. $sql.=" WHERE ".$where;
223. }
224. if($order!=""){
225. $sql.=" ORDER BY ".$order;
226. }
227. if($limit!=""){
228. $sql.=" LIMIT ".$limit;
229. }
230. try{
231. $stmt=$this->DB->query($sql);
232. $result=$stmt->fetchAll();
233. $stmt=null;
234. return $result;
235. }catch(PDOException $e){
236. echo $e->getMessage();
237. }
240. }
244. //输出该类的所有可用方法,属性和说明
245. public function __toString(){
246. $str= "您当前使用用户名'{$this->DB_USER}'已建立对库'{$this->DB_NAME}'中数据表'{$this->tableName}'的连接
     ";
247. $str.="查询该库中所有数据表,请查询该对象的'allTableNames'属性数组
     ";
248. $st.="选定数据表,请使用该对象的'usetable'方法,参数为表名";
249. $str.="查询已选择数据表中的所有字段属性,请调用该对象的'seefields'方法
     ";
250. $str.="查询已选择数据表中的主键,请查询该对象的'pk'属性
     ";
251. $str.="插入数据请使用该对象的'insert'方法,传递参数使用格式为(\"字段名\",\"值\",\"字段名2\",\"值2\".....)
     ";
252. $str.="更新数据请使用该对象的'update'方法,传递参数第一项为where字句条件,其后需更新的字段,格式为(\"条件字段名=值\",\"更新字段名=值\",[\"更新字段名2=值2\"],.....)
     ";
253. $str.="删除数据请使用该对象的'del'方法,接受主键值为删除条件
     ";
254. $str.=" 查询数据请使用该对象的'select'方法,传递参数的第一项为要查询的字段名,多个字段使用逗号分隔,全选使用*号,
     参数第二项为'where'字句的条件字段,
     参数第三项为'order by'字句的条件字段,
     参数第四项为'limit'条件的条件字段,使用逗号分隔起始值和长度数值,第二三四项如果无要求请使用双引号留空
     ";
255. return $str;
257. }
258. }

原文地址：