2016-08-02 2 views
2

Я использую пружинное ядро ​​и зимуют integration.While я использую следующий кодorg.hibernate.TransactionException: вложенные транзакции не поддерживаются

@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");   
} 

Я получаю следующее исключение.

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) 

Я подаю на темы transactions.while Я пытаюсь без резьбы код работает fine.But при применении темы, получать вышеуказанное исключение.

+0

я предполагаю, здесь сделка начинается и заканчивается фиксация, то в промежутке между другой транзакцией начинаются, следовательно, в результате чего этот вопроса. Здесь сеанс не является потокобезопасным. – Imran

ответ

0

Невозможно создать новую транзакцию внутри метода, который аннотируется @Transactional. Таким образом, вы должны удалить Сделку hadling в методе, или @Transactional аннотацию

@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");   
} 
Смежные вопросы