日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 运维知识 > 数据库 >内容正文

数据库

mysql乐观锁总结和实践--转

發布時間:2025/4/5 数据库 28 豆豆
生活随笔 收集整理的這篇文章主要介紹了 mysql乐观锁总结和实践--转 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

原文地址:http://chenzhou123520.iteye.com/blog/1863407

上一篇文章《MySQL悲觀鎖總結和實踐》談到了MySQL悲觀鎖,但是悲觀鎖并不是適用于任何場景,它也有它存在的一些不足,因為悲觀鎖大多數情況下依靠數據庫的鎖機制實現,以保證操作最大程度的獨占性。如果加鎖的時間過長,其他用戶長時間無法訪問,影響了程序的并發訪問性,同時這樣對數據庫性能開銷影響也很大,特別是對長事務而言,這樣的開銷往往無法承受。所以與悲觀鎖相對的,我們有了樂觀鎖,具體參見下面介紹:

?

樂觀鎖介紹:

樂觀鎖( Optimistic Locking ) 相對悲觀鎖而言,樂觀鎖假設認為數據一般情況下不會造成沖突,所以在數據進行提交更新的時候,才會正式對數據的沖突與否進行檢測,如果發現沖突了,則讓返回用戶錯誤的信息,讓用戶決定如何去做。那么我們如何實現樂觀鎖呢,一般來說有以下2種方式:

1.使用數據版本(Version)記錄機制實現,這是樂觀鎖最常用的一種實現方式。何謂數據版本?即為數據增加一個版本標識,一般是通過為數據庫表增加一個數字類型的 “version” 字段來實現。當讀取數據時,將version字段的值一同讀出,數據每更新一次,對此version值加一。當我們提交更新的時候,判斷數據庫表對應記錄的當前版本信息與第一次取出來的version值進行比對,如果數據庫表當前版本號與第一次取出來的version值相等,則予以更新,否則認為是過期數據。用下面的一張圖來說明:

如上圖所示,如果更新操作順序執行,則數據的版本(version)依次遞增,不會產生沖突。但是如果發生有不同的業務操作對同一版本的數據進行修改,那么,先提交的操作(圖中B)會把數據version更新為2,當A在B之后提交更新時發現數據的version已經被修改了,那么A的更新操作會失敗。

?

2.樂觀鎖定的第二種實現方式和第一種差不多,同樣是在需要樂觀鎖控制的table中增加一個字段,名稱無所謂,字段類型使用時間戳(timestamp), 和上面的version類似,也是在更新提交的時候檢查當前數據庫中數據的時間戳和自己更新前取到的時間戳進行對比,如果一致則OK,否則就是版本沖突。

?

使用舉例:以MySQL InnoDB為例

還是拿之前的實例來舉:商品goods表中有一個字段status,status為1代表商品未被下單,status為2代表商品已經被下單,那么我們對某個商品下單時必須確保該商品status為1。假設商品的id為1。

?

下單操作包括3步驟:

1.查詢出商品信息

select (status,status,version) from t_goods where id=#{id}

2.根據商品信息生成訂單

3.修改商品status為2

update t_goods?

set status=2,version=version+1

where id=#{id}?and version=#{version};

?

那么為了使用樂觀鎖,我們首先修改t_goods表,增加一個version字段,數據默認version值為1。

t_goods表初始數據如下:

