mysql事务回滚数据回滚用法与问题
在当前事务中确实能看到插入的记录。最后只不过删除了。但是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 |
|
下面为存储过程的代码：
| 代码如下 | 复制代码 |
|
BEGIN INSERT INTO `mytest`.`test2` VALUES ( 1 ,’22′,’33′); IF t_error = 1 THEN END |
|
其中红色的代码为控制回滚的关键性代码！
上面只是mysql事物回滚了，下面我来介绍一个与php结合的实例
例子
| 代码如下 | 复制代码 |
|
|
|
例子：
/
| 代码如下 | 复制代码 |
| ** * 订单入库 * 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类型的数据表才能支持事务处理！其他的类型是不支持的！
