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

2024-07-24 12:37:14

字體：大中小

來源：轉載

供稿：網友

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 {    //Vevb.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');

}

}