通過在表中及POJO中增加一個version欄位來表示記錄的版本，來達到多使用者同時更改一條資料的衝突

資料庫指令碼：

POJO

 Version;

{
  private String id;
  private String name;
  privateint version;
public String getId() {
    return id;
}
publicvoid setId(String id) 

{
    this.id = id;
}
public String getName() {
    return name;
}
publicvoid setName(String name) {
    this.name = name;
}
publicint getVersion() {
    return version;
}
publicvoid setVersion(int version) {
    this.version = version;
}


}

Student.hbm.xml

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.cfg.xml

DOCTYPE hibernate-configuration PUBLIC
          "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
          "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"

    

    

        jdbc:mysql://localhost:3306/schoolproject?characterEncoding=gb2312

useUnicode=true
    

    

        org.hibernate.dialect.MySQLDialect
    

    

    

    

        com.mysql.jdbc.Driver
    

    

        org.hibernate.dialect.MySQLDialect
    

    

    

    

    

測試程式碼：

 Version;

 java.io.File;

 java.util.Iterator;

 java.util.Set;

 org.hibernate.Session;

 org.hibernate.SessionFactory;

 org.hibernate.Transaction;

 org.hibernate.cfg.Configuration;

{


    publicstaticvoid main(String[] args) {

        String filePath=System.getProperty("user.dir")+File.separator+"src/Version"+File.separator+"hibernate.cfg.xml";
        File file=new File(filePath);
        System.out.println(filePath);
        SessionFactory sessionFactory=new Configuration().configure(file).buildSessionFactory();
        Session session=sessionFactory.openSession();
        Transaction t=session.beginTransaction();
        
        Student stu=new Student();
        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