PDO数据库操作类

2. class HRDB{
3. protected $pdo;
4. protected $res;
5. protected $config;
7. /*构造函数*/
8. function __construct($config){
9. $this->Config = $config;
10. $this->connect();
11. }
13. /*数据库连接*/
14. public function connect(){
15. $this->pdo = new PDO($this->Config['dsn'], $this->Config['name'], $this->Config['password']);
16. $this->pdo->query('set names utf8;');
17. //把结果序列化成stdClass
18. //$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
19. //自己写代码捕获Exception
20. $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
21. }
23. /*数据库关闭*/
24. public function close(){
25. $this->pdo = null;
26. }
28. public function query($sql){
29. $res = $this->pdo->query($sql);
30. if($res){
31. $this->res = $res;
32. }
33. }
34. public function exec($sql){
35. $res = $this->pdo->exec($sql);
36. if($res){
37. $this->res = $res;
38. }
39. }
40. public function fetchAll(){
41. return $this->res->fetchAll();
42. }
43. public function fetch(){
44. return $this->res->fetch();
45. }
46. public function fetchColumn(){
47. return $this->res->fetchColumn();
48. }
49. public function lastInsertId(){
50. return $this->res->lastInsertId();
51. }
53. /**
54. * 参数说明
55. * int $debug 是否开启调试，开启则输出sql语句
56. * 0 不开启
57. * 1 开启
58. * 2 开启并终止程序
59. * int $mode 返回类型
60. * 0 返回多条记录
61. * 1 返回单条记录
62. * 2 返回行数
63. * string/array $table 数据库表，两种传值模式
64. * 普通模式：
65. * 'tb_member, tb_money'
66. * 数组模式：
67. * array('tb_member', 'tb_money')
68. * string/array $fields 需要查询的数据库字段，允许为空，默认为查找全部，两种传值模式
69. * 普通模式：
70. * 'username, password'
71. * 数组模式：
72. * array('username', 'password')
73. * string/array $sqlwhere 查询条件，允许为空，两种传值模式
74. * 普通模式：
75. * 'and type = 1 and username like "%os%"'
76. * 数组模式：
77. * array('type = 1', 'username like "%os%"')
78. * string $orderby 排序，默认为id倒序
79. */
80. public function select($debug, $mode, $table, $fields="*", $sqlwhere="", $orderby="tbid desc"){
81. //参数处理
82. if(is_array($table)){
83. $table = implode(', ', $table);
84. }
85. if(is_array($fields)){
86. $fields = implode(', ', $fields);
87. }
88. if(is_array($sqlwhere)){
89. $sqlwhere = ' and '.implode(' and ', $sqlwhere);
90. }
91. //数据库操作
92. if($debug === 0){
93. if($mode === 2){
94. $this->query("select count(tbid) from $table where 1=1 $sqlwhere");
95. $return = $this->fetchColumn();
96. }else if($mode === 1){
97. $this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby");
98. $return = $this->fetch();
99. }else{
100. $this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby");
101. $return = $this->fetchAll();
102. }
103. return $return;
104. }else{
105. if($mode === 2){
106. echo "select count(tbid) from $table where 1=1 $sqlwhere";
107. }else if($mode === 1){
108. echo "select $fields from $table where 1=1 $sqlwhere order by $orderby";
109. }
110. else{
111. echo "select $fields from $table where 1=1 $sqlwhere order by $orderby";
112. }
113. if($debug === 2){
114. exit;
115. }
116. }
117. }
119. /**
120. * 参数说明
121. * int $debug 是否开启调试，开启则输出sql语句
122. * 0 不开启
123. * 1 开启
124. * 2 开启并终止程序
125. * int $mode 返回类型
126. * 0 无返回信息
127. * 1 返回执行条目数
128. * 2 返回最后一次插入记录的id
129. * string/array $table 数据库表，两种传值模式
130. * 普通模式：
131. * 'tb_member, tb_money'
132. * 数组模式：
133. * array('tb_member', 'tb_money')
134. * string/array $set 需要插入的字段及内容，两种传值模式
135. * 普通模式：
136. * 'username = "test", type = 1, dt = now()'
137. * 数组模式：
138. * array('username = "test"', 'type = 1', 'dt = now()')
139. */
140. public function insert($debug, $mode, $table, $set){
141. //参数处理
142. if(is_array($table)){
143. $table = implode(', ', $table);
144. }
145. if(is_array($set)){
146. $set = implode(', ', $set);
147. }
148. //数据库操作
149. if($debug === 0){
150. if($mode === 2){
151. $this->query("insert into $table set $set");
152. $return = $this->lastInsertId();
153. }else if($mode === 1){
154. $this->exec("insert into $table set $set");
155. $return = $this->res;
156. }else{
157. $this->query("insert into $table set $set");
158. $return = NULL;
159. }
160. return $return;
161. }else{
162. echo "insert into $table set $set";
163. if($debug === 2){
164. exit;
165. }
166. }
167. }
169. /**
170. * 参数说明
171. * int $debug 是否开启调试，开启则输出sql语句
172. * 0 不开启
173. * 1 开启
174. * 2 开启并终止程序
175. * int $mode 返回类型
176. * 0 无返回信息
177. * 1 返回执行条目数
178. * string $table 数据库表，两种传值模式
179. * 普通模式：
180. * 'tb_member, tb_money'
181. * 数组模式：
182. * array('tb_member', 'tb_money')
183. * string/array $set 需要更新的字段及内容，两种传值模式
184. * 普通模式：
185. * 'username = "test", type = 1, dt = now()'
186. * 数组模式：
187. * array('username = "test"', 'type = 1', 'dt = now()')
188. * string/array $sqlwhere 修改条件，允许为空，两种传值模式
189. * 普通模式：
190. * 'and type = 1 and username like "%os%"'
191. * 数组模式：
192. * array('type = 1', 'username like "%os%"')
193. */
194. public function update($debug, $mode, $table, $set, $sqlwhere=""){
195. //参数处理
196. if(is_array($table)){
197. $table = implode(', ', $table);
198. }
199. if(is_array($set)){
200. $set = implode(', ', $set);
201. }
202. if(is_array($sqlwhere)){
203. $sqlwhere = ' and '.implode(' and ', $sqlwhere);
204. }
205. //数据库操作
206. if($debug === 0){
207. if($mode === 1){
208. $this->exec("update $table set $set where 1=1 $sqlwhere");
209. $return = $this->res;
210. }else{
211. $this->query("update $table set $set where 1=1 $sqlwhere");
212. $return = NULL;
213. }
214. return $return;
215. }else{
216. echo "update $table set $set where 1=1 $sqlwhere";
217. if($debug === 2){
218. exit;
219. }
220. }
221. }
223. /**
224. * 参数说明
225. * int $debug 是否开启调试，开启则输出sql语句
226. * 0 不开启
227. * 1 开启
228. * 2 开启并终止程序
229. * int $mode 返回类型
230. * 0 无返回信息
231. * 1 返回执行条目数
232. * string $table 数据库表
233. * string/array $sqlwhere 删除条件，允许为空，两种传值模式
234. * 普通模式：
235. * 'and type = 1 and username like "%os%"'
236. * 数组模式：
237. * array('type = 1', 'username like "%os%"')
238. */
239. public function delete($debug, $mode, $table, $sqlwhere=""){
240. //参数处理
241. if(is_array($sqlwhere)){
242. $sqlwhere = ' and '.implode(' and ', $sqlwhere);
243. }
244. //数据库操作
245. if($debug === 0){
246. if($mode === 1){
247. $this->exec("delete from $table where 1=1 $sqlwhere");
248. $return = $this->res;
249. }else{
250. $this->query("delete from $table where 1=1 $sqlwhere");
251. $return = NULL;
252. }
253. return $return;
254. }else{
255. echo "delete from $table where 1=1 $sqlwhere";
256. if($debug === 2){
257. exit;
258. }
259. }
260. }
261. }

复制代码

PDO