Spring @Transactional with a transaction across multiple data sources

by

I’ve solved this problem using ChainedTransactionManager – http://docs.spring.io/spring-data/commons/docs/1.6.2.RELEASE/api/org/springframework/data/transaction/ChainedTransactionManager.html

Spring Boot Configuration:

    @Bean(name = "chainedTransactionManager")
    public ChainedTransactionManager transactionManager(@Qualifier("primaryDs") PlatformTransactionManager ds1,
                                                    @Qualifier("secondaryDs") PlatformTransactionManager ds2) {
         return new ChainedTransactionManager(ds1, ds2);
    }

And then you can use it as follows:

@Transactional(value="chainedTransactionManager")
public void updateDb01() {
    Entity01 entity01 = repository01.findOne(1234);
    entity01.setName("Name");
    repository01.save(entity01);

    //Calling method to update DB02
    updateDb02();
}

public void updateDb02() {
    Entity02 entity02 = repository02.findOne(1234);
    entity02.setName("Name");
    repository02.save(entity02);

    //Added this to force a roll back for testing
    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}

More Related Contents:

  1. Joining two table entities in Spring Data JPA
  2. Disable all Database related auto configuration in Spring Boot
  3. Spring Data JPA – Multiple EnableJpaRepositories
  4. Spring Data optional parameter in query method
  5. Spring Boot Data JPA – Modifying update query – Refresh persistence context
  6. Spring Data and Native Query with pagination
  7. Spring Hibernate – Could not obtain transaction-synchronized Session for current thread
  8. @Transactional on @PostConstruct method
  9. Transaction marked as rollback only: How do I find the cause
  10. How to test Spring’s declarative caching support on Spring Data repositories?
  11. How to integrate spring with hibernate session and transaction management?
  12. Spring and hibernate: No Session found for current thread
  13. Hibernate Transactions and Concurrency Using attachDirty (saveOrUpdate)
  14. Do you need a database transaction for reading data?
  15. Spring Data: “delete by” is supported?
  16. Can Spring Data REST’s QueryDSL integration be used to perform more complex queries?
  17. The matching wildcard is strict, but no declaration can be found for element ‘tx:annotation-driven’
  18. How to use OrderBy with findAll in Spring Data
  19. How to configure Spring to make JPA (Hibernate) and JDBC (JdbcTemplate or MyBatis) share the same transaction
  20. @Autowired in static classes
  21. JPA / JTA / @Transactional Spring annotation
  22. Can’t Autowire @Repository annotated interface in Spring Boot
  23. Difference between save and saveAndFlush in Spring data jpa
  24. Access to Session using Spring JPA and Hibernate in order to enable filters
  25. spring data jpa @query and pageable
  26. Set default page size for JPA Pageable Object
  27. Could not build ClassFile – ArchiveException
  28. PostGIS Geometry saving: “Invalid endian flag value encountered.”
  29. Implementing Optimistic lock using Hibernate and Spring
  30. Multiple data source and schema creation in Spring Boot

Leave a Comment