Hibernate之悲观锁与乐观锁
http://blog.csdn.net/a19881029/article/details/20665663
如果需要保证数据访问的排它性,则需对目标数据加“锁”,使其无法被其它程序修改
一,悲观锁
对数据被外界(包括本系统当前的其它事务和来自外部系统的事务处理)修改持保守态度,通过数据库提供的锁机制实现
最常用的,是对查询进行加锁(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列,用来记录每行数据的版本
<?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作为版本标识
<?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类的所有字段作为版本控制信息
乐观锁相较悲观锁提高了不少性能,但是有一定的局限性,由于是在应用层加锁,如果此时在数据中直接修改数据(或其它应用程序修改数据库中的数据),应用层是无法感知到这种变化的,需要配合其它技术手段一起使用
Hibernate之悲观锁与乐观锁相关推荐
- (13) 悲观锁和乐观锁解决hibernate并发(转)
前言: 做项目时由于业务逻辑的需要,必须对数据表的一行或多行加入行锁,举个最简单的例子,图书借阅系统.假设 id=1 的这本书库存为 1 ,但是有 2 个人同时来借这本书,此处的逻辑为 Select ...
- 锁机制有什么用?简述Hibernate的悲观锁和乐观锁机制
有些业务逻辑在执行过程中要求对数据进行排他性的访问,于是需要通过一些机制保证在此过程中数据被锁住不会被外界修改,这就是所谓的锁机制. Hibernate支持悲观锁和乐观锁两种锁机制.悲观锁,顾名思义悲 ...
- java面试(二)--(1)EJB的几种类型(2)Hibernate的悲观锁和乐观锁(3) 二叉搜索树与双向链表
1.请说明一下EJB的几种类型分别是什么? EJB(Enterprise JavaBean)是J2EE服务器端的组件模型,EJB包括会话Bean(Session Bean).实体Bean(Entity ...
- 数据库事务的悲观锁和乐观锁
转载出处:http://www.hollischuang.com/archives/934 在数据库的锁机制中介绍过,数据库管理系统(DBMS)中的并发控制的任务是确保在多个事务同时存取数据库中同一数 ...
- Oracle的悲观锁和乐观锁
为了得到最大的性能,一般数据库都有并发机制,不过带来的问题就是数据访问的冲突.为了解决这个问题,大多数数据库用的方法就是数据的锁定. 数据的锁定分为两种方法,第一种叫做悲观锁,第二种叫做乐观锁.什么叫 ...
- mysql隔离级别与悲观锁、乐观锁
2019独角兽企业重金招聘Python工程师标准>>> 1.什么是悲观锁,乐观锁 悲观锁大多数情况下依靠数据库的锁机制实现,以保证操作最大程度的独占性.但随之而来的就是数据库性能的大 ...
- 独占锁、共享锁、更新锁,乐观锁、悲观锁
转载自 独占锁.共享锁.更新锁,乐观锁.悲观锁 1.锁的两种分类方式 (1)从数据库系统的角度来看,锁分为以下三种类型: 独占锁(Exclusive Lock) 独占锁锁定的资源只允许 ...
- MySql事务4种隔离级别以及悲观锁和乐观锁
前言:在那鬼公司呆着发现自己居然把事务给搞明白了. 缘由:公司做的一个项目在进行首页内容显示的时候发现查询结果特别慢,有时候需要一到五分钟才能显示出结果.于是乎,我就顺着SQL语句查询慢的原因找了下去 ...
- mysql的锁机制(读锁,写锁,表锁,行锁,悲观锁,乐观锁,间隙锁)
读锁和写锁 介绍 MyISAM表锁中的读锁和写锁 读锁(共享锁S): 对同一个数据,多个读操作可以同时进行,互不干扰.加锁的会话只能对此表进行读操作,其他会话也只能进行读操作.MyISAM的读默认是加 ...
- laravel mysql 悲观锁_[笔记] 悲观锁与乐观锁
在数据库的锁机制中介绍过,数据库管理系统(DBMS)中的并发控制的任务是确保在多个事务同时存取数据库中同一数据时不破坏事务的隔离性和统一性以及数据库的统一性. 乐观并发控制(乐观锁)和悲观并发控制(悲 ...
最新文章
- Equifax再陷风波:一门户网站管理员密码是admin/admin
- Python设计模式-桥接模式
- 程序员到底为什么要掌握数据结构与算法?
- [转]Asp.NET生成静态页面并分页
- nodejs(三) --- nodejs进程与子进程
- 有关字符编码学习记录
- vue 字典_【开源】基于Vue的前端组件库HeyUI
- Java虚拟机(JVM)简介
- 第二季4:HI_S32 SAMPLE_VENC_1080P_CLASSIC(HI_VOID)函数的分析
- Jmeter使用之高效组织接口自动化用例技巧
- web开发 java如何连接数据库并取得数据,实现 增,删,改,查
- springboot项目启动后第一次接口慢_项目实践:SpringBoot三招组合拳,手把手教你打出优雅的后端接口...
- 如果微信被运维删库、跑路,会造成什么恐怖的后果?
- 《大数据之路-阿里巴巴大数据实践》第九章 阿里巴巴数据整合及管理体系
- AutoCAD2018_块
- ajax加载txt文件,ajax读取txt文件
- 模拟进程创建、终止、阻塞、唤醒原语_轻松搞定进程原理
- Matlab代码生成之SIL/PIL测试
- 使用谷歌的服务器训练
- 微信群营销方案微信群营销步骤
热门文章
- .NET RulesEngine(规则引擎)
- 在.NET Core 中使用Quartz.NET
- Beetlex之tcp/tls服务压测工具
- 微软:Excel公式是世界上使用最广泛的编程语言
- 使用BeetleX访问redis服务
- 使用WebBenchmark对webapi进行管理和性能测试
- 你不该错过的2020中国开源年报,填开源开发者问卷,成为国内开源的见证者
- 简述使用REST API 的最佳实践
- .NET Core开发实战(第16课:选项数据热更新:让服务感知配置的变化)--学习笔记...
- [NewLife.XCode]分表分库(百亿级大数据存储)