zoukankan html css js c++ java

Hibernate系列教材（二十四）- 各类概念

Hibernate使用乐观锁来处理脏数据问题

步骤1:先运行，看到效果，再学习
步骤2:模仿和排错
步骤3:首先看不使用乐观锁的情况
步骤4:修改配置文件 Product.hbm.xml
步骤5:修改 Product.java
步骤6:重新运行一样的代码
步骤7:原理

步骤 1 : 先运行，看到效果，再学习

老规矩，先下载下载区(点击进入)的可运行项目，配置运行起来，确认可用之后，再学习做了哪些步骤以达到这样的效果。

步骤 2 : 模仿和排错

在确保可运行项目能够正确无误地运行之后，再严格照着教程的步骤，对代码模仿一遍。
模仿过程难免代码有出入，导致无法得到期望的运行结果，此时此刻通过比较正确答案 ( 可运行项目 ) 和自己的代码，来定位问题所在。
采用这种方式，学习有效果，排错有效率，可以较为明显地提升学习速度，跨过学习路上的各个槛。

推荐使用diffmerge软件，进行文件夹比较。把你自己做的项目文件夹，和我的可运行项目文件夹进行比较。
这个软件很牛逼的，可以知道文件夹里哪两个文件不对，并且很明显地标记出来
这里提供了绿色安装和使用教程：diffmerge 下载和使用教程

步骤 3 : 首先看不使用乐观锁的情况

故意创造一个场景来制造脏数据。

1. 通过session1得到id=1的对象 product1
2. 在product1原来价格的基础上增加1000
3. 更新product1之前，通过session2得到id=1的对象product2
4. 在product2原来价格的基础上增加1000
5. 更新product1
6. 更新product2

最后结果是product的价格只增加了1000，而不是2000

package com.how2java.test;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.cfg.Configuration;

import com.how2java.pojo.Product;

public class TestHibernate {

public static void main(String[] args) {

SessionFactory sf = new Configuration().configure().buildSessionFactory();

Session s1 = sf.openSession();

Session s2 = sf.openSession();

s1.beginTransaction();

s2.beginTransaction();

Product p1 = (Product) s1.get(Product.class, 1);

System.out.println("产品原本价格是: " + p1.getPrice());

p1.setPrice(p1.getPrice() + 1000);

Product p2 = (Product) s2.get(Product.class, 1);

p2.setPrice(p2.getPrice() + 1000);

s1.update(p1);

s2.update(p2);

s1.getTransaction().commit();

s2.getTransaction().commit();

Product p = (Product) s1.get(Product.class, 1);

System.out.println("经过两次价格增加后，价格变为: " + p.getPrice());

s1.close();

s2.close();

sf.close();

}

步骤 4 : 修改配置文件 Product.hbm.xml

<version name="version" column="ver" type="int"></version>

增加一个version字段，用于版本信息控制。这就是乐观锁的核心机制。

比如session1获取product1的时候，version=1。那么session1更新product1的时候，就需要确保version还是1才可以进行更新，并且更新结束后，把version改为2。

注意： version元素必须紧跟着id后面，否则会出错。

<?xml version="1.0"?>

<!DOCTYPE hibernate-mapping PUBLIC

"-//Hibernate/Hibernate Mapping DTD 3.0//EN"

"http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">

<hibernate-mapping package="com.how2java.pojo">

<class name="Product" table="product_">

<id name="id" column="id">

<generator class="native">

</generator>

</id>

<version name="version" column="ver" type="int"></version>

<property name="name" />

<property name="price" />

<many-to-one name="category" class="Category" column="cid" />

<set name="users" table="user_product" lazy="false">

<key column="pid" />

<many-to-many column="uid" class="User" />

</set>

</class>

</hibernate-mapping>

步骤 5 : 修改 Product.java

增加version属性

package com.how2java.pojo;

import java.util.Set;

public class Product {

int id;

String name;

float price;

Category category;

int version;

public int getVersion() {

return version;

}

public void setVersion(int version) {

this.version = version;

}

Set<User> users;

public Set<User> getUsers() {

return users;

}

public void setUsers(Set<User> users) {

this.users = users;

}

public Category getCategory() {

return category;

}

public void setCategory(Category category) {

this.category = category;

}

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public float getPrice() {

return price;

}

public void setPrice(float price) {

this.price = price;

}

步骤 6 : 重新运行一样的代码

做同样的业务就会抛出异常，提示该行已经被其他事务删除或者修改过了，本次修改无法生效。

这样就保证了数据的一致性。