国产av日韩一区二区三区精品,成人性爱视频在线观看,国产,欧美,日韩,一区,www.成色av久久成人,2222eeee成人天堂

首頁 後端開發(fā) php教程 PHP PDO操作MYSQL封裝類

PHP PDO操作MYSQL封裝類

Jul 25, 2016 am 08:42 AM
  1. /**
  2. * auther soulence
  3. * 呼叫資料類別檔案
  4. * modify 2015/06/12
  5. */
  6. class DBConnect
  7. {
  8. private $dbname = null;
  9. private $dodbdo = null;
  10. private $persistent = false;
  11. private $statement = null;
  12. private $lastInsID = null;
  13. private static $_instance = [];
  14. private static $_instance = [];
  15. {
  16. $this->dbname = $dbname;
  17. $this->persistent = $attr;
  18. }
  20. 公共靜態(tài)函數(shù)db ($flag='r',$persistent=false)
  21. {
  22. if(!isset($flag)){
  23. $flag = 'r';
  24. }
  26. if (!class_exists('PDO'))
  27. {
  28. throw new Exception('找不到PDO');
  29. return false;
  30. }
  31. $mysql_server = Yaf_Registry::get('mysql');
  32. if(!isset($mysql_server[$flag])){
  33. return false;
  34. }
  36. $options_arr = array(PDO::MYSQL_ATTR_INIT_COMMAND => '設(shè)定名稱'.$mysql_server[$flag]['charset'],PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC); if(Ypersed $ === true){
  37. $options_arr[PDO::ATTR_PERSISTENT] = true;
  38. }
  40. 嘗試{
  41. $pdo = new PDO($mysql_server[$flag][ '??> $pdo = new PDO($mysql_server_server '],$mysql_server[$flag]['使用者名稱'],$mysql_server[$flag]['password'],$options_arr);
  42. } catch (PDOException $e) {
  43. 引發(fā)新例外( $e->getMessage());
  44. //exit('連線失敗:'.$e->getMessage());
  45. 回傳 false;
  46. }
  48. if(!$pdo) {
  49. throw new Exception('PDO CONNECT ERROR');
  50. 回傳 false;
  51. }
  53. return $pdo;
  54. }
  56. /**
  57. * 得到操作資料庫物件
  58. * @param string $dbname 對應(yīng)的資料庫是誰
  59. * @param bool $attr 是否長連接
  60. * return false說明給定的資料庫不存在
  61. */
  62. public static function getgetstance($dbname = ' r',$attr = false)
  63. {
  64. $mysql_server = Yaf_Registry::get('mysql');
  65. if(!isset($mysql_server[$dbname])){
  66. return false ;
  67. }
  68. $key = md5(md5($dbname.$attr,true));
  69. if (!isset(self::$_instance[$key]) || !is_object(self: :$_instance[$key] ]))
  70. self::$_instance[$key] = new self($dbname,$attr);
  71. return self::$_instance[$key];
  72. }
  74. 私有函數(shù)getConnect(){
  75. $this->pdo = self::db($this->dbname,$this->persistent);
  76. }
  78. /**
  79. * 查詢操作
  80. * @param string $sql 執(zhí)行查詢的sql語句
  81. * @param array $data 查詢的條件格式為[':id'=>$id,':name'=> $name](推薦)或為[1=>$id,2=>$name]
  82. * @param bool $one 是否回傳一條內(nèi)容預(yù)設(shè)為否
  83. */
  84. 公用函數(shù)查詢($sql, $data = [], $one = false)
  85. {
  86. if (!is_array($data) ||empty($sql ) || ! is_string($sql))
  87. 回傳false;
  89. $this->free();
  91. return $this->queryCommon($data,$sql,$ one) ;
  92. }
  94. /**
  95. * 內(nèi)部查詢的共用方法
  96. */
  97. 乾燥函數(shù)queryCommon($data,$sql,$one)
  98. {
  99. $this->pdoExec( $ data,$sql);
  101. if ($one){
  102. return $this->statement->fetch(PDO::FETCH_ASSOC);
  103. }else{
  104. return $this ->statement->fetchAll(PDO::FETCH_ASSOC);
  105. }
  106. }
  108. /**
  109. * 多條SQL語句的查詢操作
  110. * @param array $arr_sql 執(zhí)行查詢的sql語句數(shù)組格式為[$sql1,$sql2]
  111. * @param array $arr_data 查詢與$arr_sql對應(yīng)的條件格式為[[':id'=>$id,':name'=>$name],[':id'=>$id,':name'=>$name]](推薦)或為[ [1=>$id,2=>$name],[1=>$id,2=>$name]]
  112. * @param bool $one 是否回傳一條內(nèi)容預(yù)設(shè)為否這裡如果設(shè)定為true那麼每一條sql都只回傳一條資料
  113. */
  114. 公用函數(shù)查詢($arr_sql, $arr_data = [] , $one = false)
  115. {
  116. if(!is_array($arr_sql) ||空($arr_sql) || !is_array($arr_data))
  117. return false;
  119. $this->free();
  121. $res = [];$i = 0;
  122. foreach ( $ arr_sql as $val) {
  123. if(!isset($arr_data[$i]))
  124. $arr_data[$i] = [];
  125. elseif(!is_array($arr_data[$i]) ))
  126. throw new Exception('查詢sql時發(fā)生錯誤:'.$val.' where:'.$arr_data[$i]);
  128. $res[] = $this->queryCommon ( $arr_data[$i],$val,$one);
  129. $i ;
  130. }
  131. return $res;
  132. }
  134. /**
  135. * 分頁封裝
  136. *
  137. * @param string $sql
  138. * @param int $page 表示從第幾頁開始取
  139. * @param int $pageSize 表示每頁多少條
  140. * @param array $data 查詢的條件
  141. */
  142. public function limitQuery($sql, $page=0, $pageSize=20, $data = [])
  143. {
  144. $page = intval($page);
  145. if ($page return [];
  146. }
  147. $pageSize = intval($pageSize);
  148. if ($pageSize > 0) { // pageSize 為0時表示取得所有資料
  149. $sql .= ' LIMIT ' . $pageSize;
  150. if ($page > 0) {
  151. $start_limit = ($page - 1) * $pageSize;
  152. $sql .= ' OFFSET ' 。 > }
  153. return $this->query($sql, $data);
  154. }
  156. /**
  157. * 這個是用來進行新增刪除修改操作使用事務(wù)操作
  158. * @param string $sql 執(zhí)行查詢的sql語句
  159. * @param array $data 查詢的條件格式為[':id'= >$id,':name'=>$name](推薦)或為[1=>$id,2=>$name]
  160. * @param bool $Transaction 是否交易操作預(yù)設(shè)為否
  161. */
  162. public functionexecuteDDL($sql, $data = [ ],$Transaction = false){
  163. if (!is_array($data) || !is_string($sql))
  164. return false;
  166. $this->free();
  168. if($Transaction)
  169. $this->pdo->beginTransaction();//開啟交易
  170. try{
  171. $ this->execRes($data,$sql);
  172. if($Transaction)
  173. $this->pdo->commit();//提交交易
  174. return $this->; lastInsID;
  175. } catch (Exception $e) {
  176. if($Transaction)
  177. $this->pdo->rollBack();//交易回滾
  178. throw new Exception('錯誤 DDLExecute '.$e->getMessage());
  179. return false;
  180. }
  181. }
  183. /**
  184. * 這個是用來進行新增刪除修改操作使用事務(wù)操作
  185. * 它是執(zhí)行多條的
  186. * @param array $arr_sql 需要執(zhí)行操作的SQL語句數(shù)組
  187. * @param array $ arr_data 與陣列對應(yīng)SQL語句的條件
  188. * @param bool $Transaction 是否事務(wù)操作預(yù)設(shè)為否
  189. * /
  190. public functionexecuteDDLes($arr_sql, $arr_data = [],$Transaction = false){
  192. if(!is_array($arr_sql) || 空($arr_sql) || !is_array($ arr_data))
  193. return false;
  195. $res = [];
  197. $this->free();
  199. if($Transaction)
  200. $this->pdo-> beginTransaction();//開啟事務(wù)
  201. try{
  202. $i = 0;
  203. foreach($arr_sql as $val){
  204. if(!isset( $arr_data[$i]))
  205. $arr_data[$i] = [];
  206. elseif(!is_array($arr_data[$i])){
  207. if($Transaction)
  208. $ this->pdo->rollBack() ;// 交易回溯
  209. throw new Exception('Error where DDLExecutees sql:'.$val.' where:'.$arr_data[$i]);
  210. }
  212. $this- >execRes($arr_data[$i],$val);
  213. $res[] = $this->lastInsID;
  214. $i ;
  215. }
  217. if($Transaction)
  218. $this->pdo->commit();// 交易提交
  220. return $res;
  221. } catch (Exception $ e) {
  222. if($Transaction)
  223. $ this->pdo->rollBack();//交易回滾
  224. throw new Exception('Error DDLExecutees array_sql:'.json_encode($arr_sql) ).' '.$e->getMessage());
  225. 回傳 false;
  226. }
  227. 回傳 $res;
  228. }
  230. /**
  231. * 此方法是用來計算查詢傳回的條數(shù)注意它只支援SELECT COUNT(*) FROM TABLE...或SELECT COUNT(0) FROM TABLE...方式
  232. * @param string $sql查詢的sql語句
  233. * @param array $data SQL語句的條件
  234. */
  235. public function countRows($sql,$data = []){
  236. if (!is_array($data) ||空($sql) || !is_string($sql))
  237. return false;
  238. $this->free();
  240. $res = $this->pdoExec($data,$sql);
  242. if($res == false)
  243. return false;
  245. return $this->statement->fetchColumn();
  246. }
  248. /**
  249. * 此方法是用來計算查詢傳回的條數(shù) 它是執(zhí)行多條SQL
  250. * @param string $sql 查詢的sql語句
  251. * @param array $data SQL語句的條件
  252. */
  253. public function countRowses($arr_sql,$arr_data = []){
  255. if(!is_array($arr_sql) || empempty($ arr_sql) || !is_array($arr_data))
  256. 回傳false;
  258. $res = [];
  260. $this->free();
  261. $i = 000 ;
  262. foreach ($arr_sql as $val) {
  263. if(!isset($arr_data[$i]))
  264. $arr_data[$i] = [];
  265. elseif(!is_array ( $arr_data[$i]))
  266. throw new Exception('Error where CountRowses sql:'.$val.' where:'.$arr_data[$i]);
  268. $res1 = $ this ->pdoExec($arr_data[$i],$val);
  270. if($res1 == false)
  271. $res[] = false;
  272. else
  273. $res [] = $this->statement->fetchColumn();
  274. }
  276. return $res;
  277. }
  279. /**
  280. * 這裡再提供一個方法 由於專案中會有很多需要提供開啟事務(wù) 然後再進行操作 最後提交
  281. * @param bool $Transaction 是否事務(wù)操作 預(yù)設(shè)為否
  282. */
  283. public function getDB ($Transaction=false)
  284. {
  285. $this->Transaction = $Transaction;
  286. $this->getConnect();
  287. if($Transaction === true )
  288. $this ->pdo->beginTransaction();//開啟事務(wù)
  289. return $this;
  290. }
  292. /**
  293. * 此方法可以執(zhí)行多次它是執(zhí)行DDL語句的
  294. * 注意它是需要配合getDB和sQCommit一起使用不能單獨使用哦
  295. * 如果沒有開啟事務(wù)sQCommit方法可以不調(diào)用
  296. * @param string $sql 查詢的sql語句
  297. * @param array $data SQL語句的條件
  298. */
  299. public function execSq($sql,$data = [])
  300. {
  301. if($this->checkParams($sql,$data) === false)
  302. return false;
  304. 嘗試{
  305. $this- >execRes($data,$sql);
  306. return $this->lastInsID;
  307. } catch (Exception $e) {
  308. if(isset($ this->Transaction) && $this->Transaction === true)
  309. $this->pdo->rollBack();//交易回滾
  310. throw new Exception('Error execSq'.$e->getMessage());
  311. return false;
  312. } 最後 {
  313. if (!empty($this->statement))
  314. {
  315. $this->statement->closeCursor();
  316. unset($this->statement);
  317. }
  318. }
  319. }
  321. /* *
  322. * 執(zhí)行查詢的方法它需要傳遞一個連接資料庫物件
  323. * @param string $sql 執(zhí)行查詢的sql語句
  324. * @param array $data 查詢的條件格式為[':id'=> $id,':name'=>$name](推薦)或為[1=>$id,2=>$name]
  325. * @param bool $one 是否回傳一條內(nèi)容預(yù)設(shè)為否
  326. */
  327. public function querySq($sql,$data = [],$one = false)
  328. {
  329. if($this->checkParams($sql,$data) = == false)
  330. return false;
  332. return $this->pdoExecSq($sql,$data,[1,$one]);
  333. }
  335. /* *
  336. * 分頁封裝
  337. *
  338. * @param string $sql
  339. * @param int $page 表示從第幾頁開始取
  340. * @param int $pageSize 表示每頁多少條
  341. * @param array $data 查詢的條件
  342. */
  343. public function limitQuerySq($sql, $page=0, $pageSize=20, $data = [])
  344. {
  345. $page = intval($page);
  346. if ($page return [];
  347. }
  348. $pageSize = intval($pageSize);
  349. if ($pageSize > 0) { // pageSize 為0時表示取得所有資料
  350. $ sql .= '限制' 。 ;
  351. }
  352. }
  353. return $this->querySq($sql, $data);
  354. }
  356. /**
  357. * 此方法是用來計算查詢傳回的條數(shù)注意它只支援SELECT COUNT(*) FROM TABLE...或SELECT COUNT(0) FROM TABLE...方式
  358. * @param string $sql查詢的sql語句
  359. * @param array $data SQL語句的條件
  360. */
  361. 公共函數(shù)countRowsSq ($sql,$data = []){
  362. if($this->checkParams($sql,$data) === false)
  363. return false;
  364. return $this->pdoExecSq($ sql,$data,[2]);
  365. }
  367. /**
  368. * 這裡再提供一個方法 這是最後提交操作 如果沒有開啟事務(wù) 此方法最後可以不呼叫的
  369. */
  370. public function sQCommit()
  371. {
  372. if(empty($this->pdo) || !is_object($this->pdo) pdo))
  373. return false;
  374. if(isset($this->Transaction) && $this->Transaction === true)
  375. $this->pdo->commit() ;//提交事務(wù)
  376. unset($this->pdo);
  377. }
  379. /**
  380. * 內(nèi)部呼叫方法
  381. */
  382. public function checkParams($sql,$data)
  383. {
  384. if ($this->pdo) || !is_object($this->pdo) || !is_array($data) || 空($sql) || !is_string($sql))
  385. 回傳false;
  387. 回傳true;
  388. }
  390. /**
  391. * 內(nèi)部呼叫方法
  392. */
  393. 外部函數(shù)pdoExecSq($sql,$data,$ select = []){
  394. 嘗試{
  395. $res = $this->pdoExec($data,$sql);
  396. if(empty($select))
  397. return $res;
  398. else{
  399. if ($select[0] === 1){
  400. if($select[1] === true)
  401. return $this->statement->fetch( PDO::FETCH_ASSOC);
  402. else
  403. return $this->statement->fetchAll(PDO::FETCH_ASSOC);
  404. }elseif($select[0] === 2)
  405. return $this->statement->fetchColumn();
  406. else
  407. return false;
  408. }
  409. } catch (Exception $e) {
  410. throw new Exception($e-> ;getMessage());
  411. return false;
  412. } 最後{
  413. if (!empty($this->statement))
  414. {
  415. $this->statement->; closeCursor();
  416. unset($this->語句);
  417. }
  418. }
  419. }
  421. /**
  422. * 內(nèi)部呼叫方法
  423. */
  424. 中斷函數(shù) execRes( $資料,$sql){
  426. $res = $this->pdoExec($data,$sql);
  428. $in_id = $this->pdo->lastInsertId( );
  430. if (preg_match("/^s*(INSERTs INTO|REPLACEs INTO)s /i", $sql) && !empty($in_id))
  431. $this->lastInsID = $in_id;
  432. else
  433. $this->lastInsID = $res;
  434. }
  436. /**
  437. * 內(nèi)部呼叫方法 用來直接執(zhí)行SQL語句的方法
  438. */
  439. 外部函數(shù)pdoExec($data,$sql ){
  440. $ $ this->statement = $this->pdo->prepare($sql);
  441. if (false === $this->statement)
  442. return false;
  443. if (!empty($data) )
  444. {
  445. foreach ($data as $k =>; $v)
  446. {
  447. $this->語句->bindValue($k, $v);
  448. }
  449. }
  450. $res = $this->語句-> ;execute();
  451. if (!$res)
  452. {
  453. throw new Exception('sql:'.$sql.'where:'.json_encode($data ).'錯誤:'.json_encode($this->statement->errorInfo()));
  454. }else{
  455. return $res;
  456. }
  457. }
  459. /**
  460. * 內(nèi)部呼叫方法 用來釋放的
  461. */
  462. 原生函數(shù)free()
  463. {
  464. if (is_null($this->pdo ))
  465. $this->getConnect();
  467. if (!empty($this->statement))
  468. {
  469. $this->statement->closeCursor();
  470. $this ->statement = null;
  471. }
  472. }
  473. }
  474. ?>
