Java操作數(shù)據(jù)庫(行級鎖,for update)
一、悲觀鎖(也叫行級鎖)
在本次事務的執(zhí)行過程當中,我們指定的記錄被查詢,在我查詢的過程當中記錄就會被鎖定,任何人,任何事務都不能對我指定查詢數(shù)據(jù)進行修改操作(不能改,但是可以看),直到我都查詢結束。
1.使用悲觀鎖(在事務中的sql語句中使用)
//sql指令
String sql = "select * from t_shuihuo where id < ? for update ";
2..完整代碼
package com.luosf.jdbc;
import com.luosf.jdbc.utils.JdbcUtil;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
* JDBC中鎖的使用
* for updata
*/
public class JdbcLock {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement stat = null;
ResultSet res = null;
try {
//創(chuàng)建驅(qū)動
//獲取數(shù)據(jù)庫對象
conn = JdbcUtil.getConnection();
//sql指令
String sql = "select * from t_shuihuo where id < ? for update ";
conn.setAutoCommit(false);//開啟事務
//3,sql語句進行編譯
stat = conn.prepareStatement(sql);
//給占位符填充值
//JDBC下標從1開始的
stat.setInt(1,16); //1,代表第一個問號
Thread.sleep(1000*10); //模擬訪問時間
//4,執(zhí)行sql
res = stat.executeQuery();
//5,處理查詢結果集
while (res.next()){
int id = res.getInt("id");
String name = res.getString("name");
String nickname = res.getString("nickname");
System.out.println("id :"+ id + " name :" +name + " 昵稱 :"+nickname);
}
conn.commit();//提交事務
} catch (SQLException throwables) {
try {
if (conn != null){
conn.rollback(); //回滾事務
}
} catch (SQLException e) {
e.printStackTrace();
}
throwables.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
} finally{
//釋放資源
JdbcUtil.close(conn,stat,res);
}
}
}
3..測試代碼
package com.luosf.jdbc;
import com.luosf.jdbc.utils.JdbcUtil;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
/**
* 檢測鎖
*/
public class JdbcLockTest {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement stat = null;
try {
//獲取驅(qū)動
//獲取數(shù)據(jù)庫鏈接對象
conn = JdbcUtil.getConnection();
//開啟事務
conn.setAutoCommit(false);
//鎖開始后進行修改數(shù)據(jù)
String sql = "update t_shuihuo set name = '小羅' where id = ? ";
stat = conn.prepareStatement(sql);
stat.setInt(1,10); //1,代表第一個問號
int cunt = stat.executeUpdate();
System.out.println("更新了"+cunt+"條數(shù)據(jù)");
conn.commit();//提交事務
} catch (SQLException throwables) {
try {
if (conn != null){
conn.rollback();
}
} catch (SQLException e) {
e.printStackTrace();
}
throwables.printStackTrace();
} finally {
//釋放資源
JdbcUtil.close(conn,stat,null);
}
}
}
需要等鎖等待時間完成才能進行修改

4.結論
在MySQL當中:
在執(zhí)行“select ... from ....whrer ...for update ”對,MySQL進行row lock(行鎖) 還是 table lock(表鎖),取決于是否使用索引(如主鍵,unique字段),則為row lock(行鎖),否則為 table lock(表鎖),沒有查找到數(shù)據(jù)為無鎖,當使用“<>” 或者“l(fā)ike”時,索引會失效,進行 table lock(表鎖)。
簡單點來說就是for update最好鎖 主鍵或者unique字段,鎖其他字段會導致整張表被鎖。導致性能的降低
到此這篇關于Java操作數(shù)據(jù)庫(行級鎖,for update)的文章就介紹到這了,更多相關Java操作數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
spring boot 自定義starter的實現(xiàn)教程
下面小編就為大家分享一篇spring boot 自定義starter的實現(xiàn)教程,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2017-12-12
Mybatis?Plus?新版lambda?表達式查詢異常的處理
這篇文章主要介紹了Mybatis?Plus?新版lambda?表達式查詢異常的處理方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-01-01
Servlet+JDBC實現(xiàn)登陸功能的小例子(帶驗證碼)
這篇文章主要介紹了Servlet+JDBC實現(xiàn)登陸功能的小例子(帶驗證碼),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-06-06

