Hibernate乐观锁

xbsunshine

浏览: 10137 次
性别:
来自: 北京

最近访客更多访客>>

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

hibernate 乐观锁 version

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">



<hibernate-mapping>

<classname="Version.Student"table="studentVersion"
>

<idname="id"unsaved-value="null">

   <generatorclass="uuid.hex"></generator>

</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">



<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

分享到：