本文实例讲述了PHP的PDO常用类库。分享给大家供大家参考，具体如下：

1、Db.class.php 连接数据库

1. <?php 
2.  
3. // 连接数据库 
4.  
5. class Db { 
6.  
7.   static public function getDB() { 
8.  
9.     try { 
10.  
11.       $pdo = new PDO(DB_DSN, DB_USER, DB_PWD); 
12.  
13.       $pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 设置数据库连接为持久连接 
14.  
15.       $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置抛出错误 
16.  
17.       $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true); // 设置当字符串为空转换为 SQL 的 NULL 
18.  
19.       $pdo->query('SET NAMES utf8'); // 设置数据库编码 
20.  
21.     } catch (PDOException $e) { 
22.  
23.       exit('数据库连接错误，错误信息：'. $e->getMessage()); 
24. //phpfensi.com 
25.     } 
26.  
27.     return $pdo; 
28.  
29.   } 
30.  
31. } 
32.  
33. ?> 

2、Model.class.php 数据库操作类

1. <?php 
2.  
3. /** 
4.  
5. * 数据库操作类库 
6.  
7. * author Lee. 
8.  
9. * Last modify $Date: 2012-1-19 13:59；04 $ 
10.  
11. */ 
12.  
13. class M { 
14.  
15.   private $_db; //数据库句柄 
16.  
17.   public $_sql; //SQL语句 
18.  
19.   /** 
20.  
21.    * 构造方法 
22.  
23.    */ 
24.  
25.   public function __construct() { 
26.  
27.     $this->_db = Db::getDB(); 
28.  
29.   } 
30.  
31.   /** 
32.  
33.    * 数据库添加操作 
34.  
35.    * @param string $tName 表名 
36.  
37.    * @param array $field 字段数组 
38.  
39.    * @param array $val 值数组 
40.  
41.    * @param bool $is_lastInsertId 是否返回添加ID 
42.  
43.    * @return int 默认返回成功与否，$is_lastInsertId 为true，返回添加ID 
44.  
45.    */ 
46.  
47.   public function insert($tName, $fields, $vals, $is_lastInsertId=FALSE) { 
48.  
49.     try { 
50.  
51.       if (!is_array($fields) || !is_array($vals)) 
52.  
53.         exit($this->getError(__FUNCTION__, __LINE__)); 
54.  
55.       $fields = $this->formatArr($fields); 
56.  
57.       $vals = $this->formatArr($vals, false); 
58.  
59.       $tName = $this->formatTabName($tName); 
60.  
61.       $this->_sql = "INSERT INTO {$tName} ({$fields}) VALUES ({$vals})"; 
62.  
63.       if (!$is_lastInsertId) { 
64.  
65.         $row = $this->_db->exec($this->_sql); 
66.  
67.         return $row; 
68.  
69.       } else { 
70.  
71.         $this->_db->exec($this->_sql); 
72.  
73.         $lastId = (int)$this->_db->lastInsertId(); 
74.  
75.         return $lastId; 
76.  
77.       } 
78.  
79.     } catch (PDOException $e) { 
80.  
81.       exit($e->getMessage()); 
82.  
83.     } 
84.  
85.   } 
86.  
87.   /** 
88.  
89.    * 数据库修改操作 
90.  
91.    * @param string $tName 表名 
92.  
93.    * @param array $field 字段数组 
94.  
95.    * @param array $val 值数组 
96.  
97.    * @param string $condition 条件 
98.  
99.    * @return int 受影响的行数 
100.  
101.    */ 
102.  
103.   public function update($tName, $fieldVal, $condition) { 
104.  
105.     try { 
106.  
107.       if (!is_array($fieldVal) || !is_string($tName) || !is_string($condition)) 
108.  
109.         exit($this->getError(__FUNCTION__, __LINE__)); 
110.  
111.       $tName = $this->formatTabName($tName); 
112.  
113.       $upStr = ''; 
114.  
115.       foreach ($fieldVal as $k=>$v) { 
116.  
117.         $upStr .= '`'.$k . '`=' . '\'' . $v . '\'' . ','; 
118.  
119.       } 
120.  
121.       $upStr = rtrim($upStr, ','); 
122.  
123.       $this->_sql = "UPDATE {$tName} SET {$upStr} WHERE {$condition}"; 
124.  
125.       $row = $this->_db->exec($this->_sql); 
126.  
127.       return $row; 
128.  
129.     } catch (PDOException $e) { 
130.  
131.       exit($e->getMessage()); 
132.  
133.     } 
134.  
135.   } 
136.  
137.   /** 
138.  
139.    * 数据库删除操作（注：必须添加 where 条件） 
140.  
141.    * @param string $tName 表名 
142.  
143.    * @param string $condition 条件 
144.  
145.    * @return int 受影响的行数 
146.  
147.    */ 
148.  
149.   public function del($tName, $condition) { 
150.  
151.     try { 
152.  
153.       if (!is_string($tName) || !is_string($condition)) 
154.  
155.         exit($this->getError(__FUNCTION__, __LINE__)); 
156.  
157.       $tName= $this->formatTabName($tName); 
158.  
159.       $this->_sql = "DELETE FROM {$tName} WHERE {$condition}"; 
160.  
161.       $row = $this->_db->exec($this->_sql); 
162.  
163.       return $row; 
164.  
165.     } catch (PDOException $e) { 
166.  
167.       exit($e->getMessage()); 
168.  
169.     } 
170.  
171.   } 
172.  
173.   /** 
174.  
175.    * 返回表总个数 
176.  
177.    * @param string $tName 表名 
178.  
179.    * @param string $condition 条件 
180.  
181.    * @return int 
182.  
183.    */ 
184.  
185.   public function total($tName, $condition='') { 
186.  
187.     try { 
188.  
189.       if (!is_string($tName)) 
190.  
191.         exit($this->getError(__FUNCTION__, __LINE__)); 
192.  
193.       $tName = $this->formatTabName($tName); 
194.  
195.       $this->_sql = "SELECT COUNT(*) AS total FROM {$tName}" . 
196.  
197.       ($condition=='' ? '' : ' WHERE ' . $condition); 
198.  
199.       $re = $this->_db->query($this->_sql); 
200.  
201.       foreach ($re as $v) { 
202.  
203.         $total = $v['total']; 
204.  
205.       } 
206.  
207.       return (int)$total; 
208.  
209.     } catch (PDOException $e) { 
210.  
211.       exit($e->getMessage()); 
212.  
213.     } 
214.  
215.   } 
216.  
217.   /** 
218.  
219.    * 数据库删除多条数据 
220.  
221.    * @param string $tName 表名 
222.  
223.    * @param string $field 依赖字段 
224.  
225.    * @param array $ids 删除数组 
226.  
227.    * @return int 受影响的行数 
228.  
229.    */ 
230.  
231.   public function delMulti($tName, $field, $ids) { 
232.  
233.     try { 
234.  
235.       if (!is_string($tName) || !is_array($ids)) 
236.  
237.         exit($this->getError(__FUNCTION__, __LINE__)); 
238.  
239.       $delStr = ''; 
240.  
241.       $tName = $this->formatTabName($tName); 
242.  
243.       $field = $this->formatTabName($field); 
244.  
245.       foreach ($ids as $v) { 
246.  
247.         $delStr .= $v . ','; 
248.  
249.       } 
250.  
251.       $delStr = rtrim($delStr, ','); 
252.  
253.       $this->_sql = "DELETE FROM {$tName} WHERE {$field} IN ({$delStr})"; 
254.  
255.       $row = $this->_db->exec($this->_sql); 
256.  
257.       return $row; 
258.  
259.     } catch (PDOException $e) { 
260.  
261.       exit($e->getMessage()); 
262.  
263.     } 
264.  
265.   } 
266.  
267.   /** 
268.  
269.    * 获取表格的最后主键（注：针对 INT 类型） 
270.  
271.    * @param string $tName 表名 
272.  
273.    * @return int 
274.  
275.    */ 
276.  
277.   public function insertId($tName) { 
278.  
279.     try { 
280.  
281.       if (!is_string($tName)) 
282.  
283.         exit($this->getError(__FUNCTION__, __LINE__)); 
284.  
285.       $this->_sql = "SHOW TABLE STATUS LIKE '{$tName}'"; 
286.  
287.       $result = $this->_db->query($this->_sql); 
288.  
289.       $insert_id = 0; 
290.  
291.       foreach ($result as $v) { 
292.  
293.         $insert_id = $v['Auto_increment']; 
294.  
295.       } 
296.  
297.       return (int)$insert_id; 
298.  
299.     } catch (PDOException $e) { 
300.  
301.       exit($e->getMessage()); 
302.  
303.     } 
304.  
305.   } 
306.  
307.   /** 
308.  
309.    * 检查数据是否已经存在（依赖条件） 
310.  
311.    * @param string $tName 表名 
312.  
313.    * @param string $field 依赖的字段 
314.  
315.    * @return bool 
316.  
317.    */ 
318.  
319.   public function exists($tName, $condition) { 
320.  
321.     try { 
322.  
323.       if (!is_string($tName) || !is_string($condition)) 
324.  
325.         exit($this->getError(__FUNCTION__, __LINE__)); 
326.  
327.       $tName = $this->formatTabName($tName); 
328.  
329.       $this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$condition}"; 
330.  
331.       $result = $this->_db->query($this->_sql); 
332.  
333.       foreach ($result as $v) { 
334.  
335.          $b = $v['total']; 
336.  
337.       } 
338.  
339.       if ($b) { 
340.  
341.         return true; 
342.  
343.       } else { 
344.  
345.         return false; 
346.  
347.       } 
348.  
349.     } catch (PDOException $e) { 
350.  
351.       exit($e->getMessage()); 
352.  
353.     } 
354.  
355.   } 
356.  
357.   /** 
358.  
359.    * 检查数据是否已经存在（依赖 INT 主键） 
360.  
361.    * @param string $tName 表名 
362.  
363.    * @param string $primary 主键 
364.  
365.    * @param int $id 主键值 
366.  
367.    * @return bool 
368.  
369.    */ 
370.  
371.   public function existsByPK($tName, $primary, $id) { 
372.  
373.     try { 
374.  
375.       if (!is_string($tName) || !is_string($primary) 
376.  
377.       || !is_int($id)) 
378.  
379.         exit($this->getError(__FUNCTION__, __LINE__)); 
380.  
381.       $tName = $this->formatTabName($tName); 
382.  
383.       $this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$primary} = ". $id; 
384.  
385.       $result = $this->_db->query($this->_sql); 
386.  
387.       foreach ($result as $v) { 
388.  
389.          $b = $v['total']; 
390.  
391.       } 
392.  
393.       if ($b) { 
394.  
395.         return true; 
396.  
397.       } else { 
398.  
399.         return false; 
400.  
401.       } 
402.  
403.     } catch (PDOException $e) { 
404.  
405.       exit($e->getMessage()); 
406.  
407.     } 
408.  
409.   } 
410.  
411.   /** 
412.  
413.    * 预处理删除（注：针对主键为 INT 类型，推荐使用） 
414.  
415.    * @param string $tName 表名 
416.  
417.    * @param string $primary 主键字段 
418.  
419.    * @param int or array or string $ids 如果是删除一条为 INT，多条为 array，删除一个范围为 string 
420.  
421.    * @return int 返回受影响的行数 
422.  
423.    */ 
424.  
425.   public function delByPK($tName, $primary, $ids, $mult=FALSE) { 
426.  
427.     try { 
428.  
429.       if (!is_string($tName) || !is_string($primary) 
430.  
431.       || (!is_int($ids) && !is_array($ids) && !is_string($ids)) 
432.  
433.       || !is_bool($mult)) exit($this->getError(__FUNCTION__, __LINE__)); 
434.  
435.       $tName = $this->formatTabName($tName); 
436.  
437.       $stmt = $this->_db->prepare("DELETE FROM {$tName} WHERE {$primary}=?"); 
438.  
439.       if (!$mult) { 
440.  
441.         $stmt->bindParam(1, $ids); 
442.  
443.         $row = $stmt->execute(); 
444.  
445.       } else { 
446.  
447.         if (is_array($ids)) { 
448.  
449.           $row = 0; 
450.  
451.           foreach ($ids as $v) { 
452.  
453.             $stmt->bindParam(1, $v); 
454.  
455.             if ($stmt->execute()) { 
456.  
457.               $row++; 
458.  
459.             } 
460.  
461.           } 
462.  
463.         } elseif (is_string($ids)) { 
464.  
465.           if (!strpos($ids, '-')) 
466.  
467.             exit($this->getError(__FUNCTION__, __LINE__)); 
468.  
469.           $split = explode('-', $ids); 
470.  
471.           if (count($split)!=2 || $split[0]>$split[1]) 
472.  
473.             exit($this->getError(__FUNCTION__, __LINE__)); 
474.  
475.           $i = null; 
476.  
477.           $count = $split[1]-$split[0]+1; 
478.  
479.           for ($i=0; $i<$count; $i++) { 
480.  
481.             $idArr[$i] = $split[0]++; 
482.  
483.           } 
484.  
485.           $idStr = ''; 
486.  
487.           foreach ($idArr as $id) { 
488.  
489.             $idStr .= $id . ','; 
490.  
491.           } 
492.  
493.           $idStr = rtrim($idStr, ','); 
494.  
495.           $this->_sql ="DELETE FROM {$tName} WHERE {$primary} in ({$idStr})"; 
496.  
497.           $row = $this->_db->exec($this->_sql); 
498.  
499.         } 
500.  
501.       } 
502.  
503.       return $row; 
504.  
505.     } catch (PDOException $e) { 
506.  
507.       exit($e->getMessage()); 
508.  
509.     } 
510.  
511.   } 
512.  
513.   /** 
514.  
515.    * 返回单个字段数据或单条记录 
516.  
517.    * @param string $tName 表名 
518.  
519.    * @param string $condition 条件 
520.  
521.    * @param string or array $fields 返回的字段，默认是* 
522.  
523.    * @return string || array 
524.  
525.    */ 
526.  
527.   public function getRow($tName, $condition='', $fields="*") { 
528.  
529.     try { 
530.  
531.       if (!is_string($tName) || !is_string($condition) 
532.  
533.       || !is_string($fields) || emptyempty($fields)) 
534.  
535.          exit($this->getError(__FUNCTION__, __LINE__)); 
536.  
537.       $tName = $this->formatTabName($tName); 
538.  
539.       $this->_sql = "SELECT {$fields} FROM {$tName} "; 
540.  
541.       $this->_sql .= ($condition=='' ? '' : "WHERE {$condition}") . " LIMIT 1"; 
542.  
543.       $sth = $this->_db->prepare($this->_sql); 
544.  
545.       $sth->execute(); 
546.  
547.       $result = $sth->fetch(PDO::FETCH_ASSOC); 
548.  
549.       if ($fields === '*') { 
550.  
551.         return $result; 
552.  
553.       } else { 
554.  
555.         return $result[$fields]; 
556.  
557.       } 
558.  
559.     } catch (PDOException $e) { 
560.  
561.       exit($e->getMessage()); 
562.  
563.     } 
564.  
565.   } 
566.  
567.   /** 
568.  
569.    * 返回多条数据 
570.  
571.    * @param string $tName 表名 
572.  
573.    * @param string $fields 返回字段，默认为* 
574.  
575.    * @param string $condition 条件 
576.  
577.    * @param string $order 排序 
578.  
579.    * @param string $limit 显示个数 
580.  
581.    * @return PDOStatement 
582.  
583.    */ 
584.  
585.   public function getAll($tName, $fields='*', $condition='', $order='', $limit='') { 
586.  
587.     try { 
588.  
589.       if (!is_string($tName) || !is_string($fields) 
590.  
591.       || !is_string($condition) || !is_string($order) 
592.  
593.       || !is_string($limit)) 
594.  
595.         exit($this->getError(__FUNCTION__, __LINE__)); 
596.  
597.       $tName = $this->formatTabName($tName); 
598.  
599.       $fields = ($fields=='*' || $fields=='') ? '*' : $fields; 
600.  
601.       $condition = $condition=='' ? '' : " WHERE ". $condition ; 
602.  
603.       $order = $order=='' ? '' : " ORDER BY ". $order; 
604.  
605.       $limit = $limit=='' ? '' : " LIMIT ". $limit; 
606.  
607.       $this->_sql = "SELECT {$fields} FROM {$tName} {$condition} {$order} {$limit}"; 
608.  
609.       $sth = $this->_db->prepare($this->_sql); 
610.  
611.       $sth->execute(); 
612.  
613.       $result = $sth->fetchAll(PDO::FETCH_ASSOC); 
614.  
615.       return $result; 
616.  
617.     } catch (PDOException $e) { 
618.  
619.       exit($e->getMessage()); 
620.  
621.     } 
622.  
623.   } 
624.  
625.   /** 
626.  
627.    * 格式化数组（表结构和值） 
628.  
629.    * @param array $field 
630.  
631.    * @param bool $isField 
632.  
633.    * @return string 
634.  
635.    */ 
636.  
637.   private function formatArr($field, $isField=TRUE) { 
638.  
639.     if (!is_array($field)) exit($this->getError(__FUNCTION__, __LINE__)); 
640.  
641.     $fields = ''; 
642.  
643.     if ($isField) { 
644.  
645.       foreach ($field as $v) { 
646.  
647.         $fields .= '`'.$v.'`,'; 
648.  
649.       } 
650.  
651.     } else { 
652.  
653.       foreach ($field as $v) { 
654.  
655.         $fields .= '\''.$v.'\''.','; 
656.  
657.       } 
658.  
659.     } 
660.  
661.     $fields = rtrim($fields, ','); 
662.  
663.     return $fields; 
664.  
665.   } 
666.  
667.   /** 
668.  
669.    * 格式化问号 
670.  
671.    * @param int $count 数量 
672.  
673.    * @return string 返回格式化后的字符串 
674.  
675.    */ 
676.  
677.   private function formatMark($count) { 
678.  
679.     $str = ''; 
680.  
681.     if (!is_int($count)) exit($this->getError(__FUNCTION__, __LINE__)); 
682.  
683.     if ($count==1) return '?'; 
684.  
685.     for ($i=0; $i<$count; $i++) { 
686.  
687.       $str .= '?,'; 
688.  
689.     } 
690.  
691.     return rtrim($str, ','); 
692.  
693.   } 
694.  
695.   /** 
696.  
697.    * 错误提示 
698.  
699.    * @param string $fun 
700.  
701.    * @return string 
702.  
703.    */ 
704.  
705.   private function getError($fun, $line) { 
706.  
707.     return __CLASS__ . '->' . $fun . '() line<font color="red">'. $line .'</font> ERROR!'; 
708.  
709.   } 
710.  
711.   /** 
712.  
713.    * 处理表名 
714.  
715.    * @param string $tName 
716.  
717.    * @return string 
718.  
719.    */ 
720.  
721.   private function formatTabName($tName) { 
722.  
723.     return '`' . trim($tName, '`') . '`'; 
724.  
725.   } 
726.  
727.   /** 
728.  
729.    * 析构方法 
730.  
731.    */ 
732.  
733.   public function __destruct() { 
734. //phpfensi.com 
735.     $this->_db = null; 
736.  
737.   } 
738.  
739. } 

Tags: PDO常用类库

分享到：