Java操作數據庫(行級鎖,for update)
一、悲觀鎖(也叫行級鎖)
在本次事務的執行過程當中,我們指定的記錄被查詢,在我查詢的過程當中記錄就會被鎖定,任何人,任何事務都不能對我指定查詢數據進行修改操作(不能改,但是可以看),直到我都查詢結束。
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 { //創建驅動 //獲取數據庫對象 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,執行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 { //獲取驅動 //獲取數據庫鏈接對象 conn = JdbcUtil.getConnection(); //開啟事務 conn.setAutoCommit(false); //鎖開始後進行修改數據 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+"條數據"); 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當中:
在執行“select ... from ....whrer ...for update
”對,MySQL進行row lock
(行鎖) 還是 table lock(表鎖),取決於是否使用索引(如主鍵,unique字段),則為row lock(行鎖),否則為 table lock(表鎖),沒有查找到數據為無鎖,當使用“<>” 或者“like”時,索引會失效,進行 table lock(表鎖)。
簡單點來說就是for update
最好鎖 主鍵或者unique字段,鎖其他字段會導致整張表被鎖。導致性能的降低
到此這篇關於Java操作數據庫(行級鎖,for update)的文章就介紹到這瞭,更多相關Java操作數據庫內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!