首页 > 代码库 > MySql 事务处理

MySql 事务处理

    $mysqli=@new mysqli(‘localhost‘,‘root‘,‘‘,‘sqldb‘);    if(mysqli_connect_errno()){        echo "链接错误".$mysqli->error.":".$mysqli->errno;    }    //关闭自动提交    $mysqli->autocommit(0);    $error=true;    $zhuan=50;    //张三    $sql="update user set total=total-{$zhuan} where name=‘zhangsan‘";    $result=$mysqli->query($sql);    if(!$result){        $error=false;        echo "张三转账失败";            }else{        if($mysqli->affected_rows==0){            $error=false;            echo "张三的钱没有变化";                    }else{            $error=true;            echo "张三转账成功";                    }    }    //李四    $sql="update user set total=total+{$zhuan} where name=‘lisi‘";    $result=$mysqli->query($sql);    if(!$result){        $error=false;        echo "李四转入失败";            }else{        if($mysqli->affected_rows==0){            $error=false;            echo "李四的钱没有变化";                    }else{            $error=true;            echo "李四转入成功";                    }    }    if($error){        echo "转账成功";        $mysqli->commit();            }else{        echo "转账失败";        $mysqli->rollback();    }
    $mysqli->autocommit(1);