mysql更新怎么加行鎖 mysql中如何更新數(shù)據(jù)

MySQL - for update 行鎖 表鎖

for update 的作用是在查詢的時(shí)候?yàn)樾屑由吓潘i,當(dāng)一個(gè)事務(wù)的操作未完成時(shí)候,其他事務(wù)可以讀取但是不能寫(xiě)入或更新。

創(chuàng)新互聯(lián)公司制作網(wǎng)站網(wǎng)頁(yè)找三站合一網(wǎng)站制作公司,專注于網(wǎng)頁(yè)設(shè)計(jì),網(wǎng)站設(shè)計(jì)制作、做網(wǎng)站,網(wǎng)站設(shè)計(jì),企業(yè)網(wǎng)站搭建,網(wǎng)站開(kāi)發(fā),建網(wǎng)站業(yè)務(wù),680元做網(wǎng)站,已為上1000家服務(wù),創(chuàng)新互聯(lián)公司網(wǎng)站建設(shè)將一如既往的為我們的客戶提供最優(yōu)質(zhì)的網(wǎng)站建設(shè)、網(wǎng)絡(luò)營(yíng)銷(xiāo)推廣服務(wù)!

它的典型使用場(chǎng)景是 高并發(fā)并且對(duì)于數(shù)據(jù)的準(zhǔn)確性有很高要求 ,比如金錢(qián)、庫(kù)存等,一般這種操作都是很長(zhǎng)一串并且開(kāi)啟事務(wù)的,假如現(xiàn)在要對(duì)庫(kù)存進(jìn)行操作,在剛開(kāi)始讀的時(shí)候是1,然后馬上另外一個(gè)進(jìn)程將庫(kù)存更新為0了,但事務(wù)還沒(méi)結(jié)束,會(huì)一直用1進(jìn)行后續(xù)的邏輯,就會(huì)有問(wèn)題,所以需要用for upate 加鎖防止出錯(cuò)。

行鎖的具體實(shí)現(xiàn)算法有三種:record lock、gap lock以及next-key lock。

只在可重復(fù)讀或以上隔離級(jí)別下的特定操作才會(huì)取得 gap lock 或 next-key lock,在 Select、Update 和 Delete 時(shí),除了基于唯一索引的查詢之外,其它索引查詢時(shí)都會(huì)獲取 gap lock 或 next-key lock,即鎖住其掃描的范圍。主鍵索引也屬于唯一索引,所以主鍵索引是不會(huì)使用 gap lock 或 next-key lock

for update 僅適用于InnoDB,并且必須開(kāi)啟事務(wù),在begin與commit之間才生效。

select 語(yǔ)句默認(rèn)不獲取任何鎖,所以是可以讀被其它事務(wù)持有排它鎖的數(shù)據(jù)的!

InnoDB 既實(shí)現(xiàn)了行鎖,也實(shí)現(xiàn)了表鎖。

當(dāng)有明確指定的主鍵/索引時(shí)候,是行級(jí)鎖,否則是表級(jí)鎖

假設(shè)表 user,存在有id跟name字段,id是主鍵,有5條數(shù)據(jù)。

明確指定主鍵,并且有此記錄,行級(jí)鎖

無(wú)主鍵/索引,表級(jí)鎖

主鍵/索引不明確,表級(jí)鎖

明確指定主鍵/索引,若查無(wú)此記錄,無(wú)鎖

參考博文:

mysql的行級(jí)鎖加在哪個(gè)位置

以下五種方法可以快速定位全局鎖的位置,僅供參考。

方法1:利用 metadata_locks 視圖

此方法僅適用于 MySQL 5.7 以上版本,該版本 performance_schema 新增了 metadata_locks,如果上鎖前啟用了元數(shù)據(jù)鎖的探針(默認(rèn)是未啟用的),可以比較容易的定位全局鎖會(huì)話。

方法2:利用 events_statements_history 視圖此方法適用于 MySQL 5.6 以上版本,啟用 performance_schema.eventsstatements_history(5.6 默認(rèn)未啟用,5.7 默認(rèn)啟用),該表會(huì) SQL 歷史記錄執(zhí)行,如果請(qǐng)求太多,會(huì)自動(dòng)清理早期的信息,有可能將上鎖會(huì)話的信息清理掉。

方法3:利用 gdb 工具如果上述兩種都用不了或者沒(méi)來(lái)得及啟用,可以嘗試第三種方法。利用 gdb 找到所有線程信息,查看每個(gè)線程中持有全局鎖對(duì)象,輸出對(duì)應(yīng)的會(huì)話 ID,為了便于快速定位,我寫(xiě)成了腳本形式。也可以使用 gdb 交互模式,但 attach mysql 進(jìn)程后 mysql 會(huì)完全 hang 住,讀請(qǐng)求也會(huì)受到影響,不建議使用交互模式。

方法4:show processlist

如果備份程序使用的特定用戶執(zhí)行備份,如果是 root 用戶備份,那 time 值越大的是持鎖會(huì)話的概率越大,如果業(yè)務(wù)也用 root 訪問(wèn),重點(diǎn)是 state 和 info 為空的,這里有個(gè)小技巧可以快速篩選,篩選后嘗試 kill 對(duì)應(yīng) ID,再觀察是否還有 wait global read lock 狀態(tài)的會(huì)話。

方法5:重啟試試!

mysql 的鎖以及間隙鎖

mysql 為并發(fā)事務(wù)同時(shí)對(duì)一條記錄進(jìn)行讀寫(xiě)時(shí),提出了兩種解決方案:

