MYSQL 事务处理
MYSQL的事务处理主要有两种方法。
1、用begin,rollback,commit来实现
begin/START TRANSACTION 开始一个事务
rollback 事务回滚
commit 事务确认
2、直接用set来改变mysql的自动提交模式
MYSQL默认是自动提交的，也就是你提交一个QUERY，它就直接执行！我们可以通过
set autocommit=0 禁止自动提交
set autocommit=1 开启自动提交
当你用 set autocommit=0 的时候，你以后所有的SQL都将做为事务处理，直到你用commit确认或rollback结束。注意当你结束这个事务的同时也开启了个新的事务！按第一种方法只将当前的作为一个事务！个人推荐使用第一种方法！
MYSQL中只有INNODB和BDB类型的数据表才能支持事务处理！其他的类型是不支持的！
DROP TABLE IF EXISTS `goods`;
CREATE TABLE `goods` (
`gid` mediumint(8) unsigned NOT NULL COMMENT '//商品编号',
`name` varchar(20) NOT NULL COMMENT '//商品名',
`store` smallint NOT NULL COMMENT '//库存'
)ENGINE=INNODB DEFAULT CHARSET=utf8 ;
/********************** 事物使用示例 1 ***************/
$conn = mysql_connect('localhost','root','panbiao') 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");
/****************************** 事物使用示例 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");自动提交
/****************************** 扩展mysqli事务处理************************/
$mysqli=new mysqli("localhost", "root", "123456", "test");
//事务处理
$mysqli->autocommit(0);
$error=true;
$price=50;
$sql="update zh set ye=ye-{$price} where name='zhangsan'";
$result=$mysqli->query($sql);
if(!$result){//判断SQL语句是否有误
$error=false;
echo "从张三转出失败
";
}else{
if($mysqli->affected_rows==0){
$error=false;
echo "张三的钱没有变化";
}else{
echo "从张三账号中转出成功!
";
}
}
$sql="update zh set ye=ye+{$price} where name='lisi1'";
$result=$mysqli->query($sql);
if(!$result){
$error=false;
echo "从李四转入失败
";
}else{
if($mysqli->affected_rows==0){
$error=false;
echo "李四的钱没有变化";
}else{
echo "向李四账号中转入成功!
";
}
}
if($error){
echo "转账成功!";
$mysqli->commit();
}else{
echo "转账失败!";
$mysqli->rollback();
}
$mysqli->autocommit(1);
$mysqli->close();
/****************************** 扩展PDO事务处理************************/
try{
$autocommit=array(PDO::ATTR_AUTOCOMMIT=>0);//关闭自动提交
$pdo=new PDO("mysql:host=localhost;dbname=test", "root", "123456",$autocommit);
$pdo->setAttribute(PDO::ATTR_ERRMODE, 2 或者 PDO::ERRMODE_EXCEPTION);
}catch(PDOException $e){
echo "数据库连接失败：".$e->getMessage();
exit;
}
try{
$pdo->beginTransaction();//开启事务处理
$price=500;
$sql="update zhanghao set price=price-{$price} where id=1";
$affected_rows=$pdo->exec($sql);
if(!$affected_rows) throw new PDOException("张三转出失败");//抛出新异常
$sql="update zhanghao set price=price+{$price} where id=3";
$affected_rows=$pdo->exec($sql);
if(!$affected_rows) throw new PDOException("向李四转入失败");//抛出新异常
echo "交易成功！";
$pdo->commit();//提交
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollback();//撤销
}
$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);//开启自动提交
/******************对于不支持事务的MyISAM引擎数据库可以使用表锁定的方法 ***************/
MyISAM & InnoDB 都支持
LOCK TABLES可以锁定用于当前线程的表。如果表被其它线程锁定，则造成堵塞，直到可以获取所有锁定为止。UNLOCK TABLES可以释放被当前线程保持的任何锁定。当线程发布另一个LOCK TABLES时，或当与服务器的连接被关闭时，所有由当前线程锁定的表被隐含地解锁。
mysql_query("LOCK TABLES `user` WRITE");//锁住`user`表
$sql = "INSERT INTO `user` (`id`, `username`, `sex`) VALUES (NULL, 'test1', '0')";
$res = mysql_query($sql);
if($res){
echo '提交成功。!';
}else{
echo '失败!';
}
mysql_query("UNLOCK TABLES");//解除锁定
