mysql事務回滾數據回滾用法與問題

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 {  
     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類型的數據表才能支持事務處理！其他的類型是不支持的！