1)使用 mvcc 的方法,實(shí)現(xiàn)多事務(wù)的并發(fā)讀寫(xiě),但是這種讀只是“快照讀”,一般讀的是歷史版本數(shù)據(jù),還有一種是“當(dāng)前讀”,一般加鎖實(shí)現(xiàn)“當(dāng)前讀”,或者 insert、update、delete 也是當(dāng)前讀。

2)使用加鎖的方法,鎖分為共享鎖(讀鎖),排他鎖(寫(xiě)鎖)

快照讀:就是select

當(dāng)前讀:特殊的讀操作,插入/更新/刪除操作,屬于當(dāng)前讀,處理的都是當(dāng)前的數(shù)據(jù),需要加鎖。

mysql 在 RR 級(jí)別怎么處理幻讀的呢?一般來(lái)說(shuō),RR 級(jí)別通過(guò) mvcc 機(jī)制,保證讀到低于后面事務(wù)的數(shù)據(jù)。但是 select for update 不會(huì)觸發(fā) mvcc,它是當(dāng)前讀。如果后面事務(wù)插入數(shù)據(jù)并提交,那么在 RR 級(jí)別就會(huì)讀到插入的數(shù)據(jù)。所以,mysql 使用 行鎖 + gap 鎖(簡(jiǎn)稱 next-key 鎖)來(lái)防止當(dāng)前讀的時(shí)候插入。

Gap Lock在InnoDB的唯一作用就是防止其他事務(wù)的插入操作,以此防止幻讀的發(fā)生。

Innodb自動(dòng)使用間隙鎖的條件:

Java如何實(shí)現(xiàn)對(duì)Mysql數(shù)據(jù)庫(kù)的行鎖

下面通過(guò)一個(gè)例子來(lái)說(shuō)明

場(chǎng)景如下:

用戶賬戶有余額,當(dāng)發(fā)生交易時(shí),需要實(shí)時(shí)更新余額。這里如果發(fā)生并發(fā)問(wèn)題,那么會(huì)造成用戶余額和實(shí)際交易的不一致,這對(duì)公司和客戶來(lái)說(shuō)都是很危險(xiǎn)的。

那么如何避免:

網(wǎng)上查了下,有以下兩種方法:

1、使用悲觀鎖

當(dāng)需要變更余額時(shí),通過(guò)代碼在事務(wù)中對(duì)當(dāng)前需要更新的記錄設(shè)置for update行鎖,然后開(kāi)始正常的查詢和更新操作

這樣,其他的事務(wù)只能等待該事務(wù)完成后方可操作

當(dāng)然要特別注意,如果使用了Spring的事務(wù)注解,需要配置一下:

!-- (事務(wù)管理)transaction manager, use JtaTransactionManager for global tx --

bean id="transactionManager"

class="org.springframework.jdbc.datasource.DataSourceTransactionManager"

property name="dataSource" ref="dataSource" /

/bean

!-- 使用annotation定義事務(wù) --

tx:annotation-driven transaction-manager="transactionManager" /

在指定代碼處添加事務(wù)注解

@Transactional

@Override

public boolean increaseBalanceByLock(Long userId, BigDecimal amount)

throws ValidateException {

long time = System.currentTimeMillis();

//獲取對(duì)記錄的鎖定

UserBalance balance = userBalanceDao.getLock(userId);

LOGGER.info("[lock] start. time: {}", time);

if (null == balance) {

throw new ValidateException(

ValidateErrorCode.ERRORCODE_BALANCE_NOTEXIST,

"user balance is not exist");

}

boolean result = userBalanceDao.increaseBalanceByLock(balance, amount);

long timeEnd = System.currentTimeMillis();

LOGGER.info("[lock] end. time: {}", timeEnd);

return result;

}

MyBatis中的鎖定方式,實(shí)際測(cè)試該方法確實(shí)可以有效控制,不過(guò)在大并發(fā)量的情況下,可能會(huì)有性能問(wèn)題吧

select id="getLock" resultMap="BaseResultMap" parameterType="java.lang.Long"

![CDATA[

select * from user_balance where id=#{id,jdbcType=BIGINT} for update;

]]

/select

2、使用樂(lè)觀鎖

這個(gè)方法也同樣可以解決場(chǎng)景中描述的問(wèn)題(我認(rèn)為比較適合并不頻繁的操作):

設(shè)計(jì)表的時(shí)候增加一個(gè)version(版本控制字段),每次需要更新余額的時(shí)候,先獲取對(duì)象,update的時(shí)候根據(jù)version和id為條件去更新,如果更新回來(lái)的數(shù)量為0,說(shuō)明version已經(jīng)變更

需要重復(fù)一次更新操作,如下:sql腳本

update user_balance set Balance = #{balance,jdbcType=DECIMAL},Version = Version+1 where Id = #{id,jdbcType=BIGINT} and Version = #{version,jdbcType=BIGINT}

這是一種不使用數(shù)據(jù)庫(kù)鎖的方法,解決方式也很巧妙。當(dāng)然,在大量并發(fā)的情況下,一次扣款需要重復(fù)多次的操作才能成功,還是有不足之處的。不知道還有沒(méi)有更好的方法。

當(dāng)前題目:mysql更新怎么加行鎖 mysql中如何更新數(shù)據(jù)
當(dāng)前網(wǎng)址:http://bm7419.com/article28/dohjejp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站制作、網(wǎng)站收錄、自適應(yīng)網(wǎng)站、品牌網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、企業(yè)網(wǎng)站制作

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)

成都網(wǎng)頁(yè)設(shè)計(jì)公司