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

数据库

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

2019/10/10/17:36:30 阅读：2352 来源：谷歌SEO算法标签： SEO知识

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

修改表类型,代码如下:

ALTERTABLE`goods`ENGINE=InnoDB;engine
ALTERTABLE`goods`ENGINE=MYISAM
showcreatetablegoodsG

下面为存储过程的代码:

BEGIN
DECLAREt_errorINTEGERDEFAULT0;
DECLARECONTINUEHANDLERFORSQLEXCEPTIONSETt_error=1;
#setautocommit=0;
STARTTRANSACTION;
INSERTINTO`mytest`.`test2`VALUES(1,’22′,’33′);
INSERTINTO`mytest`.`test2`VALUES(NULL,’22′,’33′);
IFt_error=1THEN
ROLLBACK;
ELSE
COMMIT;
ENDIF;
END

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

$lnk=mysql_connect("localhost","root","");
mysql_select_db("test");
mysql_query("BEGIN");
$query=mysql_query("INSERTINTOtestVALUES(1,'yangjun')");
$q1=mysql_error();
mysql_query("INSERTINTOtestVALUES(1,'yangjun')");
$q2=mysql_error();
mysql_query("INSERTINTOtestVALUES(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，用事务保证三表的一致性
*/
/*临时需要一个生成订单的功能*/
functioncreate_sn()
{
$sn=date('YmdHis').rand(100,999);
$sql="selectcount(*)fromorder_infowhereorder_sn='$sn'";
return$GLOBALS['db']->getOne($sql)?create_sn():$sn;//有这个单号就重生成一个
}
//---------事务开始----------------------
$db->query("starttransaction");
//可用此方法插入$db->autoExecute('表名',$data,'insert/update','条件')
$order_sn=create_sn();
$user_id=$_SESSION['user']['user_id'];
$add_time=time();
$goods_amount=$cart->getPrice();
$sql="insertintoorder_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($cartlistas$k=>$v)
{
//查出商品的SN等信息加到购物车商品的数组中
$sql="selectgoods_id,goods_sn,goods_name,shop_pricefromgoodswheregoods_id='$k'";
$cartlist[$k]=$cartlist[$k]+$db->getRow($sql);
}
/*根据购物车里的商品，将所有要买的商品添加到order_goods表里，并更新goods表的库存*/
$sqls=array();
foreach($cartlistas$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[]="insertintoorder_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[]="updategoodssetgoods_number=goods_number-'$goods_number'wheregoods_id='$goods_id'";
}
//print_r($sqls);
$res=true;
foreach($sqlsas$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类型的数据表才能支持事务处理,其他的类型是不支持的.

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

广告内容

相关阅读

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

热门评论

精选文章

精彩广告