ロールバックすべてのDBは春

Question

にネストされたトランザクションでコミット

I持つネストされたトランザクションの次のサービスレイアウト：私はServiceC#methodC()が例外をスローした場合、すべてのDBがServiceAとServiceBネストされた呼び出しの中にロールバックする呼び出しを行う必要がある

@Component 
public class Main implements RPCInterface { 

    @Autowired 
    private ServiceA serviceA; 

    @Autowired 
    private ServiceB serviceB; 

    @Autowired 
    private ServiceC serviceC; 

    @Override 
    @Transactional (value="txManager", propagation=Propagation.REQUIRED, rollbackFor={ExceptionOne.class, ExceptionTwo.class, ExceptionThree.class}) 
    public void outerMethod() throws ExceptionO { 

    try { 
     serviceA.methodA(); 
     serviceB.methodB(); 
     serviceC.methodC(); 

    } catch (ExceptionOne e) { 
     throw new ExceptionO(e.getMessage, e); 
    } catch (ExceptionTwo e) { 
     throw new ExceptionO(e.getMessage, e); 
    } catch (ExceptionThree e) { 
     throw new ExceptionO(e.getMessage, e); 
    } 
    } 
} 

@Service 
public class ServiceA implements SA { 

    @Autowired 
    private ServiceA1 serviceA1; 

    @Override 
    public void methodA() { 
    serviceA1.methodA1(); 
    } 
} 

@Service 
public class ServiceA1 implements SA1 { 
    @Autowired 
    private ServiceDBTable1 serviceDBTable1; 

    @Autowired 
    private ServiceA1A serviceA1A; 

    @Transactional 
    @Override 
    public void methodA1() { 
    serviceDBTable4.callToMapper4(); 
    serviceA1A.methodA1A(); 
    } 
} 

@Service 
@Transactional (value="txManager", propagation=Propagation.REQUIRED) 
public class ServiceA1A implements SA1A { 

    @Autowired 
    private ServiceDBTable2 serviceDBTable2; 

    @Override 
    public void methodA1A() { 
    serviceDBTable1.callToMapper1(); 
    } 
} 

@Service 
public class ServiceB implements SB { 

    @Autowired 
    private ServiceDBTable3 serviceDBTable3; 

    @Override 
    @Transactional (value="txManager", propagation=Propagation.REQUIRED) 
    public void methodB() { 
    serviceDBTable3.callToMapper3(); 
    } 
} 

@Service 
public class ServiceC implements SC { 

    @Override 
    public void methodC() throws ExceptionThree { 
    // code that throws ExceptionThree 
    } 
} 

（または例外をスローするそのようなもののいずれか - ServiceAまたはServiceB）。

私はMain#outerMethodとトランザクションをREQUIREDと伝えようとしましたが、データベースコミットがロールバックされていないようです。私はrollbackForで特定のクラスを指定しましたが、コミットは持続します。誰もこの問題を解決する方法を知っていますか？

Answer 1

（私のロジックは、実際に私はそれを行うために許可）：

@Component 
public class Main implements RPCInterface { 

    @Autowired 
    private ServiceA serviceA; 

    @Override 
    public void outerMethod() throws ExceptionO { 

    try { 
     serviceA.methodA(); 

    } catch (ExceptionOne e) { 
     throw new ExceptionO(e.getMessage, e); 
    } catch (ExceptionTwo e) { 
     throw new ExceptionO(e.getMessage, e); 
    } catch (ExceptionThree e) { 
     throw new ExceptionO(e.getMessage, e); 
    } 
    } 
} 

@Service 
public class ServiceA implements SA { 

    @Autowired 
    private ServiceA1 serviceA1; 

    @Autowired 
    private ServiceB serviceB; 

    @Autowired 
    private ServiceC serviceC; 

    @Override 
    @Transactional (value="txManager", propagation=Propagation.REQUIRED, rollbackFor={ExceptionOne.class, ExceptionTwo.class, ExceptionThree.class}) 
    public void methodA() throw ExceptionOne, ExceptionTwo, ExceptionThree { 
    serviceA1.methodA1(); 
    serviceB.methodB(); 
    serviceC.methodC(); 
    } 
} 

@Service 
public class ServiceA1 implements SA1 { 
    @Autowired 
    private ServiceDBTable1 serviceDBTable1; 

    @Autowired 
    private ServiceA1A serviceA1A; 

    @Transactional 
    @Override 
    public void methodA1() { 
    serviceDBTable4.callToMapper4(); 
    serviceA1A.methodA1A(); 
    } 
} 

@Service 
@Transactional (value="txManager", propagation=Propagation.REQUIRED) 
public class ServiceA1A implements SA1A { 

    @Autowired 
    private ServiceDBTable2 serviceDBTable2; 

    @Override 
    public void methodA1A() { 
    serviceDBTable1.callToMapper1(); 
    } 
} 

@Service 
public class ServiceB implements SB { 

    @Autowired 
    private ServiceDBTable3 serviceDBTable3; 

    @Override 
    @Transactional (value="txManager", propagation=Propagation.REQUIRED) 
    public void methodB() { 
    serviceDBTable3.callToMapper3(); 
    } 
} 

@Service 
public class ServiceC implements SC { 

    @Override 
    public void methodC() throws ExceptionThree { 
    // code that throws ExceptionThree 
    } 
} 

Answer 2

コードが表示されていないので、わかりにくいです。 しかし、トランザクションはメソッドが公開されている場合にのみ機能します。プライベートメソッドはプロキシされておらず、そのためのトランザクションサポートは存在しません。

詳細はDeclarative Transations - Spring Docsから読んでください。

まだ改善のために苦労している場合は、コードを投稿してください。私はそれが仕事がServiceA.methodA()からServiceB.methodB()とServiceC.methodC()呼び出しを移行すると、これら3つの例外に基づいてmethodA()とロールバックからすべての私の例外を投げながらmethodA()@Transactionalを作ることだった作るためにやった