首页 / PHP / phppdo封装类代码(支持事务)

phppdo封装类代码(支持事务)

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了phppdo封装类代码(支持事务)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3539字，纯文字阅读大概需要6分钟。

内容图文

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

内容总结

以上是互联网集市为您收集整理的phppdo封装类代码(支持事务)全部内容，希望文章能够帮你解决phppdo封装类代码(支持事务)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/164056.html

来源：【匿名】