PHP5中PDO(PHP DATA OBJECT)模块基础详解

PHP5自从2004年发布以来PDO就有了，但是现在纵观周边开发的情况还是4世代的mysql或者mysqli占据大部分江山，就像ie6一样。也许改革需要时间的推动，在即将发行的PHP6中PDO会作为默认的数据库链接工具。这是一个趋势，不管时间需要多久，运用新的技术是技术人员一项基本要素。搜索网上的PHP的PDO不是太多，一般是一些尝试性质的简介，或者概述。总觉得少了点什么。我这里补充下自己的一些实例，让PDO的运用丰满一些。大部分参考官方文档例子。

第一部分：开启PDO支持 这个就不多说了，网上有很多这个文档。总的来说就是windows下开始 extension linux下重新开启支持pdo的编译

第二部分：实例介绍

一：创建链接，PDO作为一个PHP统一的数据库接口，包括了基本上市场上的数据库类型。因为PHP和Mysql一直相互扶持，这里就用Mysql做实例。

1. define('DB_NAME', 'wordpress'); 
2. define('DB_USER', 'root'); 
3. define('DB_PASSWORD', ''); 
4. define('DB_HOST', 'localhost'); 
5. define('DB_CHARSET', 'utf8'); 
6. try { 
7.     $DBH = new PDO('mysql:host=localhost;dbname=wordpress', DB_USER, DB_PASSWORD); 
8.     $DBH->exec('SET CHARACTER SET '.DB_CHARSET); 
9.     $DBH->exec('SET NAMES '.DB_CHARSET); 
10.     /* 
11.      * 如果想要在脚本结束的时候不释放链接那么在参数里面加上array(PDO::ATTR_PERSISTENT => true)不过一般情况下可以不用常链接 
12.     $dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass, array( 
13.         PDO::ATTR_PERSISTENT => true 
14.         )); 
15.      */ 
16. } catch (PDOException $e) { 
17.     print "Error!: " . $e->getMessage() . "<br/>"; 
18.     die(); 
19. } 

二：基本数据操作

1. /* 
2.  * 第二部分：数据库的基本操作 增删改查 这里先说基本的exec和query 函数 
3.  */ 
4.  
5. //增加数据 
6.  
7. $sql_insert = 'INSERT INTO wp_options(blog_id,option_name,option_value,autoload) VALUES (0,'.time().rand(1,100).','.time().rand(1,100).',\'no\')'; 
8. $back = $DBH->exec($sql_insert); //返回 bool 的true or fal 
9. $lastInsertId = $DBH->lastInsertId(); 
10. //更新数据 
11. $sql_update = 'UPDATE wp_options SET option_name = \''.time().rand(1,100).'\' WHERE option_id='.$lastInsertId;  
12. $lastUpdateId = $DBH->lastInsertId(); //返回的对应的操作的id 
13. //查询数据 
14. $sql_select = 'SELECT option_id FROM wp_options ORDER BY option_id DESC LIMIT 4 '; 
15. $back = $DBH->query($sql_select); //返回一个对象 这个对象可以用foreach 直接遍历循环 循环的为查询的结果集 
16. $back = $DBH->query($sql_select)->fetch(); //返回一条数据结果 这个对象可以用foreach 直接遍历循环 循环的为查询的结果集 
17. $back = $DBH->query($sql_select)->fetchAll(); //返回一个数组 这个对象可以用foreach 直接遍历循环 循环的为查询的结果集 
18. $back = $DBH->query($sql_select)->fetchColumn(0); //返回一个字段字符串，这个字符串是返回的记录的第一条记录的第一个字段 
19.  
20. //删除数据 
21. $sql_delete = 'DELETE FROM wp_options WHERE option_id='.$lastInsertId; 
22. $back = $DBH->exec($sql_delete); //返回 bool 的true or fal 
23. $lastInsertId = $DBH->lastInsertId(); 

第三部分：事务