複製程式碼

PHP、PDO、MYSQL


本網(wǎng)站聲明
本文內(nèi)容由網(wǎng)友自願投稿，版權(quán)歸原作者所有。本站不承擔(dān)相應(yīng)的法律責(zé)任。如發(fā)現(xiàn)涉嫌抄襲或侵權(quán)的內(nèi)容，請聯(lián)絡(luò)admin@php.cn

熱AI工具

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅(qū)動的應(yīng)用程序，用於創(chuàng)建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版，非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發(fā)環(huán)境

Dreamweaver CS6

Dreamweaver CS6

視覺化網(wǎng)頁開發(fā)工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

如何在PHP中實施身份驗證和授權(quán)？ 如何在PHP中實施身份驗證和授權(quán)？ Jun 20, 2025 am 01:03 AM

tosecurelyhandleauthenticationandationallizationInphp，lofterTheSesteps：1.AlwaysHashPasswordSwithPassword_hash（）andverifyusingspasspassword_verify（），usepreparedStatatementStopreventsqlineptions，andStoreSeruserDatain usseruserDatain $ _sessiveferterlogin.2.implementrole-2.imaccessccsccccccccccccccccccccccccc.

如何在PHP中安全地處理文件上傳？ 如何在PHP中安全地處理文件上傳？ Jun 19, 2025 am 01:05 AM

