如果需要保证数据访问的排它性,则需对目标数据加“锁”,使其无法被其它程序修改

一,悲观锁

对数据被外界(包括本系统当前的其它事务和来自外部系统的事务处理)修改持保守态度,通过数据库提供的锁机制实现

最常用的,是对查询进行加锁(LockMode.UPGRADE和LockMode.UPGRADE_NOWAIT):

public class Test {public static void main(String[] args) {Configuration conf = new Configuration();  SessionFactory sessionFactory = conf.configure().buildSessionFactory(); Session sess = sessionFactory.openSession();Transaction tran = sess.beginTransaction();String hql = "from User where id = 1";Query query = sess.createQuery(hql);query.setLockOptions(LockOptions.UPGRADE);List<User> list = query.list();for(User user : list){System.out.print(user.getName()+" ");}System.out.println();tran.commit();sess.close(); }
}

Hibernate会在生成的SQL后面加上for update子句:

Hibernate: select user0_.id as id0_, user0_.name as name0_, user0_.age as age0_ from TEST_USER user0_ where user0_.id=1 for update
longlong

通过for update子句,这条SQL锁定了TEST_USER表中符合检索条件的记录,本次事务提交前,外界无法修改这些记录,事务提交时会释放事务过程中的锁

Hibernate提供了2个锁对象,LockMode和LockOptions:

通过LockOptions的源代码,可以发现LockOptions只是LockMode的简单封装(在LockMode的基础上提供了timeout和scope):

......
/*** NONE represents LockMode.NONE (timeout + scope do not apply)*/
public static final LockOptions NONE = new LockOptions(LockMode.NONE);/*** READ represents LockMode.READ (timeout + scope do not apply)*/
public static final LockOptions READ = new LockOptions(LockMode.READ);/*** UPGRADE represents LockMode.UPGRADE (will wait forever for lock and* scope of false meaning only entity is locked)*/
public static final LockOptions UPGRADE = new LockOptions(LockMode.UPGRADE);public LockOptions(){}public LockOptions( LockMode lockMode) {this.lockMode = lockMode;
}
.....
public static final int NO_WAIT = 0;/*** Indicates that there is no timeout for the acquisition.* @see #getTimeOut*/
public static final int WAIT_FOREVER = -1;private int timeout = WAIT_FOREVER;private boolean scope=false;
......

LockOptions提供的加锁机制要比LockMode少很多,但是LockMode多出的加锁机制一般只是供Hibernate内部实现使用的

保证了操作的独占性,但严重影响数据库性能

二,乐观锁

乐观锁大多基于数据版本记录机制实现,既为数据增加一个版本标识

在数据库中增加version列,用来记录每行数据的版本

Hibernate配置文件中,version节点需要在id节点之后并紧跟id节点

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC"-//Hibernate/Hibernate Mapping DTD 3.0//EN""http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd" ><hibernate-mapping><class name="com.po.User" table="TEST_USER"><id name="id" column="id" type="java.lang.Integer"><generator class="assigned"/></id><version name="version"column="version"type="java.lang.Integer"/><property name="name"column="name"type="java.lang.String"not-null="true"unique="true"length="20"/><property name="age"column="age"type="java.lang.Integer"not-null="true"unique="false"length="0"/></class>
</hibernate-mapping>

每次更新User对象时时,对应行的version字段都在增加

public class Test {public static void main(String[] args) {Configuration conf = new Configuration();  SessionFactory sessionFactory = conf.configure().buildSessionFactory();Session sess1=sessionFactory.openSession();Session sess2=sessionFactory.openSession();try{User user1 = (User)sess1.get(User.class, 1);User user2 = (User)sess2.get(User.class, 1);System.out.println("v1="+user1.getVersion()+"--v2="+user2.getVersion());Transaction tx1 = sess1.beginTransaction();Transaction tx2 = sess2.beginTransaction();user1.setName("ll");tx1.commit();System.out.println("v1="+user1.getVersion()+"--v2="+user2.getVersion());user2.setName("LL");tx2.commit();}catch(Exception e){e.printStackTrace();}finally{sess1.close();sess2.close();}}
}

运行结果如下,可以看到由于tx1提交时,version字段已经被修改,tx2提交时会抛出异常:

