1 <html> 2 <body> 3 <?php 4 #數據庫連接 5 $dbtype = 'mysql'; 6 $host = 'localhost'; 7 $db = 'test'; 8 $user = 'root'; 9 $psw = 'china0913'; 10 11 $dsn = $dbtype . ':host=' . $host . ';' . 'dbname=' . $db; 12 13 try { 14 $dbh = new PDO($dsn, $user, $psw, array(PDO::ATTR_PERSISTENT=>true)); 15 echo '連接成功<br>'; 16 } catch(Exception $e) { 17 die('Connect Failed Message: ' . $e->getMessage()); 18 } 19 20 #使用query函數查詢 21 $sql = 'SELECT * FROM user'; 22 $query = $dbh->query($sql); 23 $query->setFetchMode(PDO::FETCH_ASSOC); //設置結果集返回格式,此處為關聯數組,即不包含index下標 24 $rs = $query->fetchAll(); 25 var_dump($rs); 26 27 #使用exec函數進行INSERT,UPDATE,DELETE,結果返回受影響的行數 28 $sql = 'INSERT INTO user (`userName`, `userPassword`, `userAge`) SELECT (MAX(userId) + 1), \'123456\', 18 FROM user'; //插入一行用戶數據,其中userName使用userId最大值+1 29 // $rs = $dbh->exec($sql); 30 // var_dump($rs) . '<br>'; 31 32 #使用prepareStatement進行CURD 33 $sql = 'SELECT * FROM user WHERE userId = ?'; 34 $stmt = $dbh->prepare($sql); 35 $stmt->bindParam(1, $userId); //綁定第一個參數值 36 $userId = 1; 37 38 $stmt->execute(); 39 $stmt->setFetchMode(PDO::FETCH_ASSOC); 40 $rs = $stmt->fetchAll(); 41 var_dump($rs); 42 43 #使用事務 44 try { 45 $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //設置錯誤模式,發生錯誤時拋出異常 46 $dbh->beginTransaction(); 47 $sql1 = 'SELECT bookNum FROM book WHERE bookId = ? FOR UPDATE'; //此處加上行鎖,可以對bookNum做一些判斷,bookNum>1,才做下一步更新操作 48 $sql2 = 'UPDATE book SET bookNum=bookNum-1 WHERE bookId = ?'; //加上行鎖后,如果user1在買書,並且user1的買書過程沒有結束,user2就不能執行SELECT查詢書籍數量的操作,這樣就保證了不會出現只有1本書,卻兩個人同時買的狀況 49 $stmt1 = $dbh->prepare($sql1); 50 $stmt2 = $dbh->prepare($sql2); 51 $stmt1->bindParam(1, $userId); 52 $stmt2->bindParam(1, $userId); 53 $userId = 1; 54 $stmt1->execute(); 55 $stmt2->execute(); 56 $dbh->commit(); 57 } catch(Exception $e) { 58 $dbh->rollBack(); 59 die('Transaction Error Message: ' . $e->getMessage()); 60 } 61 ?> 62 </body> 63 </html>
PHP PDO的簡單使用(query(),exec(),prepare(),Transaction,行鎖)
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。