mysql

MySQL事务处理

《PHP与MYSQL权威指南》第245页，事务处理。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
/*************** transaction--1 ***************/  
$conn = mysql_connect('localhost','root','root') or die ("数据连接错误!!!");  
mysql_select_db('test',$conn);  
mysql_query("set names 'GBK'"); //使用GBK中文编码;  
//开始一个事务  
mysql_query("BEGIN"); //或者mysql_query("START TRANSACTION");  
$sql = "INSERT INTO `user` (`id`, `username`, `sex`) VALUES (NULL, 'test1', '0')";  
$sql2 = "INSERT INTO `user` (`did`, `username`, `sex`) VALUES (NULL, 'test1', '0')";//这条我故意写错  
$res = mysql_query($sql);  
$res1 = mysql_query($sql2);  
if($res && $res1){  
    mysql_query("COMMIT");  
    echo '提交成功。';  
}else{  
    mysql_query("ROLLBACK");  
    echo '数据回滚。';  
}  
mysql_query("END");  
/**************** transaction--2 *******************/  
/*方法二*/  
mysql_query("SET AUTOCOMMIT=0"); //设置mysql不自动提交，需自行用commit语句提交  
$sql = "INSERT INTO `user` (`id`, `username`, `sex`) VALUES (NULL, 'test1', '0')";  
$sql2 = "INSERT INTO `user` (`did`, `username`, `sex`) VALUES (NULL, 'test1', '0')";//这条我故意写错  
$res = mysql_query($sql);  
$res1 = mysql_query($sql2);  
if($res && $res1){  
    mysql_query("COMMIT");  
    echo '提交成功。';  
}else{  
    mysql_query("ROLLBACK");  
    echo '数据回滚。';  
}  
mysql_query("END"); //事务处理完时别忘记mysql_query("SET AUTOCOMMIT=1");自动提交