简体中文（ZH-CN）English（EN）繁体中文（ZH-TW）日本語（JA）한국어（KO）Melayu（MS）Français（FR）Deutsch（DE）
집
기사
Q&A
강의
주제
다운로드
게임
사전
최근 업데이트

집  >  기사  >  백엔드 개발  >  PHP PDO操作MYSQL封装类

PHP PDO操作MYSQL封装类

WBOY
WBOY원래의
2016-07-25 08:42:281028검색
  1. /**
  2. * auther soulence
  3. * 调用数据类文件
  4. * modify 2015/06/12
  5. */
  6. class DBConnect
  7. {
  8. private $dbname = null;
  9. private $pdo = null;
  10. private $persistent = false;
  11. private $statement = null;
  12. private $lastInsID = null;
  13. private static $_instance = [];
  15. private function __construct($dbname,$attr)
  16. {
  17. $this->dbname = $dbname;
  18. $this->persistent = $attr;
  19. }
  21. public static function db($flag='r',$persistent=false)
  22. {
  23. if(!isset($flag)){
  24. $flag = 'r';
  25. }
  27. if (!class_exists('PDO'))
  28. {
  29. throw new Exception('not found PDO');
  30. return false;
  31. }
  32. $mysql_server = Yaf_Registry::get('mysql');
  33. if(!isset($mysql_server[$flag])){
  34. return false;
  35. }
  37. $options_arr = array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES '.$mysql_server[$flag]['charset'],PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC);
  38. if($persistent === true){
  39. $options_arr[PDO::ATTR_PERSISTENT] = true;
  40. }
  42. try {
  43. $pdo = new PDO($mysql_server[$flag]['connectionString'],$mysql_server[$flag]['username'],$mysql_server[$flag]['password'],$options_arr);
  44. } catch (PDOException $e) {
  45. throw new Exception($e->getMessage());
  46. //exit('连接失败:'.$e->getMessage());
  47. return false;
  48. }
  50. if(!$pdo) {
  51. throw new Exception('PDO CONNECT ERROR');
  52. return false;
  53. }
  55. return $pdo;
  56. }
  58. /**
  59. * 得到操作数据库对象
  60. * @param string $dbname 对应的数据库是谁
  61. * @param bool $attr 是否长连接
  62. * return false说明给定的数据库不存在
  63. */
  64. public static function getInstance($dbname = 'r',$attr = false)
  65. {
  66. $mysql_server = Yaf_Registry::get('mysql');
  67. if(!isset($mysql_server[$dbname])){
  68. return false;
  69. }
  70. $key = md5(md5($dbname.$attr,true));
  71. if (!isset(self::$_instance[$key]) || !is_object(self::$_instance[$key]))
  72. self::$_instance[$key] = new self($dbname,$attr);
  73. return self::$_instance[$key];
  74. }
  76. private function getConnect(){
  77. $this->pdo = self::db($this->dbname,$this->persistent);
  78. }
  80. /**
  81. * 查询操作
  82. * @param string $sql 执行查询的sql语句
  83. * @param array $data 查询的条件 格式为[':id'=>$id,':name'=>$name](推荐)或者为[1=>$id,2=>$name]
  84. * @param bool $one 是否返回一条内容 默认为否
  85. */
  86. public function query($sql, $data = [], $one = false)
  87. {
  88. if (!is_array($data) || empty($sql) || !is_string($sql))
  89. return false;
  91. $this->free();
  93. return $this->queryCommon($data,$sql,$one);
  94. }
  96. /**
  97. * 内部查询的共用方法
  98. */
  99. private function queryCommon($data,$sql,$one)
  100. {
  101. $this->pdoExec($data,$sql);
  103. if ($one){
  104. return $this->statement->fetch(PDO::FETCH_ASSOC);
  105. }else{
  106. return $this->statement->fetchAll(PDO::FETCH_ASSOC);
  107. }
  108. }
  110. /**
  111. * 多条SQL语句的查询操作
  112. * @param array $arr_sql 执行查询的sql语句数组 格式为[$sql1,$sql2]
  113. * @param array $arr_data 查询与$arr_sql对应的条件 格式为[[':id'=>$id,':name'=>$name],[':id'=>$id,':name'=>$name]](推荐)或者为[[1=>$id,2=>$name],[1=>$id,2=>$name]]
  114. * @param bool $one 是否返回一条内容 默认为否 这里如果设置为true那么每一条sql都只返回一条数据
  115. */
  116. public function queryes($arr_sql, $arr_data = [], $one = false)
  117. {
  118. if(!is_array($arr_sql) || empty($arr_sql) || !is_array($arr_data))
  119. return false;
  121. $this->free();
  123. $res = [];$i = 0;
  124. foreach ($arr_sql as $val) {
  125. if(!isset($arr_data[$i]))
  126. $arr_data[$i] = [];
  127. elseif(!is_array($arr_data[$i]))
  128. throw new Exception('Error where queryes sql:'.$val.' where:'.$arr_data[$i]);
  130. $res[] = $this->queryCommon($arr_data[$i],$val,$one);
  131. $i++;
  132. }
  133. return $res;
  134. }
  136. /**
  137. * 分页封装
  138. *
  139. * @param string $sql
  140. * @param int $page 表示从第几页开始取
  141. * @param int $pageSize 表示每页多少条
  142. * @param array $data 查询的条件
  143. */
  144. public function limitQuery($sql, $page=0, $pageSize=20, $data = [])
  145. {
  146. $page = intval($page);
  147. if ($page return [];
  148. }
  149. $pageSize = intval($pageSize);
  150. if ($pageSize > 0) { // pageSize 为0时表示取所有数据
  151. $sql .= ' LIMIT ' . $pageSize;
  152. if ($page > 0) {
  153. $start_limit = ($page - 1) * $pageSize;
  154. $sql .= ' OFFSET ' . $start_limit;
  155. }
  156. }
  157. return $this->query($sql, $data);
  158. }
  160. /**
  161. * 这个是用来进行添加 删除 修改操作 使用事务操作
  162. * @param string $sql 执行查询的sql语句
  163. * @param array $data 查询的条件 格式为[':id'=>$id,':name'=>$name](推荐)或者为[1=>$id,2=>$name]
  164. * @param bool $Transaction 是否事务操作 默认为否
  165. */
  166. public function executeDDL($sql, $data = [],$Transaction = false){
  167. if (!is_array($data) || !is_string($sql))
  168. return false;
  170. $this->free();
  172. if($Transaction)
  173. $this->pdo->beginTransaction();//开启事务
  174. try{
  175. $this->execRes($data,$sql);
  176. if($Transaction)
  177. $this->pdo->commit();//事务提交
  178. return $this->lastInsID;
  179. } catch (Exception $e) {
  180. if($Transaction)
  181. $this->pdo->rollBack();//事务回滚
  182. throw new Exception('Error DDLExecute '.$e->getMessage());
  183. return false;
  184. }
  185. }
  187. /**
  188. * 这个是用来进行添加 删除 修改操作 使用事务操作
  189. * 它是执行多条的
  190. * @param array $arr_sql 需要执行操作的SQL语句数组
  191. * @param array $arr_data 与数组对应SQL语句的条件
  192. * @param bool $Transaction 是否事务操作 默认为否
  193. */
  194. public function executeDDLes($arr_sql, $arr_data = [],$Transaction = false){
  196. if(!is_array($arr_sql) || empty($arr_sql) || !is_array($arr_data))
  197. return false;
  199. $res = [];
  201. $this->free();
  203. if($Transaction)
  204. $this->pdo->beginTransaction();//开启事务
  205. try{
  206. $i = 0;
  207. foreach($arr_sql as $val){
  208. if(!isset($arr_data[$i]))
  209. $arr_data[$i] = [];
  210. elseif(!is_array($arr_data[$i])){
  211. if($Transaction)
  212. $this->pdo->rollBack();//事务回滚
  213. throw new Exception('Error where DDLExecutees sql:'.$val.' where:'.$arr_data[$i]);
  214. }
  216. $this->execRes($arr_data[$i],$val);
  217. $res[] = $this->lastInsID;
  218. $i++;
  219. }
  221. if($Transaction)
  222. $this->pdo->commit();//事务提交
  224. return $res;
  225. } catch (Exception $e) {
  226. if($Transaction)
  227. $this->pdo->rollBack();//事务回滚
  228. throw new Exception('Error DDLExecutees array_sql:'.json_encode($arr_sql).' '.$e->getMessage());
  229. return false;
  230. }
  231. return $res;
  232. }
  234. /**
  235. * 此方法是用来计算查询返回的条数 注意 它只支持SELECT COUNT(*) FROM TABLE...或者SELECT COUNT(0) FROM TABLE...方式
  236. * @param string $sql 查询的sql语句
  237. * @param array $data SQL语句的条件
  238. */
  239. public function countRows($sql,$data = []){
  240. if (!is_array($data) || empty($sql) || !is_string($sql))
  241. return false;
  242. $this->free();
  244. $res = $this->pdoExec($data,$sql);
  246. if($res == false)
  247. return false;
  249. return $this->statement->fetchColumn();
  250. }
  252. /**
  253. * 此方法是用来计算查询返回的条数 它是执行多条SQL
  254. * @param string $sql 查询的sql语句
  255. * @param array $data SQL语句的条件
  256. */
  257. public function countRowses($arr_sql,$arr_data = []){
  259. if(!is_array($arr_sql) || empty($arr_sql) || !is_array($arr_data))
  260. return false;
  262. $res = [];
  264. $this->free();
  265. $i = 0;
  266. foreach ($arr_sql as $val) {
  267. if(!isset($arr_data[$i]))
  268. $arr_data[$i] = [];
  269. elseif(!is_array($arr_data[$i]))
  270. throw new Exception('Error where CountRowses sql:'.$val.' where:'.$arr_data[$i]);
  272. $res1 = $this->pdoExec($arr_data[$i],$val);
  274. if($res1 == false)
  275. $res[] = false;
  276. else
  277. $res[] = $this->statement->fetchColumn();
  278. }
  280. return $res;
  281. }
  283. /**
  284. * 这里再提供一个方法 由于项目中会有很多需要提供开启事务 然后再进行操作 最后提交
  285. * @param bool $Transaction 是否事务操作 默认为否
  286. */
  287. public function getDB($Transaction=false)
  288. {
  289. $this->Transaction = $Transaction;
  290. $this->getConnect();
  291. if($Transaction === true)
  292. $this->pdo->beginTransaction();//开启事务
  293. return $this;
  294. }
  296. /**
  297. * 此方法可以执行多次 它是执行DDL语句的
  298. * 注意 它是需要配合getDB和sQCommit一起使用 不能单独使用哦
  299. * 如果没有开启事务 sQCommit方法可以不调用
  300. * @param string $sql 查询的sql语句
  301. * @param array $data SQL语句的条件
  302. */
  303. public function execSq($sql,$data = [])
  304. {
  305. if($this->checkParams($sql,$data) === false)
  306. return false;
  308. try{
  309. $this->execRes($data,$sql);
  310. return $this->lastInsID;
  311. } catch (Exception $e) {
  312. if(isset($this->Transaction) && $this->Transaction === true)
  313. $this->pdo->rollBack();//事务回滚
  314. throw new Exception('Error execSq'.$e->getMessage());
  315. return false;
  316. } finally {
  317. if (!empty($this->statement))
  318. {
  319. $this->statement->closeCursor();
  320. unset($this->statement);
  321. }
  322. }
  323. }
  325. /**
  326. * 执行查询的方法 它需要传一个连接数据库对象
  327. * @param string $sql 执行查询的sql语句
  328. * @param array $data 查询的条件 格式为[':id'=>$id,':name'=>$name](推荐)或者为[1=>$id,2=>$name]
  329. * @param bool $one 是否返回一条内容 默认为否
  330. */
  331. public function querySq($sql,$data = [],$one = false)
  332. {
  333. if($this->checkParams($sql,$data) === false)
  334. return false;
  336. return $this->pdoExecSq($sql,$data,[1,$one]);
  337. }
  339. /**
  340. * 分页封装
  341. *
  342. * @param string $sql
  343. * @param int $page 表示从第几页开始取
  344. * @param int $pageSize 表示每页多少条
  345. * @param array $data 查询的条件
  346. */
  347. public function limitQuerySq($sql, $page=0, $pageSize=20, $data = [])
  348. {
  349. $page = intval($page);
  350. if ($page return [];
  351. }
  352. $pageSize = intval($pageSize);
  353. if ($pageSize > 0) { // pageSize 为0时表示取所有数据
  354. $sql .= ' LIMIT ' . $pageSize;
  355. if ($page > 0) {
  356. $start_limit = ($page - 1) * $pageSize;
  357. $sql .= ' OFFSET ' . $start_limit;
  358. }
  359. }
  360. return $this->querySq($sql, $data);
  361. }
  363. /**
  364. * 此方法是用来计算查询返回的条数 注意 它只支持SELECT COUNT(*) FROM TABLE...或者SELECT COUNT(0) FROM TABLE...方式
  365. * @param string $sql 查询的sql语句
  366. * @param array $data SQL语句的条件
  367. */
  368. public function countRowsSq($sql,$data = []){
  369. if($this->checkParams($sql,$data) === false)
  370. return false;
  371. return $this->pdoExecSq($sql,$data,[2]);
  372. }
  374. /**
  375. * 这里再提供一个方法 这是最后提交操作 如果没有开启事务 此方法最后可以不调用的
  376. */
  377. public function sQCommit()
  378. {
  379. if(empty($this->pdo) || !is_object($this->pdo))
  380. return false;
  381. if(isset($this->Transaction) && $this->Transaction === true)
  382. $this->pdo->commit();//提交事务
  383. unset($this->pdo);
  384. }
  386. /**
  387. * 内部调用方法
  388. */
  389. public function checkParams($sql,$data)
  390. {
  391. if (empty($this->pdo) || !is_object($this->pdo) || !is_array($data) || empty($sql) || !is_string($sql))
  392. return false;
  394. return true;
  395. }
  397. /**
  398. * 内部调用方法
  399. */
  400. private function pdoExecSq($sql,$data,$select = []){
  401. try{
  402. $res = $this->pdoExec($data,$sql);
  403. if(empty($select))
  404. return $res;
  405. else{
  406. if($select[0] === 1){
  407. if($select[1] === true)
  408. return $this->statement->fetch(PDO::FETCH_ASSOC);
  409. else
  410. return $this->statement->fetchAll(PDO::FETCH_ASSOC);
  411. }elseif($select[0] === 2)
  412. return $this->statement->fetchColumn();
  413. else
  414. return false;
  415. }
  416. } catch (Exception $e) {
  417. throw new Exception($e->getMessage());
  418. return false;
  419. } finally {
  420. if (!empty($this->statement))
  421. {
  422. $this->statement->closeCursor();
  423. unset($this->statement);
  424. }
  425. }
  426. }
  428. /**
  429. * 内部调用方法
  430. */
  431. private function execRes($data,$sql){
  433. $res = $this->pdoExec($data,$sql);
  435. $in_id = $this->pdo->lastInsertId();
  437. if (preg_match("/^\s*(INSERT\s+INTO|REPLACE\s+INTO)\s+/i", $sql) && !empty($in_id))
  438. $this->lastInsID = $in_id;
  439. else
  440. $this->lastInsID = $res;
  441. }
  443. /**
  444. * 内部调用方法 用来直接执行SQL语句的方法
  445. */
  446. private function pdoExec($data,$sql){
  447. $this->statement = $this->pdo->prepare($sql);
  448. if (false === $this->statement)
  449. return false;
  450. if (!empty($data))
  451. {
  452. foreach ($data as $k => $v)
  453. {
  454. $this->statement->bindValue($k, $v);
  455. }
  456. }
  457. $res = $this->statement->execute();
  458. if (!$res)
  459. {
  460. throw new Exception('sql:'.$sql.'where:'.json_encode($data).'error:'.json_encode($this->statement->errorInfo()));
  461. }else{
  462. return $res;
  463. }
  464. }
  466. /**
  467. * 内部调用方法 用来释放的
  468. */
  469. private function free()
  470. {
  471. if (is_null($this->pdo))
  472. $this->getConnect();
  474. if (!empty($this->statement))
  475. {
  476. $this->statement->closeCursor();
  477. $this->statement = null;
  478. }
  479. }
  480. }
  481. ?>
复制代码

PHP, PDO, MYSQL


성명：
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
이전 기사：PHP无限分类[增强版] 다음 기사：php加密解密处理类

관련 기사

더보기