PHP的PDO数据库操作类

一个简单的PDO类封装。。仅供学习交流

PdoDb 数据库类

1. /**
2. * @throws Error
3. * PDO数据库
4. */
6. class PdoDb extends DatabaseAbstract
7. {
8. /**
9. * PDO实例
10. * @var PDO
11. */
12. protected $DB;
13. /**
14. * PDO准备语句
15. * @var PDOStatement
16. */
17. protected $Stmt;
18. /**
19. * 最后的SQL语句
20. * @var string
21. */
22. protected $Sql;
23. /**
24. * 配置信息 $config=array('dsn'=>xxx,'name'=>xxx,'password'=>xxx,'option'=>xxx)
25. * @var array
26. */
27. protected $Config;
29. /**
30. * 构造函数
31. * @param array $config
32. */
33. public function __construct($config)
34. {
35. $this->Config = $config;
36. }
38. /**
39. * 连接数据库
40. * @return void
41. */
42. public function connect()
43. {
44. $this->DB = new PDO($this->Config['dsn'], $this->Config['name'], $this->Config['password'], $this->Config['option']);
45. //默认把结果序列化成stdClass
46. $this->DB->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
47. //自己写代码捕获Exception
48. $this->DB->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
49. }
51. /**
52. * 断开连接
53. * @return void
54. */
55. public function disConnect()
56. {
57. $this->DB = null;
58. $this->Stmt = null;
59. }
61. /**
62. * 执行sql，返回新加入的id
63. * @param string $statement
64. * @return string
65. */
66. public function exec($statement)
67. {
68. if ($this->DB->exec($statement)) {
69. $this->Sql = $statement;
70. return $this->lastId();
71. }
72. $this->errorMessage();
73. }
75. /**
76. * 查询sql
77. * @param string $statement
78. * @return PdoDb
79. */
80. public function query($statement)
81. {
82. $res = $this->DB->query($statement);
83. if ($res) {
84. $this->Stmt = $res;
85. $this->Sql = $statement;
86. return $this;
87. }
88. $this->errorMessage();
89. }
91. /**
92. * 序列化一次数据
93. * @return mixed
94. */
95. public function fetchOne()
96. {
97. return $this->Stmt->fetch();
98. }
100. /**
101. * 序列化所有数据
102. * @return array
103. */
104. public function fetchAll()
105. {
106. return $this->Stmt->fetchAll();
107. }
109. /**
110. * 最后添加的id
111. * @return string
112. */
113. public function lastId()
114. {
115. return $this->DB->lastInsertId();
116. }
118. /**
119. * 影响的行数
120. * @return int
121. */
122. public function affectRows()
123. {
124. return $this->Stmt->rowCount();
125. }
127. /**
128. * 预备语句
129. * @param string $statement
130. * @return PdoDb
131. */
132. public function prepare($statement)
133. {
134. $res = $this->DB->prepare($statement);
135. if ($res) {
136. $this->Stmt = $res;
137. $this->Sql = $statement;
138. return $this;
139. }
140. $this->errorMessage();
141. }
143. /**
144. * 绑定数据
145. * @param array $array
146. * @return PdoDb
147. */
148. public function bindArray($array)
149. {
150. foreach ($array as $k => $v) {
151. if (is_array($v)) {
152. //array的有效结构 array('value'=>xxx,'type'=>PDO::PARAM_XXX)
153. $this->Stmt->bindValue($k + 1, $v['value'], $v['type']);
154. } else {
155. $this->Stmt->bindValue($k + 1, $v, PDO::PARAM_STR);
156. }
157. }
158. return $this;
159. }
161. /**
162. * 执行预备语句
163. * @return bool
164. */
165. public function execute()
166. {
167. if ($this->Stmt->execute()) {
168. return true;
169. }
170. $this->errorMessage();
171. }
173. /**
174. * 开启事务
175. * @return bool
176. */
177. public function beginTransaction()
178. {
179. return $this->DB->beginTransaction();
180. }
182. /**
183. * 执行事务
184. * @return bool
185. */
186. public function commitTransaction()
187. {
188. return $this->DB->commit();
189. }
191. /**
192. * 回滚事务
193. * @return bool
194. */
195. public function rollbackTransaction()
196. {
197. return $this->DB->rollBack();
198. }
200. /**
201. * 抛出错误
202. * @throws Error
203. * @return void
204. */
205. public function errorMessage()
206. {
207. $msg = $this->DB->errorInfo();
208. throw new Error('数据库错误：' . $msg[2]);
209. }
211. //---------------------
212. /**
213. * 单例实例
214. * @var PdoDb
215. */
216. protected static $_instance;
218. /**
219. * 默认数据库
220. * @static
221. * @param array $config
222. * @return PdoDb
223. */
224. public static function instance($config)
225. {
226. if (!self::$_instance instanceof PdoDb) {
227. self::$_instance = new PdoDb($config);
228. self::$_instance->connect();
229. }
230. return self::$_instance;
231. }
233. //----------------------
235. /**
236. * 获取PDO支持的数据库
237. * @static
238. * @return array
239. */
240. public static function getSupportDriver(){
241. return PDO::getAvailableDrivers();
242. }
243. /**
244. * 获取数据库的版本信息
245. * @return array
246. */
247. public function getDriverVersion(){
248. $name = $this->DB->getAttribute(PDO::ATTR_DRIVER_NAME);
249. return array($name=>$this->DB->getAttribute(PDO::ATTR_CLIENT_VERSION));
250. }
252. }

使用的时候

1. PdoDb::instance($config);