PDO事务处理

<?php
// beginTransaction();
// commit();
// rollBack();
try{
$pdo = new PDO("mysql:host=localhost;dbname=test;","root","");
$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
}catch(PDOException $e){
die("database connect fail".$e->getMessage());
}

/*
try{
$pdo->beginTransaction();
$sql = "insert into users(id,name,age) values(?,?,?)";
$stmt = $pdo->prepare($sql);

$stmt->execute(array(null,"test4",11));
$stmt->execute(array(null,"test2",11));
$stmt->execute(array(null,"test3",11));

$pdo->commit();

}catch(PDOException $e){
die("run fail".$e->getMessage());
$pdo->rollback();
}
*/

$pdo->beginTransaction();
$sql = "insert into users(id,name,age) values(?,?,?)";
$stmt = $pdo->prepare($sql);
$datalist = array(
array(null,"test6",11),
array(null,"test7",11),
array(null,"test8",11),
);
$isCommit = true;

foreach($datalist as $data){
$stmt->execute($data);
if($stmt->errorCode()>0){
$pdo->roolback();
$isCommit = false;
break;
}
}

if($isCommit){
$pdo->commit();
}