1 try {
 2         $pdo = new PDO($dsn, $user, $pass);     //初始化一个PDO对象，就是创建了数据库连接对象$pdo
 3         $pdo->setAttribute (PDO::ATTR_ERRMODE , PDO::ERRMODE_EXCEPTION );
 4         $pdo->beginTransaction();                //开启事务
 5         $query="正确的语句";
 6         $result=$pdo->prepare($query);
 7                 
 8         if($result->execute()){
 9             echo "数据添加成功！";
10         }else{
11             echo "数据添加失败！";
12         }
13         
14         
15         $query="错误的语句";
16         $result=$pdo->prepare($query);
17                 
18         if($result->execute()){
19             echo "数据添加成功！";
20         }else{
21             echo "数据添加失败！";
22         }        
23         
24         
25         $pdo->commit();                        //执行事务的提交操作
26     } catch (PDOException $e) {
27           die ("Error!: " . $e->getMessage() . "<br/>");
28         $pdo->rollBack();                    //执行事务的回滚
29     }