ME: 下文中说明了如何使用乐观锁解决并发修改的问题。
在实际的项目中,通常在网页上展示给用户,修改表中的数据。
此时,需要在页面上保存VERSION值,设置ENTITY对象时同时设置上VERSION字段,执行UPDATE时系统会自动判断VERSION是否与库中的相同,如不相等,抛出异常信息。
Hibernate乐观锁实现之Version
Hibernate, Version
通过在表中及POJO中增加一个version字段来表示记录的版本,来达到多用户同时更改一条数据的冲突
数据库脚本:
create
tablestudentVersion (idvarchar(32),namevarchar(32),verint);
POJO
packageVersion;
public
classStudent...{
privateString id;
privateString name;
private
intversion;
publicString getId()...{
returnid;
}
public
voidsetId(String id)...{
this.id=id;
}
publicString getName()...{
returnname;
}
public
voidsetName(String name)...{
this.name=name;
}
public
intgetVersion()...{
returnversion;
}
public
voidsetVersion(intversion)...{
this.version=version;
}
}
Student.hbm.xml
<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<!--
Mapping file autogenerated by MyEclipse - Hibernate Tools
-->
<hibernate-mapping>
<classname="Version.Student"table="studentVersion"
>
<idname="id"unsaved-value="null">
<generatorclass="uuid.hex"></generator>
</id>
<!--version标签必须跟在id标签后面-->
<versionname="version"column="ver"type="int"></version>
<propertyname="name"type="string"column="name"></property>
</class>
</hibernate-mapping>
Hibernate.cfg.xml
<?xml version='1.0' encoding='UTF-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<!--Generated by MyEclipse Hibernate Tools. -->
<hibernate-configuration>
<session-factory>
<propertyname="connection.username">root</property>
<propertyname="connection.url">
jdbc:mysql://localhost:3306/schoolproject?characterEncoding=gb2312&useUnicode=true
</property>
<propertyname="dialect">
org.hibernate.dialect.MySQLDialect
</property>
<propertyname="myeclipse.connection.profile">mysql</property>
<propertyname="connection.password">1234</property>
<propertyname="connection.driver_class">
com.mysql.jdbc.Driver
</property>
<propertyname="hibernate.dialect">
org.hibernate.dialect.MySQLDialect
</property>
<propertyname="hibernate.show_sql">true</property>
<propertyname="current_session_context_class">thread</property>
<propertyname="jdbc.batch_size">15</property>
<mappingresource="Version/Student.hbm.xml"
/>
</session-factory>
</hibernate-configuration>
测试代码:
packageVersion;
importjava.io.File;
importjava.util.Iterator;
importjava.util.Set;
importorg.hibernate.Session;
importorg.hibernate.SessionFactory;
importorg.hibernate.Transaction;
importorg.hibernate.cfg.Configuration;
public
classTest...{
public
static
voidmain(String[] args)...{
String filePath=System.getProperty("user.dir")+File.separator+"src/Version"+File.separator+"hibernate.cfg.xml";
File file=newFile(filePath);
System.out.println(filePath);
SessionFactory sessionFactory=newConfiguration().configure(file).buildSessionFactory();
Session session=sessionFactory.openSession();
Transaction t=session.beginTransaction();
Student stu=newStudent();
stu.setName("tom11");
session.save(stu);
t.commit();
/**//*
* 模拟多个session操作student数据表
*/
Session session1=sessionFactory.openSession();
Session session2=sessionFactory.openSession();
Student stu1=(Student)session1.createQuery("from Student s where s.name='tom11'").uniqueResult();
Student stu2=(Student)session2.createQuery("from Student s where s.name='tom11'").uniqueResult();
//这时候,两个版本号是相同的
System.out.println("v1="+stu1.getVersion()+"--v2="+stu2.getVersion());
Transaction tx1=session1.beginTransaction();
stu1.setName("session1");
tx1.commit();
//这时候,两个版本号是不同的,其中一个的版本号递增了
System.out.println("v1="+stu1.getVersion()+"--v2="+stu2.getVersion());
Transaction tx2=session2.beginTransaction();
stu2.setName("session2");
tx2.commit();
}
}
运行结果:
Hibernate: insert into studentVersion (ver, name, id) values (?, ?, ?)
Hibernate: select student0_.id as id0_, student0_.ver as ver0_, student0_.name as name0_ from studentVersion student0_ where student0_.name='tom11'
Hibernate: select student0_.id as id0_, student0_.ver as ver0_, student0_.name as name0_ from studentVersion student0_ where student0_.name='tom11'
v1=0--v2=0
Hibernate: update studentVersion set ver=?, name=? where id=? and ver=?
v1=1--v2=0
Hibernate: update studentVersion set ver=?, name=? where id=? and ver=?
Exception in thread "main" org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect): [Version.Student#4028818316cd6b460116cd6b50830001]
可以看到,第二个“用户”session2修改数据时候,记录的版本号已经被session1更新过了,所以抛出了红色的异常,我们可以在实际应用中处理这个异常,例如在处理中重新读取数据库中的数据,同时将目前的数据与数据库中的数据展示出来,让使用者有机会比较一下,或者设计程序自动读取新的数据
注意:如果手工设置stu.setVersion()自行更新版本以跳过检查,则这种乐观锁就会失效,应对方法可以将Student.java的setVersion设置成private
分享到:
相关推荐
Hibernate乐观锁和悲观锁分析,针对在使用HIBERNATE时怎么配置乐观锁进行了详细的范例讲解
其中通过 version 实现的乐观锁机制是 Hibernate 官方推荐的乐观锁实现,同时也是 Hibernate 中,目前唯一在数据对象脱离 Session 发生修改的情况下依然有效的锁机制。因此,一般情况下,我们都选择 version 方式...
乐观锁 求助编辑百科名片相对悲观锁而言,乐观锁机制采取了更加宽松的加锁机制。悲观锁大多数情况下依靠数据库的锁机制实现,以保证操作最大程度的独占性。但随之而来的就是数据库 性能的大量开销,特别是对长事务而...
NULL 博文链接:https://12345678.iteye.com/blog/721836
Hibernate的乐观锁与悲观锁的文档,帮助学习Hibernate的乐观锁与悲观锁,让你们学得更轻松。
NULL 博文链接:https://tgwall163.iteye.com/blog/1291892
hibernate的乐观锁和悲观锁,两种锁搞定一切
很好的描述Hibernate的悲观锁和乐观锁,
Hibernate高级特性,悲观锁与乐观锁的应用和区别,及两者之间的区别。
Hibernate锁机制_悲观锁和乐观锁
NULL 博文链接:https://cdxs2.iteye.com/blog/1938245
HibernateTestHibernate乐观锁和悲观锁的学习和实践
乐观锁version 对于在Hibernate中的乐观锁和悲观锁的学习
主要介绍了Hibernate实现悲观锁和乐观锁的有关内容,涉及hibernate的隔离机制,以及实现悲观锁和乐观锁的代码实现,需要的朋友可以了解下。
主要介绍了Hibernate悲观锁和乐观锁实例详解,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
资源名称:Hibernate基础教程汇总资源目录:【】hibernate【】hibernate_312_中文参考文档【】hibernate乐观锁和悲观锁【】hibernate基础教程【】Hibernate注解详解实体类大全资源截图: 资源太大,传百度网盘了,...
hibernate利用锁的相关功能详解,分为乐观锁和悲观锁。希望各位喜欢。
NULL 博文链接:https://jordanyangwei.iteye.com/blog/313756