夏日博客

A-A+

mysql事务回滚数据回滚用法与问题

2017年11月06日 PHP技术文章 暂无评论 阅读 0 views 次

mysql事务回滚就是BEGIN,ROLLBACK,COMMIT三种组成了,差不就是就如果所有数据提交成功再把数据提交,否则就自动回滚数据了,这种做法多做于银行,大型数据操作应用上.

在当前事务中确实能看到插入的记录,最后只不过删除了,但是AUTO_INCREMENT不会应删除而改变值.

1、为什么auto_increament没有回滚？

因为innodb的auto_increament的计数器记录的当前值是保存在存内 存中的，并不是存在于磁盘上，当mysql server处于运行的时候，这个计数值只会随着insert改增长，不会随着delete而减少。而当mysql server启动时，当我们需要去查询auto_increment计数值时，mysql便会自动执行：SELECT MAX(id) FROM 表名 FOR UPDATE;语句来获得当前auto_increment列的最大值，然后将这个值放到auto_increment计数器中。所以就算 Rollback MySQL的auto_increament计数器也不会作负运算。

2、MySQL的事务对表操作的时候是否是物理操作？

MySQL的事务是有redo和undo的，redo操作的所有信息都是记录到 redo_log中，也就是说当一个事务做commit操作时，需要先把这个事务的操作写到redo_log中，然后再把这些操作flush到磁盘上，当 出现故障时，只需要读取redo_log,然后再重新flush到磁盘就行了。

而对于undo就比较麻烦，MySQL在处理事务时，会在数据共享 表空间里申请一个段叫做segment段，用保存undo信息，当在处理rollback，不是完完全全的物理undo，而是逻辑undo,就是说会对之 前的操作进行反操作，但是这些共享表空间是不进行回收的。这些表空间的回收需要由mysql的master thread进程来进行回收。

首先,mysql使用事务前需确定存储引擎为innodb,事务代码如下:

start transaction rollback commit

修改表类型,代码如下:

  1. ALTER TABLE `goods` ENGINE = InnoDB; engine   
  2. ALTER TABLE `goods` ENGINE = MYISAM    
  3. show create table goods G   

下面为存储过程的代码:

  1. BEGIN   
  2. DECLARE t_error INTEGER DEFAULT 0;    
  3. DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;   
  4. #set autocommit =0;   
  5. START TRANSACTION;   
  6. INSERT INTO `mytest`.`test2` VALUES ( 1 ,’22′,’33′);   
  7. INSERT INTO `mytest`.`test2` VALUES ( NULL ,’22′,’33′);   
  8. IF t_error = 1 THEN    
  9. ROLLBACK;    
  10. ELSE    
  11. COMMIT;    
  12. END IF;   
  13. END   

上面只是mysql事物回滚了,下面我来介绍一个与php结合的实例,例子代码如下:

  1. $lnk = mysql_connect("localhost", "root", "");      
  2. mysql_select_db("test");      
  3. mysql_query("BEGIN");      
  4. $query = mysql_query("INSERT INTO test VALUES(1, 'yangjun')");      
  5. $q1 = mysql_error();      
  6. mysql_query("INSERT INTO test VALUES(1, 'yangjun')");      
  7. $q2 = mysql_error();      
  8. mysql_query("INSERT INTO test VALUES(2, '杨俊')");      
  9. $q3 = mysql_error();      
  10. if (!$q1 && !$q2 && !$q3) {      
  11.      mysql_query("COMMIT");  //全部成功，提交执行结果    
  12. } else {    //phpfensi.com   
  13.      mysql_query("ROLLBACK"); //有任何错误发生，回滚并取消执行结果      
  14. }      
  15. var_dump($q1, $q2, $q3);   

例子,代码如下:

  1. **   
  2. * 订单入库   
  3. * 1，生成日期+随机数订单号，并保证不重复   
  4. * 2，插入订单order_info表   
  5. * 3，插入订单对应的商品表 order_goods   
  6. * 4,修改商品表，减少库存   
  7. * 5，用事务保证三表的一致性   
  8. */   
  9.    
  10. /* 临时需要一个生成订单的功能 */   
  11. function create_sn()   
  12. {   
  13. $sn = date('YmdHis').rand(100,999);   
  14. $sql = "select count(*) from order_info where order_sn = '$sn'";   
  15. return $GLOBALS['db']->getOne($sql)?create_sn():$sn;  //有这个单号就重生成一个   
  16. }   
  17.    
  18. // ---------事务开始----------------------   
  19. $db->query("start transaction");    
  20. // 可用此方法插入 $db->autoExecute('表名',$data,'insert/update','条件')   
  21. $order_sn     = create_sn();   
  22. $user_id      = $_SESSION['user']['user_id'];   
  23. $add_time     = time();   
  24. $goods_amount = $cart->getPrice();   
  25. $sql = "insert into order_info (order_sn,user_id,goods_amount,add_time)   
  26. VALUES ('$order_sn','$user_id','$goods_amount','$add_time')";   
  27.    
  28. $db->query($sql); // 执行插入订单SQL语句（order_info表）   
  29.    
  30. /* 操作order_goods表 */   
  31. $order_id = $db->insert_id(); // 取得刚插入表的主键   
  32. $cartlist = $cart->enumItems(); // 获得购物车商品的数组   
  33. foreach ($cartlist as $k=>$v)   
  34. {   
  35. //查出商品的SN等信息加到购物车商品的数组中   
  36. $sql = "select goods_id,goods_sn,goods_name,shop_price from goods where goods_id = '$k'";   
  37. $cartlist[$k] = $cartlist[$k] + $db->getRow($sql);     
  38. }   
  39. /* 根据购物车里的商品，将所有要买的商品添加到order_goods表里，并更新goods表的库存 */   
  40. $sqls=array();   
  41. foreach ($cartlist as $k=>$v)   
  42. {   
  43. $goods_id     = $k;   
  44. $goods_name   = $v['goods_name'];   
  45. $goods_sn     = $v['goods_sn'];   
  46. $goods_number = $v['num'];   
  47. $goods_price  = $v['shop_price'] * $v['num'];   
  48. $sqls[] = "insert into order_goods (order_id,goods_id,goods_name,goods_sn,goods_number,goods_price) values ('$order_id','$goods_id','$goods_name','$goods_sn','$goods_number','$goods_price')";   
  49. $sqls[] = "update goods set goods_number = goods_number - '$goods_number' where goods_id = '$goods_id'";   
  50. }   
  51. //print_r($sqls);   
  52. $res = true;   
  53. foreach ($sqls as $sql)   
  54. {   
  55.    
  56. $res = $res && $db->query($sql); //如果有一个SQL语句出错，$res就不为真   
  57. }   
  58. // ---------如果$res是真就提交事务，否则就回滚事务----------   
  59.    
  60. if(!$res)   
  61. {    
  62. $db->query('rollback');   
  63. show_message('订单创建失败','返回购物车','flow.php?act=cartinfo');   
  64. exit();   
  65. }   
  66. else    
  67. {   
  68. $db->query('commit');   
  69. $smarty->assign('order_sn',$order_sn);   
  70. $smarty->assign('order_amount',$cart->getPrice());   
  71. $cart->emptyItems();   
  72. $smarty->display('my_gwc3.html');   
  73. }   
  74. }   

注意:MYSQL中只有INNODB和BDB类型的数据表才能支持事务处理,其他的类型是不支持的.

标签：

给我留言