0

在我们的应用程序中，我们使用的是 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();
    }
    }

我有另一个与此相同的方法，即使在此方法引发异常的情况下，也会在此方法之后调用该方法。

两种方法的会话相同。

现在我遇到的是，如果我的第二个方法成功执行并提交休眠事务，这将存储已保存在我不想要的第一个方法中的数据。

我无法分享确切的代码，但准备了一种与此问题类似的测试方法。我的数据库服务器是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();
        }
    }

}

任何帮助，将不胜感激。

4

1 回答 1

1

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

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

感谢您的回复。

于 2014-11-20T10:36:06.170 回答