Loading sharding-proxy-example/sharding-proxy-boot-mybatis-example/src/main/java/org/apache/shardingsphere/example/proxy/spring/boot/mybatis/service/SagaTransactionalService.java +5 −0 Original line number Diff line number Diff line Loading @@ -35,10 +35,12 @@ public class SagaTransactionalService implements CommonService { this.springPojoService = jpaCommonService; } @Override public void initEnvironment() { springPojoService.initEnvironment(); } @Override public void cleanEnvironment() { springPojoService.cleanEnvironment(); } Loading @@ -46,6 +48,7 @@ public class SagaTransactionalService implements CommonService { /** * process success, XA transaction will be committed. */ @Override @ShardingTransactionType(TransactionType.BASE) @Transactional public void processSuccess() { Loading @@ -55,12 +58,14 @@ public class SagaTransactionalService implements CommonService { /** * process failure, XA transaction will be rollback. */ @Override @ShardingTransactionType(TransactionType.BASE) @Transactional public void processFailure() { springPojoService.processFailure(); } @Override public void printData() { springPojoService.printData(); } Loading sharding-proxy-example/sharding-proxy-boot-mybatis-example/src/main/java/org/apache/shardingsphere/example/proxy/spring/boot/mybatis/service/XATransactionalService.java +5 −0 Original line number Diff line number Diff line Loading @@ -35,10 +35,12 @@ public class XATransactionalService implements CommonService { this.springPojoService = springPojoService; } @Override public void initEnvironment() { springPojoService.initEnvironment(); } @Override public void cleanEnvironment() { springPojoService.cleanEnvironment(); } Loading @@ -46,6 +48,7 @@ public class XATransactionalService implements CommonService { /** * process success, XA transaction will be committed. */ @Override @ShardingTransactionType(TransactionType.XA) @Transactional public void processSuccess() { Loading @@ -55,12 +58,14 @@ public class XATransactionalService implements CommonService { /** * process failure, XA transaction will be rollback. */ @Override @ShardingTransactionType(TransactionType.XA) @Transactional public void processFailure() { springPojoService.processFailure(); } @Override public void printData() { springPojoService.printData(); } Loading Loading
sharding-proxy-example/sharding-proxy-boot-mybatis-example/src/main/java/org/apache/shardingsphere/example/proxy/spring/boot/mybatis/service/SagaTransactionalService.java +5 −0 Original line number Diff line number Diff line Loading @@ -35,10 +35,12 @@ public class SagaTransactionalService implements CommonService { this.springPojoService = jpaCommonService; } @Override public void initEnvironment() { springPojoService.initEnvironment(); } @Override public void cleanEnvironment() { springPojoService.cleanEnvironment(); } Loading @@ -46,6 +48,7 @@ public class SagaTransactionalService implements CommonService { /** * process success, XA transaction will be committed. */ @Override @ShardingTransactionType(TransactionType.BASE) @Transactional public void processSuccess() { Loading @@ -55,12 +58,14 @@ public class SagaTransactionalService implements CommonService { /** * process failure, XA transaction will be rollback. */ @Override @ShardingTransactionType(TransactionType.BASE) @Transactional public void processFailure() { springPojoService.processFailure(); } @Override public void printData() { springPojoService.printData(); } Loading
sharding-proxy-example/sharding-proxy-boot-mybatis-example/src/main/java/org/apache/shardingsphere/example/proxy/spring/boot/mybatis/service/XATransactionalService.java +5 −0 Original line number Diff line number Diff line Loading @@ -35,10 +35,12 @@ public class XATransactionalService implements CommonService { this.springPojoService = springPojoService; } @Override public void initEnvironment() { springPojoService.initEnvironment(); } @Override public void cleanEnvironment() { springPojoService.cleanEnvironment(); } Loading @@ -46,6 +48,7 @@ public class XATransactionalService implements CommonService { /** * process success, XA transaction will be committed. */ @Override @ShardingTransactionType(TransactionType.XA) @Transactional public void processSuccess() { Loading @@ -55,12 +58,14 @@ public class XATransactionalService implements CommonService { /** * process failure, XA transaction will be rollback. */ @Override @ShardingTransactionType(TransactionType.XA) @Transactional public void processFailure() { springPojoService.processFailure(); } @Override public void printData() { springPojoService.printData(); } Loading