php下pdo的mysql事務(wù)處理應(yīng)用實(shí)例

2024-05-04 21:49:12

字體：大中小

供稿：網(wǎng)友

php+mysql事務(wù)處理的幾個(gè)步驟:

1.關(guān)閉自動(dòng)提交 2.開啟事務(wù)處理 3.有異常就自動(dòng)拋出異常提示再回滾 4.開啟自動(dòng)提交

注意:mysql只有這個(gè)InnoDB驅(qū)動(dòng)是支持事務(wù)處理的,默認(rèn)MyIsAM驅(qū)動(dòng)不支持,下面是實(shí)例代碼:

<?php

    try{

        $pdo=new pdo("mysql:host=localhost;dbname=mydb", "root", "root", array(PDO::ATTR_AUTOCOMMIT=>0));//最后是關(guān)閉自動(dòng)提交

        //$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 0);//這個(gè)是通過設(shè)置屬性方法進(jìn)行關(guān)閉自動(dòng)提交和上面的功能一樣

        $pdo->setAttribute(PDO::ATTR_ERRMODE,  PDO::ERRMODE_EXCEPTION);//開啟異常處理

    }catch(PDOException $e){

        echo "數(shù)據(jù)庫連接失敗：".$e->getMessage();

        exit;//開源代碼Vevb.com

    }

    /*

     * 事務(wù)處理

     *

     *   張三從李四那里買了一臺(tái) 2000 元的電腦

     *     從張三帳號(hào)中扣出 2000元

     *     向李四賬號(hào)中加入 2000元

     *     從商品表中減少一臺(tái)電腦

     *     MyIsAM  InnoDB

     */

    try{

        $pdo->beginTransaction();//開啟事務(wù)處理

        $price=500;

        $sql="update zhanghao set price=price-{$price} where id=1";

        $affected_rows=$pdo->exec($sql);

        if(!$affected_rows)

            throw new PDOException("張三轉(zhuǎn)出失敗");//那個(gè)錯(cuò)誤拋出異常

        $sql="update zhanghao set price=price+{$price} where id=3";

        $affected_rows=$pdo->exec($sql);

        if(!$affected_rows)

            throw new PDOException("向李四轉(zhuǎn)入失敗");

        echo "交易成功！";

        $pdo->commit();//交易成功就提交

    }catch(PDOException $e){

        echo $e->getMessage();

        $pdo->rollback();

    }

    $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);//自動(dòng)提交，如果最后不自動(dòng)提交，轉(zhuǎn)賬是不成功的

    //設(shè)置錯(cuò)誤報(bào)告模式 ERRMODE_SILENT    ERRMODE_WARNING

?>