Sql代碼??
  • mysql>?select?*?from?t_goods;??
  • +----+--------+------+---------+??
  • |?id?|?status?|?name?|?version?|??
  • +----+--------+------+---------+??
  • |??1?|??????1?|?道具?|???????1?|??
  • |??2?|??????2?|?裝備?|???????2?|??
  • +----+--------+------+---------+??
  • 2?rows?in?set??
  • ??
  • mysql>??
  • 對于樂觀鎖的實現,我使用MyBatis來進行實踐,具體如下:

    Goods實體類:

    Java代碼??
  • /**?
  • ?*?ClassName:?Goods?<br/>?
  • ?*?Function:?商品實體.?<br/>?
  • ?*?date:?2013-5-8?上午09:16:19?<br/>?
  • ?*?@author?chenzhou1025@126.com?
  • ?*/??
  • public?class?Goods?implements?Serializable?{??
  • ??
  • ????/**?
  • ?????*?serialVersionUID:序列化ID.?
  • ?????*/??
  • ????private?static?final?long?serialVersionUID?=?6803791908148880587L;??
  • ??????
  • ????/**?
  • ?????*?id:主鍵id.?
  • ?????*/??
  • ????private?int?id;??
  • ??????
  • ????/**?
  • ?????*?status:商品狀態:1未下單、2已下單.?
  • ?????*/??
  • ????private?int?status;??
  • ??????
  • ????/**?
  • ?????*?name:商品名稱.?
  • ?????*/??
  • ????private?String?name;??
  • ??????
  • ????/**?
  • ?????*?version:商品數據版本號.?
  • ?????*/??
  • ????private?int?version;??
  • ??????
  • ????@Override??
  • ????public?String?toString(){??
  • ????????return?"good?id:"+id+",goods?status:"+status+",goods?name:"+name+",goods?version:"+version;??
  • ????}??
  • ??
  • ????//setter?and?getter??
  • ??
  • }??
  • GoodsDao

    Java代碼??
  • /**?
  • ?*?updateGoodsUseCAS:使用CAS(Compare?and?set)更新商品信息.?<br/>?
  • ?*?
  • ?*?@author?chenzhou1025@126.com?
  • ?*?@param?goods?商品對象?
  • ?*?@return?影響的行數?
  • ?*/??
  • int?updateGoodsUseCAS(Goods?goods);??
  • mapper.xml

    Xml代碼??
  • <update?id="updateGoodsUseCAS"?parameterType="Goods">??
  • ????<![CDATA[?
  • ????????update?t_goods?
  • ????????set?status=#{status},name=#{name},version=version+1?
  • ????????where?id=#{id}?and?version=#{version}?
  • ????]]>??
  • </update>??
  • GoodsDaoTest測試類

    Java代碼??
  • @Test??
  • public?void?goodsDaoTest(){??
  • ????int?goodsId?=?1;??
  • ????//根據相同的id查詢出商品信息,賦給2個對象??
  • ????Goods?goods1?=?this.goodsDao.getGoodsById(goodsId);??
  • ????Goods?goods2?=?this.goodsDao.getGoodsById(goodsId);??
  • ??????
  • ????//打印當前商品信息??
  • ????System.out.println(goods1);??
  • ????System.out.println(goods2);??
  • ??????
  • ????//更新商品信息1??
  • ????goods1.setStatus(2);//修改status為2??
  • ????int?updateResult1?=?this.goodsDao.updateGoodsUseCAS(goods1);??
  • ????System.out.println("修改商品信息1"+(updateResult1==1?"成功":"失敗"));??
  • ??????
  • ????//更新商品信息2??
  • ????goods1.setStatus(2);//修改status為2??
  • ????int?updateResult2?=?this.goodsDao.updateGoodsUseCAS(goods1);??
  • ????System.out.println("修改商品信息2"+(updateResult2==1?"成功":"失敗"));??
  • }??
  • 輸出結果:

    Shell代碼??
  • good?id:1,goods?status:1,goods?name:道具,goods?version:1??
  • good?id:1,goods?status:1,goods?name:道具,goods?version:1??
  • 修改商品信息1成功??
  • 修改商品信息2失敗??
  • 說明:

    在GoodsDaoTest測試方法中,我們同時查出同一個版本的數據,賦給不同的goods對象,然后先修改good1對象然后執行更新操作,執行成功。然后我們修改goods2,執行更新操作時提示操作失敗。此時t_goods表中數據如下:

    Sql代碼??
  • mysql>?select?*?from?t_goods;??
  • +----+--------+------+---------+??
  • |?id?|?status?|?name?|?version?|??
  • +----+--------+------+---------+??
  • |??1?|??????2?|?道具?|???????2?|??
  • |??2?|??????2?|?裝備?|???????2?|??
  • +----+--------+------+---------+??
  • 2?rows?in?set??
  • ??
  • mysql>???
  • 我們可以看到 id為1的數據version已經在第一次更新時修改為2了。所以我們更新good2時update where條件已經不匹配了,所以更新不會成功,具體sql如下:

    Sql代碼??
  • update?t_goods???
  • set?status=2,version=version+1??
  • where?id=#{id}?and?version=#{version};??
  • 這樣我們就實現了樂觀鎖

    ?

    以上就是我對MySQL樂觀鎖的總結和實踐,寫得比較淺顯,有不對的地方歡迎拍磚

    轉載于:https://www.cnblogs.com/davidwang456/p/6030095.html

    總結

    以上是生活随笔為你收集整理的mysql乐观锁总结和实践--转的全部內容,希望文章能夠幫你解決所遇到的問題。

    如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。