php学习笔记之事务处理

1.try-catch

<?php

header("content-type:text/html;charset=utf-8");

$pdo= new PDO("mysql:host=127.0.0.1;dbname=test","root","");

$pdo->query('set names utf8');

try{

    //开启事务

    $pdo->beginTransaction();

    $sql="insert into user(id,name,class) values(?,?,?)";

    $stmt=$pdo->prepare($sql);

    //传入参数

    $stmt->execute(array(3,'limng','六年级旧版'));

    $stmt->execute(array(4,'limng','六年级旧版'));

    $stmt->execute(array(5,'limng','六年级旧版'));

    //提交事物

    $pdo->commit();

}catch(PDOException $e) {

        die($e->getMessage());

        $pdo->roolback();

}

2.foreach结构

<?php

header("content-type:text/html;charset=utf-8");

$pdo= new PDO("mysql:host=127.0.0.1;dbname=test","root","");

$pdo->query('set names utf8');

    //开启事务

    $pdo->beginTransaction();

    $sql="insert into user(id,name,class) values(?,?,?)";

    $stmt=$pdo->prepare($sql);

    $datalist=array(

            array(3,'limng','六年级旧版'),

            array(3,'limng','六年级旧版'),

            array(3,'limng','六年级旧版')

        );

    $isCommit=true;

    foreach ($datalist as $data) {

        $stmt->execute($data);

        if($stmt->errorCode()>0){

            $pdo->roolback();

            $isCommit=false;

            break;

        }

    }

    if($isCommit){

            $pdo->commit();

    }