Hibernate: select user0_.id as id0_0_, user0_.version as version0_0_, user0_.name as name0_0_, user0_.age as age0_0_ from TEST_USER user0_ where user0_.id=?
Hibernate: select user0_.id as id0_0_, user0_.version as version0_0_, user0_.name as name0_0_, user0_.age as age0_0_ from TEST_USER user0_ where user0_.id=?
v1=0--v2=0
Hibernate: update TEST_USER set version=?, name=?, age=? where id=? and version=?
v1=1--v2=0
Hibernate: update TEST_USER set version=?, name=?, age=? where id=? and version=?
Exception in thread "main" org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect): [com.po.User#1]at org.hibernate.persister.entity.AbstractEntityPersister.check(AbstractEntityPersister.java:1932)at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2576)at org.hibernate.persister.entity.AbstractEntityPersister.updateOrInsert(AbstractEntityPersister.java:2476)at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2803)at org.hibernate.action.EntityUpdateAction.execute(EntityUpdateAction.java:113)at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:273)at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:265)at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:185)at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321)at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:51)at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1216)at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:383)at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:133)at com.test.Test.main(Test.java:43)

除了使用version作为版本标识,还可以使用timestamp作为版本标识

timestamp节点没有type属性:

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC"-//Hibernate/Hibernate Mapping DTD 3.0//EN""http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd" ><hibernate-mapping><class name="com.po.User" table="TEST_USER"><id name="id" column="id" type="java.lang.Integer"><generator class="assigned"/></id><timestamp name="updatetime"column="updatetime"/><property name="name"column="name"type="java.lang.String"not-null="true"unique="true"length="20"/><property name="age"column="age"type="java.lang.Integer"not-null="true"unique="false"length="0"/></class>
</hibernate-mapping>

在某些情况下,不允许修改数据库的表结构,此时Hibernate也有相应的处理手段:

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC"-//Hibernate/Hibernate Mapping DTD 3.0//EN""http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd" ><hibernate-mapping><class name="com.po.User" table="TEST_USER"optimistic-lock="all"dynamic-update="true"dynamic-insert="true"><id name="id" column="id" type="java.lang.Integer"><generator class="assigned"/></id><property name="name"column="name"type="java.lang.String"not-null="true"unique="true"length="20"/><property name="age"column="age"type="java.lang.Integer"not-null="true"unique="false"length="0"/></class>
</hibernate-mapping>

此时Hibernate将使用User类的所有字段作为版本控制信息

乐观锁相较悲观锁提高了不少性能,但是有一定的局限性,由于是在应用层加锁,如果此时在数据中直接修改数据(或其它应用程序修改数据库中的数据),应用层是无法感知到这种变化的,需要配合其它技术手段一起使用

转载于:https://www.cnblogs.com/sean-zou/p/3709975.html

Hibernate悲观锁/乐观锁相关推荐

  1. java 对变量加锁_Java最全锁剖析:独享锁/共享锁+公平锁/非公平锁+乐观锁/悲观锁...

    乐观锁 VS 悲观锁 乐观锁与悲观锁是一种广义上的概念,体现了看待线程同步的不同角度,在Java和数据库中都有此概念对应的实际应用. 1.乐观锁 顾名思义,就是很乐观,每次去拿数据的时候都认为别人不会 ...

  2. 【Java 并发编程】线程锁机制 ( 悲观锁 | 乐观锁 | CAS 三大问题 | ABA 问题 | 循环时间长问题 | 多个共享变量原子性问题 )

    文章目录 一.悲观锁 二.乐观锁 三.乐观锁 CAS 三大问题 一.悲观锁 假设有 222 个线程 , 线程 A 和 线程 B ; 线程 A 访问共享资源 , 线程 B 等待 , 一旦线程 A 访问结 ...

  3. Java锁详解:“独享锁/共享锁+公平锁/非公平锁+乐观锁/悲观锁+线程锁”

    在Java并发场景中,会涉及到各种各样的锁如公平锁,乐观锁,悲观锁等等,这篇文章介绍各种锁的分类: 公平锁/非公平锁 可重入锁 独享锁/共享锁 乐观锁/悲观锁 分段锁 自旋锁 线程锁 乐观锁 VS 悲 ...

  4. innodb 悲观锁 乐观锁_mysql乐观锁、悲观锁、共享锁、排它锁、行锁、表锁

    mysql乐观锁.悲观锁.共享锁.排它锁.行锁.表锁 乐观锁 总是假设最好的情况,每次去拿数据的时候都认为别人不会修改,所以不会上锁,但是在更新的时候会判断一下在此期间别人有没有去更新这个数据,可以使 ...

  5. 最全Java锁详解:独享锁/共享锁+公平锁/非公平锁+乐观锁/悲观锁

    在Java并发场景中,会涉及到各种各样的锁,比如:高并发编程系列:4种常用Java线程锁的特点,性能比较.使用场景,这些锁有对应的种类:公平锁,乐观锁,悲观锁等等,这篇文章来详细介绍各种锁的分类: 公 ...

  6. MySQL - 行锁 表锁 乐观锁 悲观锁 读锁 写锁

    MySQL - 行锁 表锁 乐观锁 悲观锁 读锁 写锁 锁是在执行多线程时用于强行限制资源访问的同步机制,即用于在并发控制中保证对互斥要求的满足.在DBMS中,可以按照锁的粒度把数据库锁分为行级锁(I ...

  7. 理解悲观锁乐观锁、同步锁、读锁、写锁

    ava 锁分类 Java 中的锁有很多,可以按照不同的功能.种类进行分类,下面是我对 Java 中一些常用锁的分类,包括一些基本的概述 从线程是否需要对资源加锁可以分为 悲观锁 和 乐观锁 从资源已被 ...

  8. mysql悲观群_谈谈mysql的悲观和乐观锁

    悲观锁与乐观锁是两种常见的资源并发锁设计思路,也是并发编程中一个非常基础的概念.之前有写过一篇文章关于并发的处理思路和解决方案,这里我单独将对这两种常见的锁机制在数据库数据上的实现进行比较系统的介绍一 ...

  9. hibernate 悲观锁乐观锁

    悲观锁和乐观锁是:在事务隔离机制中设置了ReadCommited的情况下,两种可以避免不可重复读的方式. 设置成读已提交是考虑到安全和处理速度,保证并发效率,但是在这个情况下仍然需要避免不可重复读这种 ...

最新文章

  1. java程序设计pdf下载_Java程序设计(迟立颖) PDF扫描版[21MB]
  2. 排序算法--冒泡排序的首尾改进
  3. 很详细的Nginx配置说明
  4. SAP C4C url mashup跳转原理 - C4C UI到Mashup的参数传递是如何进行的
  5. scala中class与object区别.
  6. “远程桌面己停止工作”的解决方法
  7. 因DataValueField设置不当引起的DropDownList的SelectedItem的取不到所选值的问题
  8. Visual Studio 2019报错:缺少mfc120.dll
  9. OLEDB, ODEB, ADO.NET Abbreviation
  10. 大厂用的分库分表方案和demo源码,都在这里了!
  11. 网吧显示最近使用计算机,影子系统怎么用?实现像网吧电脑一样重启后自动还原系统教程...
  12. android ios开发难度对比,ios VS android:这不就是简洁与复杂最明显的对比
  13. java中运行dos命令_JAVA中如何执行DOS命令
  14. HTML朗读可以用英文吗,关于英语朗读的方法技巧
  15. 非计算机专业学生怎么走上计算机技术之路?
  16. 因为取了个快递我搞懂了五种网络IO模型
  17. 数据挖掘-二项逻辑斯蒂回归模型算法的R实现
  18. Linux Bash漏洞最新最全的修复方法
  19. 【Python】第十一课 模块
  20. PointRend相关论文集

热门文章

  1. mysql 存储过程 无限分类_mysql存储过程实现无限分类
  2. python 程序中断_有趣的Python处理程序中断信号
  3. feignclient url_Spring Cloud Feign 请求动态URL
  4. java里的局部变量为什么不能加static?
  5. oracle中判断是否为季末,Oracle中取月初,月末,季初,季末及年初,年末时间总结...
  6. react 动态添加组件属性_这么高质量React面试题(含答案),看到就是赚到了!...
  7. python清空字典保留变量_python彻底清除字典数据,clear方法使用
  8. mysql支持asp.net_关于Mysql + asp.net注射能支持多语句的感慨(2月)
  9. vi测试仪维修成功率高吗?_电工电路板检测维修无图电路板的技巧
  10. Android Studio系列教程一:下载与安装