php pdo封装类实现mysql数据增删查改

3. define('DSN', 'mysql:host=127.0.0.1;dbname=baozhong_tour'); //数据库地址+数据库名的常量

4. define('DB_USERNAME', 'root'); //数据库用户名
5. define('DB_USERPWD', ''); //数据库密码
6. ?>
7. /**
8. * @author shuimugan
9. * @version 0.2
10. * @return PDOStatement
11. */
12. function getConn() {
13. try {
14. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD); //创建pdo对象,传入数据库参数信息
15. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置数据库错误信息
16. $db->query('set names utf8;'); //设置编码为utf8
17. return $db;
18. }
19. catch (PDOException $e) {
20. echo '数据处理出错,请联系网站管理员!';
21. print_r($e);//超详细的报错信息,上线后必须注释这句话!
22. return false;
23. }
24. }
25. /**
26. * @author shuimugan
27. * @version 0.2
28. * @param String $tablename 表名,类型为字符串
29. * @param Array $column_name 列名,要数组的格式
30. * @param String $condition 条件,如'where name=? and pws=?'或'name like?'
31. * @param Array $condition_value 条件对应的数据,类型要求为数组,如'name=? and pws=?' 时,
32. * @return Array 返回一个结果集 数组形式
33. * @example $column_name=array('*');
34. $condition_value=array('1');
35. $limit='limit 0,10';
36. $res=easy_select('user', $column_name, 'where id=? ', $condition_value,$limit);
37. */
38. function easy_select($tablename,$column_name,$condition,$condition_value,$limit) {
39. try {
40. $db=getConn();
41. $sql='select ';//初始化sql语句
42. foreach ($column_name as $col_name) {
43. //动态追加列名进sql语句
44. if($col_name=='*'){
45. $sql.='*';
46. break;
47. }
48. if($col_name==end($column_name))
49. {
50. $sql.=$col_name." ";//如果属于最后一个,语句不拼接逗号
51. }else {
52. $sql.=$col_name.", ";//拼接列名+逗号
53. }
54. }
55. $sql.="from ".$tablename." ";//拼接表名
56. $sql.=$condition.' ';//拼接条件语句
57. if(strlen($limit)>0){
58. $sql.=$limit;//拼接limit语句
59. }
60. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
61. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
62. $db->query('set names utf8;');//设置编码为utf8
63. $stmt = $db->prepare($sql);
64. $i=1;//开始计数,计算?的数量
65. $j=count($condition_value);
66. for (; $i $stmt->bindParam($i, $condition_value[$i-1]);// 绑定参数
67. $i++;
68. }
69. // 查询
70. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
71. $stmt->execute();
72. // 获取数据
73. return $stmt->fetchAll();
74. //return $stmt->rowCount();
75. } catch (PDOException $e) {
76. return false;
77. echo '数据处理出错,请联系网站管理员!';
78. print_r($e);//超详细的报错信息,上线后必须注释这句话!
79. }
80. }
81. /**
82. * @author shuimugan
83. * @version 0.2
84. * @param String $tablename 表名,类型为字符串
85. * @param Array $column_name 列名,要数组的格式
86. * @param String $condition 条件,如'where name=? and pws=?'或'name like?'
87. * @param Array $condition_value 条件对应的数据,类型要求为数组,如'name=? and pws=?' 时,
88. * @return int 返回记录条数
89. * @example $column_name=array('*');
90. $condition_value=array('1');
91. $limit='limit 0,10';
92. $res=easy_selectCount('user', $column_name, 'where id=? ', $condition_value,$limit);
93. */
94. function easy_selectCount($tablename,$column_name,$condition,$condition_value,$limit) {
95. try {
96. $db=getConn();
97. $sql='select ';//初始化sql语句
98. foreach ($column_name as $col_name) {
99. //动态追加列名进sql语句
100. if($col_name=='*'){
101. $sql.='*';
102. break;
103. }
104. if($col_name==end($column_name))
105. {
106. $sql.=$col_name." ";//如果属于最后一个,语句不拼接逗号
107. }else {
108. $sql.=$col_name.", ";//拼接列名+逗号
109. }
110. }
111. $sql.="from ".$tablename." ";//拼接表名
112. $sql.=$condition.' ';//拼接条件语句
113. if(strlen($limit)>0){
114. $sql.=$limit;//拼接limit语句
115. }
116. ;
117. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
118. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
119. $db->query('set names utf8;');//设置编码为utf8
120. $stmt = $db->prepare($sql);
121. $i=1;//开始计数,计算?的数量
122. $j=count($condition_value);
123. for (; $i $stmt->bindParam($i, $condition_value[$i-1]);// 绑定参数
124. $i++;
125. }
126. // 查询
127. //$stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
128. $stmt->execute();
129. // 获取数据
130. return $stmt->rowCount();
131. } catch (PDOException $e) {
132. return false;
133. echo '数据处理出错,请联系网站管理员!';
134. print_r($e);//超详细的报错信息,上线后必须注释这句话!
135. }
136. }
137. /**
138. * @author shuimugan
139. * @version 0.2
140. * @param String $tablename 表名,类型为字符串
141. * @param Array $column_name 列名,要数组的格式
142. * @param Array $column_value 对应的数据,要求数组的格式
143. * @return int 返回最后自增的id
144. * @example $column_name=array('pwd','ip','name');
145. $column_value=array('1246','11.11.11.11','张三');
146. echo easy_insert('user',$column_name,$column_value);
147. */
148. function easy_insert($tablename,$column_name,$column_value) {
149. try {
150. $db=getConn();
151. $sql='INSERT INTO ';//初始化sql语句
152. $sql.=$tablename.' (';//拼接表名
153. foreach ($column_name as $col_name) {
154. //动态追加列名进sql语句
155. if($col_name==end($column_name))
156. {
157. $sql.=$col_name." )";//如果属于最后一个,拼接右括号
158. }else {
159. $sql.=$col_name.", ";//拼接列名+逗号
160. }
161. }
162. $sql.=' VALUES (';//拼接$condition_value语句
163. for ($i=0; $i if ($i==count($column_name)-1) {
164. $sql.='?) ;';
165. }else {
166. $sql.='?,';
167. }
168. }
169. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
170. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
171. $db->query('set names utf8;');//设置编码为utf8
172. $stmt = $db->prepare($sql);
173. for ($i=1; $i $stmt->bindParam($i, $column_value[$i-1]);
174. }
175. // 查询
176. //echo $sql;
177. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
178. $stmt->execute();
179. // 获取数据
180. return $db->lastInsertId();
181. } catch (PDOException $e) {
182. return false;
183. echo '数据处理出错,请联系网站管理员!';
184. print_r($e);//超详细的报错信息,上线后必须注释这句话!
185. }
186. }
187. /**
188. * @author shuimugan
189. * @version 0.2
190. * @param String $tablename 表名,类型为字符串
191. * @param Array $column_name 列名,要数组的格式
192. * @param Array $column_value 对应的数据,要求数组的格式
193. * @param String $condition 对应的的where语句 字符串 如 'where id=?'
194. * @param Array $condition_value 对应where 后面问号的数据 类型要求为数组
195. * @return int 返回影响的数据行数
196. * @example $column_name=array('pwd','ip','name');
197. $column_value=array('123456','127.152.123.132','张三');
198. $condition_value=array('1');
199. easy_update('user',$column_name,$column_value,'where id=?',$condition_value,null);
200. */
201. function easy_update($tablename,$column_name,$column_value,$condition,$condition_value,$limit) {
202. try {
203. $db=getConn();
204. $sql='UPDATE ';//初始化sql语句
205. $sql.=$tablename.' SET ';//拼接表名
206. foreach ($column_name as $col_name) {
207. //动态追加列名进sql语句
208. if($col_name==end($column_name))
209. {
210. $sql.=$col_name." = ? ";//如果属于最后一个
211. }else {
212. $sql.=$col_name." = ?, ";//拼接列名+逗号
213. }
214. }
215. $sql.=$condition;//拼接条件语句
216. if(strlen($limit)>0){
217. $sql.=$limit;//拼接limit语句
218. }
219. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
220. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
221. $db->query('set names utf8;');//设置编码为utf8
222. $stmt = $db->prepare($sql);//准备语句
223. $i=1;
224. $total=count($column_name)+count($condition_value);
225. for (;$i $stmt->bindParam($i, $column_value[$i-1]);//绑定列名对应数据参数
226. $i++;
227. }
228. $j=1;
229. for (;$i $stmt->bindParam($i, $condition_value[$j-1]);//绑定条件对应数据参数
230. $i++;
231. $j++;
232. }
233. // 查询
234. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
235. $stmt->execute();
236. // 获取数据
237. return $stmt->rowCount();
238. } catch (PDOException $e) {
239. return false;
240. echo '数据处理出错,请联系网站管理员!';
241. print_r($e);//超详细的报错信息,上线后必须注释这句话!
242. }
243. }
244. /**
245. * @author shuimugan
246. * @version 0.2
247. * @param String $tablename 表命名
248. * @param String $condition 条件 如 'where id= ?'
249. * @param Array $condition_value 条件对应的值 就是?对应的值
250. * @param String $limit 限制语句 如'limit 0,1'
251. * @return int 返回影响结果数
252. * @example $condition_value=array('83');
253. echo easy_delete('user', 'where id=?', $condition_value, null);
254. */
255. function easy_delete($tablename,$condition,$condition_value,$limit) {
256. try {
257. $db=getConn();
258. $sql='DELETE FROM ';//初始化sql语句
259. $sql.=$tablename.' ';//拼接表名
260. $sql.=$condition;//拼接条件语句
261. if(strlen($limit)>0){
262. $sql.=$limit;//拼接limit语句
263. }
264. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
265. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
266. $db->query('set names utf8;');//设置编码为utf8
267. $stmt = $db->prepare($sql);//准备语句
268. for ($i=1;$i $stmt->bindParam($i, $condition_value[$i-1]);//绑定条件对应数据参数
269. $i++;
270. }
271. // 查询
272. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
273. $stmt->execute();
274. // 获取数据
275. return $stmt->rowCount();
276. } catch (PDOException $e) {
277. return false;
278. echo '数据处理出错,请联系网站管理员!';
279. print_r($e);//超详细的报错信息,上线后必须注释这句话!

280. }

281. }
282. ?>

复制代码