oracle嗎?查看這個(gè)Java登錄的session的用戶,用這個(gè)用戶登錄sqlplus再執(zhí)行上面的語(yǔ)句看,java.util.NoSuchElementException應(yīng)該是權(quán)限問(wèn)題,沒(méi)法訪問(wèn)這些表,相當(dāng)于當(dāng)前用戶的schema下沒(méi)有這些表
創(chuàng)新互聯(lián)致力于互聯(lián)網(wǎng)網(wǎng)站建設(shè)與網(wǎng)站營(yíng)銷,提供做網(wǎng)站、網(wǎng)站建設(shè)、網(wǎng)站開(kāi)發(fā)、seo優(yōu)化、網(wǎng)站排名、互聯(lián)網(wǎng)營(yíng)銷、微信小程序、公眾號(hào)商城、等建站開(kāi)發(fā),創(chuàng)新互聯(lián)網(wǎng)站建設(shè)策劃專家,為不同類型的客戶提供良好的互聯(lián)網(wǎng)應(yīng)用定制解決方案,幫助客戶在新的全球化互聯(lián)網(wǎng)環(huán)境中保持優(yōu)勢(shì)。
下面通過(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)有更好的方法。
數(shù)據(jù)庫(kù)是 oracle?
直接select * from 表 where id='xxxx' for update
然后程序里面不commit 就鎖了這條數(shù)據(jù)了
當(dāng)然可行.我不知道你的理解是在什么地方切入的.但是這個(gè)問(wèn)題不太需要涉及到JDBC也就是數(shù)據(jù)庫(kù)的讀寫(xiě)的內(nèi)容.
實(shí)際上的理解你應(yīng)該緊扣住"實(shí)體"這個(gè)關(guān)鍵點(diǎn).JDBC只不過(guò)是達(dá)到目的的一個(gè)手段,實(shí)體Bean作為參數(shù)在不同的類之間傳遞才是關(guān)鍵.
我們舉個(gè)例子,這個(gè)bank表簡(jiǎn)單的具有:ID, bank_name, address 這3個(gè)屬性.而實(shí)際的項(xiàng)目中,往往一張表能有十幾個(gè)字段甚至更多.
一開(kāi)始的時(shí)候,程序員們都是這樣來(lái)讀取數(shù)據(jù)庫(kù): 例如這張bank表,從數(shù)據(jù)庫(kù)把某一個(gè)ID=1的記錄讀出來(lái)以后,直接把3個(gè)字段值返回給調(diào)用該數(shù)據(jù)庫(kù)類的方法(例如可以采用封裝到一個(gè)數(shù)組中去的方法).這樣當(dāng)字段變多以后會(huì)變得非常的麻煩, 例如,很可能一不小心把返回的字段給弄顛倒了.
后來(lái)這樣的方法進(jìn)過(guò)改進(jìn),就成了現(xiàn)在的以實(shí)體類封裝數(shù)據(jù)并進(jìn)行傳遞的方式.例如一張訂單表:你盡管可能覺(jué)得order_date和order_data這2個(gè)字段非常容易混淆.但是如果date是日期類型,data是String類型,那么你怎么也不可能把這2個(gè)值賦予給錯(cuò)誤的屬性.
那么在使用中,首先,你讀出了數(shù)據(jù)之后,我們?cè)倌胋ank表作例子,ID=1的表里的數(shù)據(jù)如下:ID=1,name=abc,address=nanjing,那么你實(shí)例化一個(gè)bank類,然后把這3個(gè)值一一 賦予對(duì)應(yīng)的屬性(調(diào)用set方法)
而在將這個(gè)實(shí)體類返回調(diào)用者之后,可以調(diào)用get方法來(lái)查看.
如果需要看具體的代碼的話可以繼續(xù)追問(wèn)
可能是之前對(duì)該表執(zhí)行的事務(wù)未完成,導(dǎo)致有鎖,所以用sql又查不出來(lái),但是java代碼能查出來(lái)有一條數(shù)據(jù)。建議先在數(shù)據(jù)庫(kù)中查詢是否有未完成的事務(wù)及是否有鎖,如果有,先commit,提交,確保表沒(méi)鎖,這樣java查出來(lái)就正常了。
方法1:用mysql命令鎖住表.
public?void?test()?{??
String?sql?=?"lock?tables?aa1?write";??
//?或String?sql?=?"lock?tables?aa1?read";???
//?如果想鎖多個(gè)表?lock?tables?aa1?read?,aa2?write?,?.....???
String?sql1?=?"select?*?from?aa1?";??
String?sql2?=?"unlock?tables";??
try?{??
this.pstmt?=?conn.prepareStatement(sql);??
this.pstmt1?=?conn.prepareStatement(sql1);??
this.pstmt2?=?conn.prepareStatement(sql2);??
pstmt.executeQuery();??
pstmt1.executeQuery();??
pstmt2.executeQuery();??
}?catch?(Exception?e)?{??
System.out.println("異常"?+?e.getMessage());??
}??
}
對(duì)于read lock 和 write lock官方說(shuō)明:
1.如果一個(gè)線程獲得一個(gè)表的READ鎖定,該線程(和所有其它線程)只能從該表中讀取。
如果一個(gè)線程獲得一個(gè)表的WRITE鎖定,只有保持鎖定的線程可以對(duì)表進(jìn)行寫(xiě)入。
其它的線程被阻止,直到鎖定被釋放時(shí)為止。
2.當(dāng)您使用LOCK TABLES時(shí),您必須鎖定您打算在查詢中使用的所有的表。
雖然使用LOCKTABLES語(yǔ)句獲得的鎖定仍然有效,但是您不能訪問(wèn)沒(méi)有被此語(yǔ)句鎖定的任何的表。
同時(shí),您不能在一次查詢中多次使用一個(gè)已鎖定的表——使用別名代替,
在此情況下,您必須分別獲得對(duì)每個(gè)別名的鎖定。
對(duì)與read lock 和 write lock個(gè)人說(shuō)明:
1.read lock 和 write lock 是線程級(jí)(表級(jí)別).
2.在同一個(gè)會(huì)話中加了read lock鎖. 只能對(duì)這個(gè)表進(jìn)行讀操作.對(duì)這個(gè)表以外的任何表都無(wú)法進(jìn)行增、刪、改、查的操作.
但是在不同會(huì)話中,只能對(duì)加了read lock的表進(jìn)行讀操作.但可以對(duì)read lock以外的表進(jìn)行增、刪、改、查的操作.
3.在同一個(gè)會(huì)話中加了write lock鎖.只能對(duì)這個(gè)表進(jìn)行讀、寫(xiě)操作.對(duì)這個(gè)表以外的任何表都無(wú)法進(jìn)行增、刪、改、查的操作.
但是在不同會(huì)話中,無(wú)法對(duì)加了write lock的表進(jìn)行讀、寫(xiě)操作.但可以對(duì)write lock以外的表進(jìn)行增、刪、改、查的操作.
4.如果表中使用了別名.(SELECT * FROM aa1 AS byname_table)
在對(duì)aa1加鎖時(shí),必須把別名加上去(lock tables aa1 as byname_table read)
在同一個(gè)會(huì)話中.必須使用別名進(jìn)行查詢.
在不同的會(huì)話中.可以不需要使用別名進(jìn)行查詢.
5.在多個(gè)會(huì)話中可以對(duì)同一個(gè)表進(jìn)行l(wèi)ock read操作.但不能在多個(gè)會(huì)話中對(duì)同一個(gè)表進(jìn)行l(wèi)ock write操作(這些鎖將等待已鎖的表釋放自身的線程鎖)
如果多個(gè)會(huì)話對(duì)同一個(gè)表進(jìn)行l(wèi)ock read操作.那么在這些會(huì)話中,也只能對(duì)以鎖的表進(jìn)行讀操作.
6.如果要你鎖住了一個(gè)表,需要嵌套查詢.你必須使用別名,并且,要鎖定別名.
例如.lock table aa1 read ,aa1 as byname_table read;
select * from aa1 where id in (select * from aa1 as xx??where id=2);
7.解鎖必須用unlock tables;
另:
在JAVA程序中,要想解鎖,需要調(diào)用 unlock tables來(lái)解鎖.
如果沒(méi)有調(diào)用unlock tables.
關(guān)閉connection 、程序結(jié)束 、調(diào)用GC 都能解鎖.
方法2:用記錄鎖鎖表.
public?void?test()?{??
String?sql?=?"select?*?from?aa1?for?update";???
//?select?*?from?aa1?lock?in?share?mode;???
try?{??
conn.setAutoCommit(false);??
this.pstmt?=?conn.prepareStatement(sql);??
pstmt.executeQuery();??
}?catch?(Exception?e)?{??
System.out.println("異常"?+?e.getMessage());??
}??
}
1.for update 與 lock in share mode 屬于行級(jí)鎖和頁(yè)級(jí)鎖
2.for update 排它鎖,lock in share mode 共享鎖
3.對(duì)于記錄鎖.必須開(kāi)啟事務(wù).
4.行級(jí)鎖定事實(shí)上是索引記錄的鎖定.只要是用索引掃描的行(或沒(méi)索引全表掃描的行),都將被鎖住.
5.在不同的隔離級(jí)別下還會(huì)使用next-key locking算法.即所掃描的行之間的“間隙”也會(huì)也鎖住(在Repeatable read和Serializable隔離級(jí)別下有間隙鎖).
6.在mysql中共享鎖的含義是:在被共享鎖鎖住的行,即使內(nèi)容被修改且并沒(méi)有提交.在另一個(gè)會(huì)話中依然看到最新修改的信息.
在同一會(huì)話中加上了共享鎖.可以對(duì)這個(gè)表以及這個(gè)表以外的所有表進(jìn)行增、刪、改、查的操作.
在不同的會(huì)話中.可以查到共享鎖鎖住行的最新消息.但是在Read Uncommitted隔離級(jí)別下不能對(duì)鎖住的表進(jìn)行刪,
改操作.(需要等待鎖釋放才能操作...)
在Read Committed隔離級(jí)別下不能對(duì)鎖住的表進(jìn)行刪,改操作.(需要等待鎖釋放才能操作...)
在Repeatable read隔離級(jí)別下不能對(duì)鎖住行進(jìn)行增、刪、改操作.(需要等待鎖釋放才能操作...)
在Serializable隔離級(jí)別下不能對(duì)鎖住行進(jìn)行增、刪、改操作.??(需要等待鎖釋放才能操作...)
7.在mysql中排他鎖的含義是:在被排它鎖鎖住的行,內(nèi)容修改并沒(méi)提交,在另一個(gè)會(huì)話中不會(huì)看到最新修改的信息。
在不同的會(huì)話中.可以查到共享鎖鎖住行的最新消息.但是Read Uncommitted隔離級(jí)別下不能對(duì)鎖住的表進(jìn)行刪,
改操作.(需要等待鎖釋放才能操作...)
在Read Committed隔離級(jí)別下不能對(duì)鎖住的表進(jìn)行刪,改操作.(需要等待鎖釋放才能操作...)
在Repeatable read隔離級(jí)別下不能對(duì)鎖住行進(jìn)行增、刪、改操作.(需要等待鎖釋放才能操作...)
在Serializable隔離級(jí)別下不能對(duì)鎖住行進(jìn)行增、刪、改操作. (需要等待鎖釋放才能操作...)
8.在同一個(gè)會(huì)話中的可以疊加多個(gè)共享鎖和排他鎖.在多個(gè)會(huì)話中,需要等待鎖的釋放.
9.SQL中的update 與 for update是一樣的原理.
10.等待超時(shí)的參數(shù)設(shè)置:innodb_lock_wait_timeout=50 (單位秒).
11.任何可以觸發(fā)事務(wù)提交的命令,都可以關(guān)閉共享鎖和排它鎖.