1. /* 
2.  * 第三部分 PDO的事务机制 这里已经封装好了 在使用事务的时候最好使用 try 和catch 如果try 返回错误 那么就不会提交的哦 
3.  */ 
4. try{ 
5.     $DBH->beginTransaction();//开启一个事务 
6.     //Sql 执行的内容 ...................... 
7.     $DBH->exec($sql_insert); //执行一系列的操作 
8.     $DBH->exec($sql_update); 
9.     $DBH->exec($sql_delete); 
10.     //等等 
11.     $DBH->commit(); //如果正确执行完成 那么确认 commit 
12. } catch(Exception $e) { 
13.     $DBH->rollBack();//如果执行中有错误的情况下  回滚 
14. } 

第四部分：预处理Sql 和 存储过程

1. /* 
2.  * 第四部分 存储过程 和预处理Sql 
3.  */ 
4. //预处理Sql PDO 提供了预处理Sql 机制 这样可以重复使用Sql 语句 只要把其中的一些关键的变量每次重新赋值就可以了 这里的变量是引用传递的值  
5. $stmt = $DBH->prepare('INSERT INTO wp_options(blog_id,option_name,option_value,autoload) VALUES (0,:option_name,:option_value,\'no\')'); 
6. $option_name = $option_value = ''; 
7. $stmt->bindParam(':option_name', $option_name); // 
8. $stmt->bindParam(':option_value', $option_value); 
9.  
10. // insert one row 
11. $option_name = 'name'.time(); 
12. $option_value = 'value'.time(); 
13. $stmt->execute(); 
14.  
15. // insert another row with different values 
16. $option_name = 'name_'.time(); 
17. $option_value = 'value_'.time(); 
18. $stmt->execute(); 
19.  
20. $stmt = $DBH->prepare('INSERT INTO wp_options(blog_id,option_name,option_value,autoload) VALUES (0,?,?,\'no\')'); 
21. $option_name = $option_value = ''; 
22. $stmt->bindParam('1', $option_name); // 
23. $stmt->bindParam('2', $option_value); 
24.  
25. // insert one row 
26. $option_name = 'name'.time(); 
27. $option_value = 'value'.time(); 
28. $stmt->execute(); 
29.  
30. // insert another row with different values 
31. $option_name = 'name_'.time(); 
32. $option_value = 'value_'.time(); 
33. $stmt->execute(); 
34.  
35.  
36. $stmt = $DBH->prepare("SELECT * FROM wp_options where option_id = ?"); 
37. if ($stmt->execute(array(@$_GET['option_id']))) { 
38.   while (@$row = $stmt->fetch()) { 
39.     print_r($row); 
40.   } 
41. } 
42. //存储过程 关于存储过程的写法，我回头再另一篇文章中详细介绍下。 这里只是简单的提下 以便PDO这个功能的描述 
43. $sql_procedure = ' 
44.             CREATE PROCEDURE inout_test( 
45.                 IN in_option_id INT, 
46.                 OUT out_option_name VARCHAR(255), 
47.                 OUT out_option_value TEXT 
48.             ) 
49.             BEGIN 
50.                 SELECT option_name INTO out_option_name   FROM wp_options WHERE option_id = in_option_id; 
51.                 SELECT option_value INTO out_option_value FROM wp_options WHERE option_id = in_option_id; 
52.             END; 
53. '; 
54. try{ 
55.     $sql_drop_procedure = 'DROP PROCEDURE inout_test'; 
56.     $back = $DBH->exec($sql_procedure); 
57.     //这里发觉现在的这一部分总觉得不是太完善和容易上手，可能个人原因吧 这里还是用原始点的方法 以后如果有新的认知再补充 
58.     $sql_call_procedure = 'CALL inout_test(100,@out_option_name,@out_option_value)'; 
59.     $DBH->exec($sql_call_procedure); 
60.     $sql_select_procedure = 'SELECT @out_option_name,@out_option_value'; 
61.     $back = $DBH->query($sql_select_procedure)->fetch(); 
62.     $back = $DBH->exec($sql_drop_procedure); 
63. }catch(Exception $e){ 
64.     echo $e->getMessage(); 
65. } 

这些都是示例 数据库结构是基于wordpress的 wp_options 表来做的测试

表结构如下

