sql >> Database teknologi >  >> RDS >> PostgreSQL

Spring Boot - Samme repository og samme enhed for forskellige databaser

Opret 2 konfigurationsfiler med forskellige datakilder, og disse 2 konfigurationsfiler vil have forskellige specifikationer for 2 forskellige jpa repository class.men kan have samme domæneklasse.

step1>I din egenskabsfil har du 2 datakildedetaljer.

spring.datasource.url=jdbc:postgresql://localhost:5432/DB2017_test
spring.datasource.username=xxx
spring.datasource.password=xxx


# DB2018 DB - ""
spring.datasource2.url=jdbc:postgresql://localhost:5432/DB2018_test
spring.datasource2.username=xxx
spring.datasource2.password=xxx

step2>Opret derefter konfigurationsfil til den første datakilde

package com.package1;

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
  entityManagerFactoryRef = "entityManagerFactory",
  basePackages = { "com.package1.repo" } 
)
public class DB2017Config {

  @Primary
  @Bean(name = "dataSource")
  @ConfigurationProperties(prefix = "spring.datasource")
  public DataSource dataSource() {
    return DataSourceBuilder.create().build();
  }

  @Primary
  @Bean(name = "entityManagerFactory")
  public LocalContainerEntityManagerFactoryBean 
  entityManagerFactory(
    EntityManagerFactoryBuilder builder,
    @Qualifier("dataSource") DataSource dataSource
  ) {
    return builder
      .dataSource(dataSource)
      .packages("com.domain")
      .persistenceUnit("foo")
      .build();
  }

  @Primary
  @Bean(name = "transactionManager")
  public PlatformTransactionManager transactionManager(
    @Qualifier("entityManagerFactory") EntityManagerFactory 
    entityManagerFactory
  ) {
    return new JpaTransactionManager(entityManagerFactory);
  }
}

step3> Tilsvarende opret en anden konfigurationsfil til anden datakilde,

@EnableJpaRepositories(
  entityManagerFactoryRef = "entityManagerFactory",
  basePackages = { "com.package2.repo" }

Og skift præfiks

@ConfigurationProperties(prefix = "spring.datasource2")

Nu vil du have 2 lignende RequestRepository1 og RequestRepository2 i henholdsvis pakke1 og pakke2 som nævnt ovenfor (basePackages ={ "com.package1.repo" }).

step4>Alle sæt autowire 2 forskellige repo.

@Autowired
private final RequestRepository1  repo1;
@Autowired
private final RequestRepository2  repo2;

Brug dem derefter.

List<Request> listAdesioni = repo1.findByCodiceFiscale(codicefiscale);
List<Request> listAdesioni = repo2.findByCodiceFiscale(codicefiscale);



  1. Sådan itereres gennem PostgreSQL jsonb-arrayværdier med det formål at matche i en forespørgsel

  2. Tabeller, jeg opretter, der starter med dotNetChat_ forsvinder efter genstart af MySQL

  3. Oracle Konverter TIMESTAMP med Timezone til DATE

  4. MySQL-forbindelse tegnsæt problemer