Настройте два источника данных в Spring boot очень чистым способом

Я думаю, вы можете использовать AbstractRoutingDataSource, как указано в этом репо. https://github.com/kwon37xi/replication-datasource

При таком подходе вы можете добавить метод @Transactional с дополнительным свойством, чтобы указать, читается он или пишется. @Transactional(только для чтения = истина|ложь)

Я не думаю, что это на самом деле возможно (см. ниже), но это подход, чтобы хотя бы приблизиться.

Я бы начал с кода LazyConnectionDataSource, потому что из-за ваших требований вы не должны получать соединение, пока не узнаете, что вы собираетесь с ним делать.

Дайте ему ссылку на сеанс, поэтому, когда ему действительно нужен Connection, он проверяет сеанс, чтобы увидеть, не загрязнен ли он, и принять решение на основе того, что фактически использовалось DataSource.

Теперь о причине, почему я не думаю, что это действительно сработает. В обычном случае использования транзакция состоит из:

1. чтение некоторых данных

2. внесение некоторых изменений на его основе

3. сохранение этих изменений.

Эти шаги происходят строго последовательно, и хотя у нас есть такие типы, как Future в Java, мы не можем заглянуть в будущее и, следовательно, не можем на первом шаге решить, будет ли третий шаг.

Я предполагаю, что это можно рассматривать как подход с несколькими арендаторами, один арендатор будет только для чтения, другой арендатор будет запись.

Шаги по настройке уровня сохраняемости для поддержки нескольких арендаторов включают в себя:

• Hibernate, JPA и свойства источников данных. Что-то вроде:

application.yml

...
multitenancy:
  dvdrental:
    dataSources:
      -
        tenantId: readonly
        url: jdbc:postgresql://172.16.69.133:5432/db_dvdrental
        username: user_dvdrental
        password: changeit
        driverClassName: org.postgresql.Driver
      -
        tenantId: write
        url: jdbc:postgresql://172.16.69.133:5532/db_dvdrental
        username: user_dvdrental
        password: changeit
        driverClassName: org.postgresql.Driver
...

MultiTenantJpaConfiguration.java

 ...
 @Configuration
 @EnableConfigurationProperties({ MultiTenantDvdRentalProperties.class, JpaProperties.class })
 @ImportResource(locations = { "classpath:applicationContent.xml" })
 @EnableTransactionManagement
 public class MultiTenantJpaConfiguration {

   @Autowired
   private JpaProperties jpaProperties;

   @Autowired
   private MultiTenantDvdRentalProperties multiTenantDvdRentalProperties;
 ...
 }

MultiTenantDvdRentalProperties.java

...
@Configuration
@ConfigurationProperties(prefix = "multitenancy.dvdrental")
public class MultiTenantDvdRentalProperties {

  private List<DataSourceProperties> dataSourcesProps;
  // Getters and Setters

  public static class DataSourceProperties extends org.springframework.boot.autoconfigure.jdbc.DataSourceProperties {

    private String tenantId;
    // Getters and Setters
  }
}

• Компоненты источников данных

MultiTenantJpaConfiguration.java

 ...
 public class MultiTenantJpaConfiguration {
 ...
   @Bean(name = "dataSourcesDvdRental" )
   public Map<String, DataSource> dataSourcesDvdRental() {
       ...
   }
 ...
 }

• Компонент фабрики менеджера сущностей

MultiTenantJpaConfiguration.java

 ...
 public class MultiTenantJpaConfiguration {
 ...
   @Bean
   public MultiTenantConnectionProvider multiTenantConnectionProvider() {
       ...
   }

   @Bean
   public CurrentTenantIdentifierResolver currentTenantIdentifierResolver() {
       ...
   }

   @Bean
   public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean(MultiTenantConnectionProvider multiTenantConnectionProvider,
     CurrentTenantIdentifierResolver currentTenantIdentifierResolver) {
       ...  
   }
 ...
 }

• Компонент менеджера транзакций

MultiTenantJpaConfiguration.java

 ...
 public class MultiTenantJpaConfiguration {
 ...
   @Bean
   public EntityManagerFactory entityManagerFactory(LocalContainerEntityManagerFactoryBean entityManagerFactoryBean) {
       ...
   }

   @Bean
   public PlatformTransactionManager txManager(EntityManagerFactory entityManagerFactory) {
       ...
   }
 ...
 }

• Spring Data JPA и конфигурация поддержки транзакций

applicationContent.xml

...
<jpa:repositories base-package="com.asimio.dvdrental.dao" transaction-manager-ref="txManager" />
<tx:annotation-driven transaction-manager="txManager" proxy-target-class="true" />
...

ActorDao.java

public interface ActorDao extends JpaRepository<Actor, Integer> {
}

В зависимости от ваших потребностей можно сделать что-то вроде этого:

...
@Autowired
private ActorDao actorDao;
...

// Read feature
...
DvdRentalTenantContext.setTenantId("readonly");
this.actorDao.findOne(...);
...

// Or write
DvdRentalTenantContext.setTenantId("write");
this.actorDao.save(...);
...

Установка tenantId может быть выполнена в фильтре сервлета/перехватчике Spring MVC/потоке, который будет выполнять операцию JPA и т. д.

Более подробную информацию о многопользовательском подходе можно найти в моем блоге по адресу http://tech.asimio.net/2017/01/17/Multitenant-applications-using-Spring-Boot-JPA-Hibernate-and-Postgres.html