1. CREATE TABLE IF NOT EXISTS `wp_options` ( 
2.   `option_id` bigint(20) unsigned NOT NULL AUTO_INCREMENT, 
3.   `blog_id` int(11) NOT NULL DEFAULT '0', 
4.   `option_name` varchar(64) NOT NULL DEFAULT '', 
5.   `option_value` longtext NOT NULL, 
6.   `autoload` varchar(20) NOT NULL DEFAULT 'yes', 
7.   PRIMARY KEY (`option_id`), 
8.   UNIQUE KEY `option_name` (`option_name`) 
9. ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=256 ; 

这些都是基本的入门的，但是可以满足目前对数据库的操作。剩下的一些PDO的部分看文档不解释，但是现在新手看文档的习惯。也许是造成这个现在还使用范围不大的原因吧。

最后整体来一份code

1. <?php 
2. /** 
3.  * 关于PHP5版本引入的PDO(PHP Data Objects)的详细实例使用 
4.  */ 
5.  
6. /* 
7.  *第一部分：数据库链接  
8.  */ 
9. define('DB_NAME', 'wordpress'); 
10. define('DB_USER', 'root'); 
11. define('DB_PASSWORD', ''); 
12. define('DB_HOST', 'localhost'); 
13. define('DB_CHARSET', 'utf8'); 
14. try { 
15.     $DBH = new PDO('mysql:host=localhost;dbname=wordpress', DB_USER, DB_PASSWORD); 
16.     $DBH->exec('SET CHARACTER SET '.DB_CHARSET); 
17.     $DBH->exec('SET NAMES '.DB_CHARSET); 
18.     /* 
19.      * 如果想要在脚本结束的时候不释放链接那么在参数里面加上array(PDO::ATTR_PERSISTENT => true)不过一般情况下可以不用常链接 
20.     $dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass, array( 
21.         PDO::ATTR_PERSISTENT => true 
22.         )); 
23.      */ 
24. } catch (PDOException $e) { 
25.     print "Error!: " . $e->getMessage() . "<br/>"; 
26.     die(); 
27. } 
28.  
29. /* 
30.  * 第二部分：数据库的基本操作 增删改查 这里先说基本的exec和query 函数 
31.  */ 
32.  
33. //增加数据 
34.  
35. $sql_insert = 'INSERT INTO wp_options(blog_id,option_name,option_value,autoload) VALUES (0,'.time().rand(1,100).','.time().rand(1,100).',\'no\')'; 
36. $back = $DBH->exec($sql_insert); //返回 bool 的true or fal 
37. $lastInsertId = $DBH->lastInsertId(); 
38. //更新数据 
39. $sql_update = 'UPDATE wp_options SET option_name = \''.time().rand(1,100).'\' WHERE option_id='.$lastInsertId;  
40. $lastUpdateId = $DBH->lastInsertId(); //返回的对应的操作的id 
41. //查询数据 
42. $sql_select = 'SELECT option_id FROM wp_options ORDER BY option_id DESC LIMIT 4 '; 
43. $back = $DBH->query($sql_select); //返回一个对象 这个对象可以用foreach 直接遍历循环 循环的为查询的结果集 
44. $back = $DBH->query($sql_select)->fetch(); //返回一条数据结果 这个对象可以用foreach 直接遍历循环 循环的为查询的结果集 
45. $back = $DBH->query($sql_select)->fetchAll(); //返回一个数组 这个对象可以用foreach 直接遍历循环 循环的为查询的结果集 
46. $back = $DBH->query($sql_select)->fetchColumn(0); //返回一个字段字符串，这个字符串是返回的记录的第一条记录的第一个字段 
47.  
48. //删除数据 
49. $sql_delete = 'DELETE FROM wp_options WHERE option_id='.$lastInsertId; 
50. $back = $DBH->exec($sql_delete); //返回 bool 的true or fal 
51. $lastInsertId = $DBH->lastInsertId(); 
52.  
53. /* 
54.  * 第三部分 PDO的事务机制 这里已经封装好了 在使用事务的时候最好使用 try 和catch 如果try 返回错误 那么就不会提交的哦 
55.  */ 
56. try{ 
57.     $DBH->beginTransaction();//开启一个事务 
58.     //Sql 执行的内容 ...................... 
59.     $DBH->exec($sql_insert); //执行一系列的操作 
60.     $DBH->exec($sql_update); 
61.     $DBH->exec($sql_delete); 
62.     //等等 
63.     $DBH->commit(); //如果正确执行完成 那么确认 commit 
64. } catch(Exception $e) { 
65.     $DBH->rollBack();//如果执行中有错误的情况下  回滚 
66. } 
67. /* 
68.  * 第四部分 存储过程 和预处理Sql 
69.  */ 
70. //预处理Sql PDO 提供了预处理Sql 机制 这样可以重复使用Sql 语句 只要把其中的一些关键的变量每次重新赋值就可以了 这里的变量是引用传递的值  
71. $stmt = $DBH->prepare('INSERT INTO wp_options(blog_id,option_name,option_value,autoload) VALUES (0,:option_name,:option_value,\'no\')'); 
72. $option_name = $option_value = ''; 
73. $stmt->bindParam(':option_name', $option_name); // 
74. $stmt->bindParam(':option_value', $option_value); 
75.  
76. // insert one row 
77. $option_name = 'name'.time(); 
78. $option_value = 'value'.time(); 
79. $stmt->execute(); 
80.  
81. // insert another row with different values 
82. $option_name = 'name_'.time(); 
83. $option_value = 'value_'.time(); 
84. $stmt->execute(); 
85.  
86. $stmt = $DBH->prepare('INSERT INTO wp_options(blog_id,option_name,option_value,autoload) VALUES (0,?,?,\'no\')'); 
87. $option_name = $option_value = ''; 
88. $stmt->bindParam('1', $option_name); // 
89. $stmt->bindParam('2', $option_value); 
90.  
91. // insert one row 
92. $option_name = 'name'.time(); 
93. $option_value = 'value'.time(); 
94. $stmt->execute(); 
95.  
96. // insert another row with different values 
97. $option_name = 'name_'.time(); 
98. $option_value = 'value_'.time(); 
99. $stmt->execute(); 
100.  
101.  
102. $stmt = $DBH->prepare("SELECT * FROM wp_options where option_id = ?"); 
103. if ($stmt->execute(array(@$_GET['option_id']))) { 
104.   while (@$row = $stmt->fetch()) { 
105.     print_r($row); 
106.   } 
107. } 
108. //存储过程 关于存储过程的写法，我回头再另一篇文章中详细介绍下。 这里只是简单的提下 以便PDO这个功能的描述 
109. $sql_procedure = ' 
110.             CREATE PROCEDURE inout_test( 
111.                 IN in_option_id INT, 
112.                 OUT out_option_name VARCHAR(255), 
113.                 OUT out_option_value TEXT 
114.             ) 
115.             BEGIN 
116.                 SELECT option_name INTO out_option_name   FROM wp_options WHERE option_id = in_option_id; 
117.                 SELECT option_value INTO out_option_value FROM wp_options WHERE option_id = in_option_id; 
118.             END; 
119. '; 
120. try{ 
121.     $sql_drop_procedure = 'DROP PROCEDURE inout_test'; 
122.     $back = $DBH->exec($sql_procedure); 
123.     //这里发觉现在的这一部分总觉得不是太完善和容易上手，可能个人原因吧 这里还是用原始点的方法 以后如果有新的认知再补充 
124.     $sql_call_procedure = 'CALL inout_test(100,@out_option_name,@out_option_value)'; 
125.     $DBH->exec($sql_call_procedure); 
126.     $sql_select_procedure = 'SELECT @out_option_name,@out_option_value'; 
127.     $back = $DBH->query($sql_select_procedure)->fetch(); 
128.     $back = $DBH->exec($sql_drop_procedure); 
129. }catch(Exception $e){ 
130.     echo $e->getMessage(); 
131. } 

如果有问题的可以留言或者自己看官方手册

http://cn.php.net/manual/zh/book.pdo.php