Home  >  Article  >  Backend Development  >  PDO database operation class

PDO database operation class

WBOY
WBOYOriginal
2016-07-25 08:44:29961browse
  1. class HRDB{
  2. protected $pdo;
  3. protected $res;
  4. protected $config;
  5. /*constructor*/
  6. function __construct($config){
  7. $this->Config = $config;
  8. $this->connect();
  9. }
  10. /*Database connection*/
  11. public function connect(){
  12. $this->pdo = new PDO($this->Config['dsn'], $this->Config['name'], $this->Config['password']);
  13. $this->pdo->query('set names utf8;');
  14. //Put the result Serialized into stdClass
  15. //$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
  16. //Write your own code to catch Exception
  17. $this->pdo->setAttribute(PDO: :ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  18. }
  19. /*Database close*/
  20. public function close(){
  21. $this->pdo = null;
  22. }
  23. public function query($sql){
  24. $ res = $this->pdo->query($sql);
  25. if($res){
  26. $this->res = $res;
  27. }
  28. }
  29. public function exec($sql){
  30. $ res = $this->pdo->exec($sql);
  31. if($res){
  32. $this->res = $res;
  33. }
  34. }
  35. public function fetchAll(){
  36. return $this ->res->fetchAll();
  37. }
  38. public function fetch(){
  39. return $this->res->fetch();
  40. }
  41. public function fetchColumn(){
  42. return $this-> ;res->fetchColumn();
  43. }
  44. public function lastInsertId(){
  45. return $this->res->lastInsertId();
  46. }
  47. /**
  48. * Parameter Description
  49. * int $debug Whether to enable debugging, if enabled, the sql statement will be output
  50. * 0 Do not enable
  51. * 1 Enable
  52. * 2 Enable and terminate the program
  53. * int $mode Return type
  54. * 0 Return multiple records
  55. * 1 Returns a single record
  56. * 2 Returns the number of rows
  57. * string/array $table database table, two value-passing modes
  58. * Normal mode:
  59. * 'tb_member, tb_money'
  60. * Array mode:
  61. * array('tb_member', 'tb_money')
  62. * string/array $fields Database fields to be queried, allowed to be empty, default is to find all, two value-passing modes
  63. * Normal mode:
  64. * 'username, password'
  65. * Array mode:
  66. * array('username', 'password')
  67. * string/array $sqlwhere query conditions, empty allowed, two value-passing modes
  68. * Normal mode:
  69. * 'and type = 1 and username like "%os%"'
  70. * Array mode:
  71. * array('type = 1', 'username like "%os%"')
  72. * string $orderby sorting, the default is id reverse order
  73. */
  74. public function select( $debug, $mode, $table, $fields="*", $sqlwhere="", $orderby="tbid desc"){
  75. //Parameter processing
  76. if(is_array($table)){
  77. $table = implode(', ', $table);
  78. }
  79. if(is_array($fields)){
  80. $fields = implode(', ', $fields);
  81. }
  82. if(is_array($sqlwhere)){
  83. $ sqlwhere = ' and '.implode(' and ', $sqlwhere);
  84. }
  85. //Database operation
  86. if($debug === 0){
  87. if($mode === 2){
  88. $this-> ;query("select count(tbid) from $table where 1=1 $sqlwhere");
  89. $return = $this->fetchColumn();
  90. }else if($mode === 1){
  91. $this ->query("select $fields from $table where 1=1 $sqlwhere order by $orderby");
  92. $return = $this->fetch();
  93. }else{
  94. $this->query( "select $fields from $table where 1=1 $sqlwhere order by $orderby");
  95. $return = $this->fetchAll();
  96. }
  97. return $return;
  98. }else{
  99. if($mode = == 2){
  100. echo "select count(tbid) from $table where 1=1 $sqlwhere";
  101. }else if($mode === 1){
  102. echo "select $fields from $table where 1=1 $sqlwhere order by $orderby";
  103. }
  104. else{
  105. echo "select $fields from $table where 1=1 $sqlwhere order by $orderby";
  106. }
  107. if($debug === 2){
  108. exit;
  109. }
  110. }
  111. }
  112. /**
  113. * Parameter Description
  114. * int $debug Whether to enable debugging, if enabled, the sql statement will be output
  115. * 0 Do not enable
  116. * 1 Enable
  117. * 2 Enable and terminate the program
  118. * int $mode Return type
  119. * 0 No return information
  120. * 1 Returns the number of execution entries
  121. * 2 Returns the id of the last inserted record
  122. * string/array $table database table, two value-passing modes
  123. * Normal mode:
  124. * 'tb_member, tb_money'
  125. * Array mode:
  126. * array( 'tb_member', 'tb_money')
  127. * string/array $set Fields and contents to be inserted, two value-passing modes
  128. * Normal mode:
  129. * 'username = "test", type = 1, dt = now() '
  130. * Array mode:
  131. * array('username = "test"', 'type = 1', 'dt = now()')
  132. */
  133. public function insert($debug, $mode, $table, $set){
  134. //参数处理
  135. if(is_array($table)){
  136. $table = implode(', ', $table);
  137. }
  138. if(is_array($set)){
  139. $set = implode(', ', $set);
  140. }
  141. //数据库操作
  142. if($debug === 0){
  143. if($mode === 2){
  144. $this->query("insert into $table set $set");
  145. $return = $this->lastInsertId();
  146. }else if($mode === 1){
  147. $this->exec("insert into $table set $set");
  148. $return = $this->res;
  149. }else{
  150. $this->query("insert into $table set $set");
  151. $return = NULL;
  152. }
  153. return $return;
  154. }else{
  155. echo "insert into $table set $set";
  156. if($debug === 2){
  157. exit;
  158. }
  159. }
  160. }
  161. /**
  162. * Parameter Description
  163. * int $debug Whether to enable debugging, if enabled, the sql statement will be output
  164. * 0 Do not enable
  165. * 1 Enable
  166. * 2 Enable and terminate the program
  167. * int $mode Return type
  168. * 0 No return information
  169. * 1 Returns the number of execution entries
  170. * string $table database table, two value-passing modes
  171. * Normal mode:
  172. * 'tb_member, tb_money'
  173. * Array mode:
  174. * array('tb_member', 'tb_money')
  175. * string/ array $set Fields and contents that need to be updated, two value-passing modes
  176. * Normal mode:
  177. * 'username = "test", type = 1, dt = now()'
  178. * Array mode:
  179. * array('username = "test"', 'type = 1', 'dt = now()')
  180. * string/array $sqlwhere Modify the conditions, allow empty, two value-passing modes
  181. * Normal mode:
  182. * 'and type = 1 and username like "%os%"'
  183. * Array mode:
  184. * array('type = 1', 'username like "%os%"')
  185. */
  186. public function update($debug, $mode, $table, $set, $sqlwhere=""){
  187. //参数处理
  188. if(is_array($table)){
  189. $table = implode(', ', $table);
  190. }
  191. if(is_array($set)){
  192. $set = implode(', ', $set);
  193. }
  194. if(is_array($sqlwhere)){
  195. $sqlwhere = ' and '.implode(' and ', $sqlwhere);
  196. }
  197. //数据库操作
  198. if($debug === 0){
  199. if($mode === 1){
  200. $this->exec("update $table set $set where 1=1 $sqlwhere");
  201. $return = $this->res;
  202. }else{
  203. $this->query("update $table set $set where 1=1 $sqlwhere");
  204. $return = NULL;
  205. }
  206. return $return;
  207. }else{
  208. echo "update $table set $set where 1=1 $sqlwhere";
  209. if($debug === 2){
  210. exit;
  211. }
  212. }
  213. }
  214. /**
  215. * Parameter Description
  216. * int $debug Whether to enable debugging, if enabled, the sql statement will be output
  217. * 0 Do not enable
  218. * 1 Enable
  219. * 2 Enable and terminate the program
  220. * int $mode Return type
  221. * 0 No return information
  222. * 1 Returns the number of execution entries
  223. * string $table database table
  224. * string/array $sqlwhere deletion condition, allowed to be empty, two value-passing modes
  225. * Normal mode:
  226. * 'and type = 1 and username like "%os%" '
  227. * Array mode:
  228. * array('type = 1', 'username like "%os%"')
  229. */
  230. public function delete($debug, $mode, $table, $sqlwhere=""){
  231. //参数处理
  232. if(is_array($sqlwhere)){
  233. $sqlwhere = ' and '.implode(' and ', $sqlwhere);
  234. }
  235. //数据库操作
  236. if($debug === 0){
  237. if($mode === 1){
  238. $this->exec("delete from $table where 1=1 $sqlwhere");
  239. $return = $this->res;
  240. }else{
  241. $this->query("delete from $table where 1=1 $sqlwhere");
  242. $return = NULL;
  243. }
  244. return $return;
  245. }else{
  246. echo "delete from $table where 1=1 $sqlwhere";
  247. if($debug === 2){
  248. exit;
  249. }
  250. }
  251. }
  252. }
复制代码

PDO


Statement:
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn