Hibernate悲观锁（pessimistic lock）实例详解

悲观锁（pessimistic lock）是指在每次操作数据时，总是悲观地认为会有其他事务操作同一数据，因此，在整个数据处理过程中，会把数据处于锁定状态。

悲观锁具有排他性，一般由数据库实现。在锁定时间内，其他事务不能对数据进行存取等操作，这可能导致长时间的等待问题。

在 Hibernate 中，用户可以显示地设定锁模式，通常在应用中会设定如下两种锁模式。

1）LockMode.UPGRADE

该模式不管缓存中是否存在对象，总是通过 select 语句到数据库中加载该对象，如果映射文件中设置了版本元素，则执行版本检查，比较缓存中的对象是否与数据库中对象的版本一致，如果数据库系统支持悲观锁（如 MySQL），则执行 select...for update 语句，如果不支持（如 Sybase），则执行普通 select 语句。

2）LockMode.UPGRADE_NOWAIT

该模式与 LockMode.UPGRADE 具有同样的功能，是 Oracle 数据库特有的锁模式，会执行 select...for update nowait 语句。

nowait 表示如果执行 select 语句的事务不成立则获得悲观锁，它不会等待其他事务释放锁，而是立刻抛出锁定异常。

下面通过丢失更新的案例演示悲观锁的使用。

1. 创建项目并引入JAR包

在 MyEclipse 中创建一个名称为 hibernateDemo05 的 Web 项目，将 Hibernate 所必需的 JAR 包添加到 lib 目录中，并发布到类路径下。

2. 创建实体类

在 src 目录下创建一个名为 com.mengma.domain 的包，在该包下创建一个 Person 类，定义 id、name 和 age 三个属性，并实现各属性的 getter 和 setter 方法以及 toString() 方法，如下所示。

package com.mengma.domain;
public class Person {
    private Integer id;
    private String name; // 姓名
    private Integer age; // 年龄
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Integer getAge() {
        return age;
    }
    public void setAge(Integer age) {
        this.age = age;
    }
}

3. 创建映射文件

在 com.mengma.domain 包中创建一个名为 Person.hbm.xml 的映射文件，将实体类 Person 映射到数据表中，如下所示。

<?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>
    <class name="com.mengma.domain.Person" table="person">
        <id name="id" column="id">
            <generator class="native" />
        </id>
        <property name="name" column="name" type="string" />
        <property name="age" column="age" type="integer" />
    </class>
</hibernate-mapping>

4. 创建配置文件

