Hibernate 3有两个事务问题

Question

在我们的应用程序中，我们使用Hibernate 3。最近我在交易中遇到了一个问题。我有一些代码如下方式

    method1()
    try{
    tx = session.beginTransaction();
    //New object which needs to be stored
    session.save(object);
    // Some code which generates exception
    tx.commit(); // Exception occured before commit processing
    }catch(Exception ex){
    e.printStackTrace();
    throw e;
    }finally{
    if(tx!=null && tx.wasNotCommited()){
    tx.rollback();
    }
    }

我有另一个与此相同的方法，即使该方法抛出异常，也会在该方法之后调用该方法。

两个方法的会话是相同的。

现在我所经历的是，如果我的第二个方法成功执行并提交hibernate事务，这将存储我不想要的保存在第一个方法中的数据。

我无法分享确切的代码，但我准备了一个与此问题类似的测试方法。我的数据库服务器是mysql。

package com.opshub.jobs.core;

import org.hibernate.Session;
import org.hibernate.Transaction;

import com.opshub.dao.core.Company;
import com.opshub.utils.hibernate.HibernateSessionFactory;

public class Test {

    public static void main(String[] args) throws Exception{
        Session session = HibernateSessionFactory.openSession();
        try{
            Transaction tx = session.beginTransaction();
            try{
                Company company = new Company();
                company.setName("Gaurav");
                company.setCompanyDetails("IT Company");
                company.setCompanyAddress("India");
                session.save(company);
                if(true)
                    throw new Exception("Now go to finally");
                tx.commit();
            }catch(Exception e){
                throw e;
            }finally{
                tx.rollback();
            }
        }finally{
            Transaction tx = session.beginTransaction();
            tx.begin();
            Company company = new Company();
            company.setName("Gaurav 1");
            company.setCompanyDetails("IT Company");
            company.setCompanyAddress("India");
            session.save(company);
//          if(true)
//              throw new Exception("Now go to finally");
            tx.commit();
        }
    }

}

任何帮助都将不胜感激。

Answer 1

最后，我找到了这个问题的解决方案。在开始另一个事务/操作之前，您可以使用session.clear（）从会话中删除所有挂起的保存/更新/删除操作。

所以在最后的回滚中，只需添加session.save()。

感谢您的回复。