2016-08-02 13 views
2

I Federkern bin mit und überwintern integration.While i den folgenden Code verwendenorg.hibernate.TransactionException: verschachtelte Transaktionen nicht unterstützt

@Transactional 
public void updateExecutedStatus(Processing_File_data file,int status) throws SQLException { 
    System.out.println(this.getClass().getName()+"and method name is updateExecutedStatus start"); 
    /*synchronized (this) {*/ 

    //Session session=sessionFactory.openSession(); 
    Session session=sessionFactory.getCurrentSession(); 
    if(session==null||session.equals(null)){ 
     session=sessionFactory.openSession(); 
    } 
      try { 

       //Transaction tx1 = sessionFactory.getCurrentSession().beginTransaction(); 

       Transaction tx1 = session.beginTransaction(); 
       file.setStatus(status); 
       file.getLdb().setExecuted(status); 
       session.saveOrUpdate(file); 
      tx1.commit(); 
      } 
      catch (Exception e) { 
       //log.error(e.getMessage()); 
       e.printStackTrace(); 
      }finally{ 
       session.close(); 
      } 

    /*}*/ 
      System.out.println(this.getClass().getName()+"and method name is updateExecutedStatus end");   
} 

ich die folgende Ausnahme zu bekommen.

org.hibernate.TransactionException: nested transactions not supported 
at org.hibernate.engine.transaction.spi.AbstractTransactionImpl.begin(AbstractTransactionImpl.java:154) 
at org.hibernate.internal.SessionImpl.beginTransaction(SessionImpl.java:1435) 
at pe.entel.dao.impl.MasDatabaseTransactImpl.updateExecutedStatus(MasDatabaseTransactImpl.java:147) 
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source) 
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
at java.lang.reflect.Method.invoke(Method.java:497) 
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317) 
at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190) 
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157) 
at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:98) 
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:262) 
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:95) 
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) 
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207) 
at com.sun.proxy.$Proxy23.updateExecutedStatus(Unknown Source) 
at pe.entel.service.MassiveDatabaseServiceImpl.updateExecutedStatus(MasDatabaseServiceImpl.java:54) 
at pe.entel.service.activation.masivas.servadd.core.SeMain.handler(SeMain.java:284) 
at pe.entel.integrated.MasiRoot.getlists(MasiRoot.java:71) 
at pe.entel.integrated.RecordsDistributedThread.run(RecordsDistributedThread.java:44) 

Ich bewerbe mich Threads auf transactions.while ich den Code ohne Gewinde versuche fine.But arbeitet, wenn Fäden Anwendung der oben Ausnahme bekommen.

+0

Ich nehme hier eine Transaktion beginnt und endet mit einem Commit dann in-zwischen einer anderen Transaktion damit begonnen wird, um dieses Problem zu verursachen. Die Sitzung ist hier nicht threadsicher. – Imran

Antwort

0

Sie können keine neue Transaktion innerhalb einer Methode starten, die mit @Transactional gekennzeichnet ist. So müssen Sie hadling in Verfahren, die Transaktion entfernen, oder die @Transactional Anmerkung

@Transactional 
public void updateExecutedStatus(Processing_File_data file,int status) throws SQLException { 
    System.out.println(this.getClass().getName()+"and method name is updateExecutedStatus start"); 
    /*synchronized (this) {*/ 

    //Session session=sessionFactory.openSession(); 
    Session session=sessionFactory.getCurrentSession(); 
    if(session==null||session.equals(null)){ 
     session=sessionFactory.openSession(); 
    } 
      try { 

       file.setStatus(status); 
       file.getLdb().setExecuted(status); 
       session.saveOrUpdate(file); 
      } 
      catch (Exception e) { 
       //log.error(e.getMessage()); 
       e.printStackTrace(); 
      } 

    /*}*/ 
      System.out.println(this.getClass().getName()+"and method name is updateExecutedStatus end");   
}