要安全處理PHP中的文件上傳，核心在於驗證文件類型、重命名文件並限制權(quán)限。 1.使用finfo_file()檢查真實MIME類型，僅允許特定類型如image/jpeg；2.用uniqid()生成隨機文件名，存儲至非Web根目錄；3.通過php.ini和HTML表單限製文件大小，設(shè)置目錄權(quán)限為0755；4.使用ClamAV掃描惡意軟件，增強安全性。這些步驟有效防止安全漏洞，確保文件上傳過程安全可靠。

PHP中==（鬆散比較）和===（嚴(yán)格的比較）之間有什麼區(qū)別？ PHP中==（鬆散比較）和===（嚴(yán)格的比較）之間有什麼區(qū)別？ Jun 19, 2025 am 01:07 AM

在PHP中，==與===的主要區(qū)別在於類型檢查的嚴(yán)格程度。 ==在比較前會進行類型轉(zhuǎn)換，例如5=="5"返回true，而===要求值和類型都相同才會返回true，例如5==="5"返回false。使用場景上，===更安全應(yīng)優(yōu)先使用，==僅在需要類型轉(zhuǎn)換時使用。

如何在PHP（ - ， *， /，％）中執(zhí)行算術(shù)操作？ 如何在PHP（ - ， *， /，％）中執(zhí)行算術(shù)操作？ Jun 19, 2025 pm 05:13 PM

