<thead id="rrjt3"></thead>
      <progress id="rrjt3"><dfn id="rrjt3"></dfn></progress>

      <em id="rrjt3"></em>

        <address id="rrjt3"><ins id="rrjt3"><dfn id="rrjt3"></dfn></ins></address>
          <i id="rrjt3"></i>

        php下pdo的mysql事務處理用法實例

        時間:2020-09-09 15:54:37 類型:PHP
        字號:    

         

           事務的作用是

          要么語句塊中每條語句都操作成功,要么都失敗。換句話說,就是可以保持數據庫中數據的一致性和完整性。事物以BEGIN關鍵字開始,COMMIT關鍵字結束。在這之間的一條SQL操作失敗,那么,ROLLBACK命令就可以把數據庫恢復到BEGIN開始之前的狀態


         php+mysql事務處理的幾個步驟:

        1. 關閉自動提交

        2. 開啟事務處理

        3. 有異常就自動拋出異常提示再回滾

        4. 開啟自動提交

        5. 注意:mysql只有這個InnoDB驅動是支持事務處理的,默認MyIsAM驅動不支持,下面是實例代碼:


        6. <?php 
          
              try{ 
          
                  $pdo=new pdo("mysql:host=localhost;dbname=mydb", "root", "root", array(PDO::ATTR_AUTOCOMMIT=>0));//最后是關閉自動提交 
          
                  //$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 0);//這個是通過設置屬性方法進行關閉自動提交和上面的功能一樣 
          
                  $pdo->setAttribute(PDO::ATTR_ERRMODE,  PDO::ERRMODE_EXCEPTION);//開啟異常處理 
          
              }catch(PDOException $e){ 
          
                  echo "數據庫連接失?。?quot;.$e->getMessage(); 
          
                  exit;
          
              } 
          
              /* 
          
               * 事務處理 
          
               * 
          
               *   張三從李四那里買了一臺 2000 元的電腦 
          
               *     從張三帳號中扣出 2000元 
          
               *     向李四賬號中加入 2000元 
          
               *     從商品表中減少一臺電腦 
          
               *     MyIsAM  InnoDB 
          
               */ 
          
              try{ 
          
                  $pdo->beginTransaction();//開啟事務處理        
          
                  $price=500; 
          
                  $sql="update zhanghao set price=price-{$price} where id=1"; 
          
                  $affected_rows=$pdo->exec($sql); 
          
                  if(!$affected_rows) 
          
                      throw new PDOException("張三轉出失敗");//那個錯誤拋出異常 
          
                  $sql="update zhanghao set price=price+{$price} where id=3"; 
          
                  $affected_rows=$pdo->exec($sql);       
          
                  if(!$affected_rows) 
          
                      throw new PDOException("向李四轉入失敗"); 
          
                  echo "交易成功!"; 
          
                  $pdo->commit();//交易成功就提交 
          
              }catch(PDOException $e){ 
          
                  echo $e->getMessage(); 
          
                  $pdo->rollback(); 
          
              }   
          
              $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);//自動提交,如果最后不自動提交,轉賬是不成功的   
          
              //設置錯誤報告模式 ERRMODE_SILENT    ERRMODE_WARNING 
          
          ?>


        黄网站免费 <