php中PDO方式实现数据库的增删改查

PDO是mysql数据库操作的一个公用类了，我们不需要进行自定类就可以直接使用pdo来操作数据库了，但是在php默认配置中pdo是未开启所以我们必须先在php.ini中开启它才可以使用。

需要开启php的pdo支持，php5.1以上版本支持

实现数据库连接单例化，有三要素 静态变量、静态实例化方法、私有构造函数 DPDO.php

1. class DPDO{ 
2. private $DSN; 
3. private $DBUser; 
4. private $DBPwd; 
5. private $longLink; 
6. private $pdo; 
7. //私有构造函数 防止被直接实例化 
8. private function __construct($dsn, $DBUser, $DBPwd, $longLink = false) { 
9. $this->DSN = $dsn; 
10. $this->DBUser = $DBUser; 
11. $this->DBPwd = $DBPwd; 
12. $this->longLink = $longLink; 
13. $this->connect(); 
14. } 
15. //私有 空克隆函数 防止被克隆 
16. private function __clone(){} 
17. //静态 实例化函数 返回一个pdo对象 
18. static public function instance($dsn, $DBUser, $DBPwd, $longLink = false){ 
19. static $singleton = array();//静态函数 用于存储实例化对象 
20. $singIndex = md5($dsn . $DBUser . $DBPwd . $longLink); 
21. if (emptyempty($singleton[$singIndex])) { 
22. $singleton[$singIndex] = new self($dsn, $DBUser, $DBPwd, $longLink = false); 
23. } 
24. return $singleton[$singIndex]->pdo; 
25. } 
26.  
27. private function connect(){ 
28. try{ 
29. if($this->longLink){ 
30. $this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd, array(PDO::ATTR_PERSISTENT => true)); 
31. }else{ 
32. $this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd); 
33. } 
34. $this->pdo->query('SET NAMES UTF-8'); 
35. } catch(PDOException $e) { 
36. die('Error:' . $e->getMessage() . '<br/>'); 
37. } 
38. } 
39. } 

用于处理字段映射，使用pdo的字段映射，可以有效避免sql注入

1. //字段关联数组处理， 主要用于写入和更新数据、同and 或 or 的查询条件，产生sql语句和映射字段的数组 
2. public function FDFields($data, $link = ',', $judge = array(), $aliasTable = ''){ 
3. $sql = ''; 
4. $mapData = array(); 
5. foreach($data as $key => $value) { 
6. $mapIndex = ':' . ($link != ',' ? 'c' : '') . $aliasTable . $key; 
7. $sql .= ' ' . ($aliasTable ? $aliasTable . '.' : '') . '`' . $key . '` ' . ($judge[$key] ? $judge[$key] : '=') . ' ' . $mapIndex . ' ' . $link; 
8. $mapData[$mapIndex] = $value; 
9. } 
10. $sql = trim($sql, $link); 
11. return array($sql, $mapData); 
12. } 
13. //用于处理单个字段处理 
14. public function FDField($field, $value, $judge = '=', $preMap = 'cn', $aliasTable = '') { 
15. $mapIndex = ':' . $preMap . $aliasTable . $field; 
16. $sql = ' ' . ($aliasTable ? $aliasTable . '.' : '') . '`' . $field . '`' . $judge . $mapIndex; 
17. $mapData[$mapIndex] = $value; 
18. return array($sql, $mapData); 
19. } 
20. //使用刚方法可以便捷产生查询条件及对应数据数组 
21. public function FDCondition($condition, $mapData) { 
22. if(is_string($condition)) { 
23. $where = $condition; 
24. } else if (is_array($condition)) { 
25. if($condition['str']) { 
26. if (is_string($condition['str'])) { 
27. $where = $condition['str']; 
28. } else { 
29. return false; 
30. } 
31. } 
32. if(is_array($condition['data'])) { 
33. $link = $condition['link'] ? $condition['link'] : 'and'; 
34. list($conSql, $mapConData) = $this->FDFields($condition['data'], $link, $condition['judge']); 
35. if ($conSql) { 
36. $where .= ($where ? ' ' . $link : '') . $conSql; 
37. $mapData = array_merge($mapData, $mapConData); 
38. } 
39. } 
40. } 
41. return array($where, $mapData); 
42. } 

增删改查的具体实现DB.php