PHP中使用基本數(shù)學(xué)運算的方法如下：1.加法用 號，支持整數(shù)和浮點數(shù)，也可用於變量，字符串?dāng)?shù)字會自動轉(zhuǎn)換但不推薦依賴；2.減法用-號，變量同理，類型轉(zhuǎn)換同樣適用；3.乘法用*號，適用於數(shù)字及類似字符串；4.除法用/號，需避免除以零，並註意結(jié)果可能是浮點數(shù)；5.取模用%號，可用於判斷奇偶數(shù)，處理負(fù)數(shù)時餘數(shù)符號與被除數(shù)一致。正確使用這些運算符的關(guān)鍵在於確保數(shù)據(jù)類型清晰並處理好邊界情況。

如何與PHP的NOSQL數(shù)據(jù)庫（例如MongoDB，Redis）進行交互？ 如何與PHP的NOSQL數(shù)據(jù)庫（例如MongoDB，Redis）進行交互？ Jun 19, 2025 am 01:07 AM

是的，PHP可以通過特定擴展或庫與MongoDB和Redis等NoSQL數(shù)據(jù)庫交互。首先，使用MongoDBPHP驅(qū)動（通過PECL或Composer安裝）創(chuàng)建客戶端實例並操作數(shù)據(jù)庫及集合，支持插入、查詢、聚合等操作；其次，使用Predis庫或phpredis擴展連接Redis，執(zhí)行鍵值設(shè)置與獲取，推薦phpredis用於高性能場景，Predis則便於快速部署；兩者均適用於生產(chǎn)環(huán)境且文檔完善。