在 src 目录下创建一个名为 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>
  <!-- 指定方言 -->
  <property name="dialect">
   org.hibernate.dialect.MySQL5Dialect
  </property>
  <!-- 链接数据库url -->
  <property name="connection.url">
              <![CDATA[jdbc:mysql://localhost:3306/hibernate?useUnicode=true&characterEncoding=utf-8]]>
  </property>
  <!-- 连接数据库的用户名 -->
  <property name="connection.username">
   root
  </property>
  <!-- 数据库的密码 -->
  <property name="connection.password">
   1128
  </property>
  <!-- 数据库驱动 -->
  <property name="connection.driver_class">
   com.mysql.jdbc.Driver
  </property>
  <!-- 显示sql语句 -->
  <property name="show_sql">
   true
  </property>
  <!-- 格式化sql语句 -->
  <property name="format_sql">true</property>
  <!-- 映射文件配置 -->
  <mapping resource="com/mengma/domain/Person.hbm.xml" />
</session-factory>
</hibernate-configuration>

5. 创建工具类

在 src 目录下创建一个名为 com.mengma.utils 的包，并在该包下创建一个名为 HibernateUtils 的工具类，该工具类的实现代码如下所示。

package com.mengma.utils;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
public class HibernateUtils {
    // 声明一个私有的静态final类型的Configuration对象
    private static final Configuration config;
    // 声明一个私有的静态的final类型的SessionFactory对象
    private static final SessionFactory factory;
    // 通过静态代码块构建SessionFactory
    static {
        config = new Configuration().configure();
        factory = config.buildSessionFactory();
    }
    // 提供一个公有的静态方法供外部获取，并返回一个session对象
    public static Session getSession() {
        return factory.openSession();
    }
}

6. 创建测试类

在 src 目录下创建一个名为 com.mengma.test 的包，在该包下创建一个名为 PersonTest 的类。在类中编写一个test1()方法，用于添加一条记录，并检查项目是否可以正常运行。然后再分别编写一个 test2() 方法和 test3() 方法，其中 test2() 方法用于修改 name 属性，test3() 方法用于修改 age 属性。其具体实现代码如下所示。

package com.mengma.test;
import org.hibernate.Session;
import org.junit.Test;
import com.mengma.domain.Person;
import com.mengma.utils.HibernateUtils;
public class PersonTest {
    // 添加数据
    @Test
    public void test1() {
        Session session = HibernateUtils.getSession();
        session.beginTransaction();
        Person person = new Person();
        person.setName("zhangsan");
        person.setAge(20);
        session.save(person);
        session.getTransaction().commit();
        session.close();
    }
    // 修改name屈性
    @Test
    public void test2() {
        Session session = HibernateUtils.getSession();
        session.beginTransaction();
        Person person = (Person) session.get(Person.class, 1);
        person.setName("lisi");
        session.save(person);
        session.getTransaction().commit();
        session.close();
    }
    // 修改age属性
    @Test
    public void test3() {
        Session session = HibernateUtils.getSession();
        session.beginTransaction();
        Person person = (Person) session.get(Person.class, 1);
        person.setAge(25);
        session.save(person);
        session.getTransaction().commit();
    }
}

7. 运行程序并查看结果

使用 JUnit 测试运行 test1() 方法，运行成功后，控制台的显示结果如图 1 所示。 

图 1  输出结果

从图 1 中可以看出，使用 Hibernate 已经成功向 person 表中添加数据，说明项目可以正常运行。接下来在 PersonTest 的第 29 行和第 41 行分别设置一个断点，然后采用 Debug 模式运行 test2() 方法，MyEclipse 的显示如图 2 所示。 

图 2  调试 test2() 方法

从图 2 中可以看出，程序代码已经停在了第 29 行，接下来按 F6 键，使代码依次向下执行，在第 30 行代码处（提交事务前）停止运行。然后以同样的方式运行 test3() 方法，这时代码会停在第 41 行。

由于同时运行了两个方法，但是在 MyEclipse 中，当前窗口只能显示一个运行方法，所以需要手动单击需要显示的方法。此时可以在窗口左上方的 Debug 窗口中看到 test2() 和 test3() 方法，如图 3 所示。 

图 3  Debug窗口

单击展开图 3 中的 PersonTest.test3[JUnit] 后，再次单击 Thread[main]（Suspended）下面的 PersonTest.test3() 即可进入 test3() 方法的 Debug 调试模式。按 F6 键依次向下执行代码，直到第 38 行代码处停止运行，如图 4 所示。 

图 4  调试test3()方法

接下来，单击展开图 4 中的 PersonTest.test2[JUnit]，回到 test2() 方法，并单击 Debug 窗口上方的  按钮，使 MyEclipse 自动运行完后面的代码。此时 Debug 窗口上方的按钮会变成灰色的不可操作状态。再次回到 test3() 方法，以同样的方式执行完 test3() 方法。此时查询 person 表数据时，其查询结果如图 5 所示。 

图 5  查询结果

从图 5 中可以看出，此时 person 表中的数据已经发生了变化。Test2() 提交后，name 字段变为 lisi，但是 test3() 方法提交后，会将 test2() 方法提交的数据覆盖，导致 name 字段变回了原来的 zhangsan，而 age 字段被修改为 25，这就是并发访问数据时的数据丢失。

要解决这一问题，只需在 test2() 和 test3() 方法的 Person person=(Person)session.get(Person.class，1) 中加入 LockMode.UPGRADE 参数即可，具体实现代码如下所示：

此时再次通过 Debug 调试运行 test2() 和 test3() 方法，就不会出现数据丢失的情况了，这是因为使用了 Hibernate 的悲观锁模式，当某条数据被锁定时，其他方法无法对此条数据进行操作，直到事务提交后才会被解锁，这时其他方法才可以对这条数据进行操作。