1. public function fetch($sql, $searchData = array(), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) { 
2. if ($sql) { 
3. $sql .= ' limit 1'; 
4. $pdoStatement = $this->pdo->prepare($sql, $preType); 
5. $pdoStatement->execute($searchData); 
6. return $data = $pdoStatement->fetch($dataMode); 
7. } else { 
8. return false; 
9. } 
10. } 
11.  
12. public function fetchAll($sql, $searchData = array(), $limit = array(0, 10), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) { 
13. if ($sql) { 
14. $sql .= ' limit ' . (int) $limit[0] . ',' . (intval($limit[1]) > 0 ? intval($limit[1]) : 10); 
15. $pdoStatement = $this->pdo->prepare($sql, $preType); 
16. $pdoStatement->execute($searchData); 
17. return $data = $pdoStatement->fetchAll($dataMode); 
18. } else { 
19. return false; 
20. } 
21. } 
22.  
23. public function insert($tableName, $data, $returnInsertId = false, $replace = false) { 
24. if(!emptyempty($tableName) && count($data) > 0){ 
25. $sql = $replace ? 'REPLACE INTO ' : 'INSERT INTO '; 
26. list($setSql, $mapData) = $this->FDFields($data); 
27. $sql .= $tableName . ' set ' . $setSql; 
28. $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)); 
29. $execRet = $pdoStatement->execute($mapData); 
30. return $execRet ? ($returnInsertId ? $this->pdo->lastInsertId() : $execRet) : false; 
31. } else { 
32. return false; 
33. } 
34. } 
35.  
36. public function update($tableName, $data, $condition, $mapData = array(), $returnRowCount = true) { 
37. if(!emptyempty($tableName) && count($data) > 0) { 
38. $sql = 'UPDATE ' . $tableName . ' SET '; 
39. list($setSql, $mapSetData) = $this->FDFields($data); 
40. $sql .= $setSql; 
41. $mapData = array_merge($mapData, $mapSetData); 
42. list($where, $mapData) = $this->FDCondition($condition, $mapData); 
43. $sql .= $where ? ' WHERE ' . $where : ''; 
44. $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)); 
45. $execRet = $pdoStatement->execute($mapData); 
46. return $execRet ? ($returnRowCount ? $pdoStatement->rowCount() : $execRet) : false; 
47. } else { 
48. return false; 
49. } 
50. } 
51.  
52. public function delete($tableName, $condition, $mapData = array()) { 
53. if(!emptyempty($tableName) && $condition){ 
54. $sql = 'DELETE FROM ' . $tableName; 
55. list($where, $mapData) = $this->FDCondition($condition, $mapData); 
56. $sql .= $where ? ' WHERE ' . $where : ''; 
57. $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)); 
58. $execRet = $pdoStatement->execute($mapData); 
59. return $execRet; 
60. } 
61. } 

测试文件test.php

1. header("Content-type: text/html; charset=utf-8"); 
2. define('APP_DIR', dirname(__FILE__)); 
3.  
4. if (function_exists('spl_autoload_register')) { 
5. spl_autoload_register('autoClass'); 
6. } else { 
7. function __auto_load($className){ 
8. autoClass($className); 
9. } 
10. } 
11.  
12. function autoClass($className){ 
13. try{ 
14. require_once APP_DIR.'/class/'.$className.'.php'; 
15. } catch (Exception $e) { 
16. die('Error:' . $e->getMessage() . '<br />'); 
17. } 
18. } 
19. $DB = new DB(); 
20. //插入 
21. $inData['a'] = rand(1, 100); 
22. $inData['b'] = rand(1, 1000); 
23. $inData['c'] = rand(1,200) . '.' . rand(1,100); 
24. $ret = $DB->insert('a', $inData); 
25. echo '插入' . ($ret ? '成功' : '失败') . '<br/>'; 
26. //更新 
27. $upConData['a'] = 100; 
28. $upConJudge['a'] = '<'; 
29. $upConData['b'] = 30; 
30. $upConJudge['b'] = '>'; 
31. list($upConStr, $mapUpConData) = $DB->FDField('b', 200, '<', 'gt'); 
32. $condition = array( 
33. 'str' => $upConStr, 
34. 'data' => $upConData, 
35. 'judge' => $upConJudge, 
36. 'link' => 'and' 
37. ); 
38. $upData['a'] = rand(1, 10); 
39. $upData['b'] = 1; 
40. $upData['c'] = 1.00; 
41. $changeRows = $DB->update('a', $upData, $condition, $mapUpConData); 
42. echo '更新行数:' . (int) $changeRows . '<br/>'; 
43. //删除 
44. $delVal = rand(1, 10); 
45. list($delCon, $mapDelCon) = $DB->FDField('a', $delVal); 
46. $delRet = $DB->delete('a', $delCon, $mapDelCon); 
47. echo '删除a=' . $delVal . ($delRet ? '成功' : '失败') . '<br/>'; 
48.  
49. //查询 
50. $data['a'] = '10'; 
51. $judge['a'] = '>'; 
52. $data['b'] = '400'; 
53. $judge['b'] = '<'; 
54. list($conSql, $mapConData) = $DB->FDFields($data, 'and', $judge); 
55. $mData = $DB->fetch('select * from a where ' . $conSql . ' order by `a` desc', $mapConData); 
56.  
57. var_dump($mData); 

以上所述就是本文的全部内容了，希望大家能够喜欢。