我如何了解最新的PHP開發(fā)和最佳實踐？ 我如何了解最新的PHP開發(fā)和最佳實踐？ Jun 23, 2025 am 12:56 AM

TostaycurrentwithPHPdevelopmentsandbestpractices,followkeynewssourceslikePHP.netandPHPWeekly,engagewithcommunitiesonforumsandconferences,keeptoolingupdatedandgraduallyadoptnewfeatures,andreadorcontributetoopensourceprojects.First,followreliablesource

什麼是PHP，為什麼它用於Web開發(fā)？ 什麼是PHP，為什麼它用於Web開發(fā)？ Jun 23, 2025 am 12:55 AM

PHPbecamepopularforwebdevelopmentduetoitseaseoflearning,seamlessintegrationwithHTML,widespreadhostingsupport,andalargeecosystemincludingframeworkslikeLaravelandCMSplatformslikeWordPress.Itexcelsinhandlingformsubmissions,managingusersessions,interacti

如何設(shè)置PHP時區(qū)？ 如何設(shè)置PHP時區(qū)？ Jun 25, 2025 am 01:00 AM

tosetTherightTimeZoneInphp，restate_default_timezone_set（）functionAtthestArtofyourscriptWithavalIdidentIdentifiersuchas'america/new_york'.1.usedate_default_default_timezone_set_set（）

See all articles