mysql事务回滚数据回滚用法与问题
发布:smiling 来源: PHP粉丝网 添加日期:2014-09-28 21:50:27 浏览: 评论:0
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
修改表类型,代码如下:
- ALTER TABLE `goods` ENGINE = InnoDB; engine
- ALTER TABLE `goods` ENGINE = MYISAM
- show create table goods G
下面为存储过程的代码:
- BEGIN
- DECLARE t_error INTEGER DEFAULT 0;
- DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;
- #set autocommit =0;
- START TRANSACTION;
- INSERT INTO `mytest`.`test2` VALUES ( 1 ,’22′,’33′);
- INSERT INTO `mytest`.`test2` VALUES ( NULL ,’22′,’33′);
- IF t_error = 1 THEN
- ROLLBACK;
- ELSE
- COMMIT;
- END IF;
- END
上面只是mysql事物回滚了,下面我来介绍一个与php结合的实例,例子代码如下:
- $lnk = mysql_connect("localhost", "root", "");
- mysql_select_db("test");
- mysql_query("BEGIN");
- $query = mysql_query("INSERT INTO test VALUES(1, 'yangjun')");
- $q1 = mysql_error();
- mysql_query("INSERT INTO test VALUES(1, 'yangjun')");
- $q2 = mysql_error();
- mysql_query("INSERT INTO test VALUES(2, '杨俊')");
- $q3 = mysql_error();
- if (!$q1 && !$q2 && !$q3) {
- mysql_query("COMMIT"); //全部成功,提交执行结果
- } else { //phpfensi.com
- mysql_query("ROLLBACK"); //有任何错误发生,回滚并取消执行结果
- }
- var_dump($q1, $q2, $q3);
例子,代码如下:
- **
- * 订单入库
- * 1,生成日期+随机数订单号,并保证不重复
- * 2,插入订单order_info表
- * 3,插入订单对应的商品表 order_goods
- * 4,修改商品表,减少库存
- * 5,用事务保证三表的一致性
- */
- /* 临时需要一个生成订单的功能 */
- function create_sn()
- {
- $sn = date('YmdHis').rand(100,999);
- $sql = "select count(*) from order_info where order_sn = '$sn'";
- return $GLOBALS['db']->getOne($sql)?create_sn():$sn; //有这个单号就重生成一个
- }
- // ---------事务开始----------------------
- $db->query("start transaction");
- // 可用此方法插入 $db->autoExecute('表名',$data,'insert/update','条件')
- $order_sn = create_sn();
- $user_id = $_SESSION['user']['user_id'];
- $add_time = time();
- $goods_amount = $cart->getPrice();
- $sql = "insert into order_info (order_sn,user_id,goods_amount,add_time)
- VALUES ('$order_sn','$user_id','$goods_amount','$add_time')";
- $db->query($sql); // 执行插入订单SQL语句(order_info表)
- /* 操作order_goods表 */
- $order_id = $db->insert_id(); // 取得刚插入表的主键
- $cartlist = $cart->enumItems(); // 获得购物车商品的数组
- foreach ($cartlist as $k=>$v)
- {
- //查出商品的SN等信息加到购物车商品的数组中
- $sql = "select goods_id,goods_sn,goods_name,shop_price from goods where goods_id = '$k'";
- $cartlist[$k] = $cartlist[$k] + $db->getRow($sql);
- }
- /* 根据购物车里的商品,将所有要买的商品添加到order_goods表里,并更新goods表的库存 */
- $sqls=array();
- foreach ($cartlist as $k=>$v)
- {
- $goods_id = $k;
- $goods_name = $v['goods_name'];
- $goods_sn = $v['goods_sn'];
- $goods_number = $v['num'];
- $goods_price = $v['shop_price'] * $v['num'];
- $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')";
- $sqls[] = "update goods set goods_number = goods_number - '$goods_number' where goods_id = '$goods_id'";
- }
- //print_r($sqls);
- $res = true;
- foreach ($sqls as $sql)
- {
- $res = $res && $db->query($sql); //如果有一个SQL语句出错,$res就不为真
- }
- // ---------如果$res是真就提交事务,否则就回滚事务----------
- if(!$res)
- {
- $db->query('rollback');
- show_message('订单创建失败','返回购物车','flow.php?act=cartinfo');
- exit();
- }
- else
- {
- $db->query('commit');
- $smarty->assign('order_sn',$order_sn);
- $smarty->assign('order_amount',$cart->getPrice());
- $cart->emptyItems();
- $smarty->display('my_gwc3.html');
- }
- }
注意:MYSQL中只有INNODB和BDB类型的数据表才能支持事务处理,其他的类型是不支持的.
Tags: mysql事务回滚 mysql数据回滚
- 上一篇:几种MySQL备份常用方法整理
- 下一篇:mysqldump导出存储过程实例
相关文章
- ·mysql事务回滚使用与常见问题介绍(2014-10-08)
推荐文章
热门文章
最新评论文章
- 写给考虑创业的年轻程序员(10)
- PHP新手上路(一)(7)
- 惹恼程序员的十件事(5)
- PHP邮件发送例子,已测试成功(5)
- 致初学者:PHP比ASP优秀的七个理由(4)
- PHP会被淘汰吗?(4)
- PHP新手上路(四)(4)
- 如何去学习PHP?(2)
- 简单入门级php分页代码(2)
- php中邮箱email 电话等格式的验证(2)