。

这可能是由于各种原因#xff0c;例如遗留系统集成、不同类型的数据存储需求#xff0c;或者仅仅是为了优化性能。

Spring

Boot

具有灵活的配置和强大的数据访问库#xff0c;可以轻松配置多个数据库。

在本综…在现代微服务架构中通常需要与多个数据库交互的服务。

这可能是由于各种原因例如遗留系统集成、不同类型的数据存储需求或者仅仅是为了优化性能。

Spring

Boot

具有灵活的配置和强大的数据访问库可以轻松配置多个数据库。

在本综合指南中我们将探讨如何在

Spring

微服务通常需要与各种数据库交互。

每个微服务可能需要不同类型的数据库例如用于事务数据的

SQL

为配置和管理多个数据源提供了出色的支持使其成为现代微服务架构的理想选择。

2.为什么要使用多个数据库

遗留系统集成与遗留系统的现有数据库集成。

优化性能使用针对特定类型的数据例如关系型与非关系型优化的不同数据库。

数据隔离出于安全、合规或组织原因分离数据。

可扩展性在不同的数据库之间分配数据负载以提高性能。

3.设置

dependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-jpa/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdcom.h2database/groupIdartifactIdh2/artifactIdscoperuntime/scope/dependencydependencygroupIdorg.postgresql/groupIdartifactIdpostgresql/artifactIdscoperuntime/scope/dependency

/dependencies

在application.yml或application.properties文件中配置每个数据库的连接属性。

application.yml

jdbc:h2:mem:primarydbdriver-class-name:

sapassword:

jdbc:postgresql://localhost:5432/secondarydbdriver-class-name:

postgrespassword:

org.hibernate.dialect.H2Dialecthibernate:ddl-auto:

updatesecondary:database-platform:

org.hibernate.dialect.PostgreSQLDialecthibernate:ddl-auto:

update

org.springframework.beans.factory.annotation.Qualifier;

import

org.springframework.boot.context.properties.ConfigurationProperties;

import

org.springframework.boot.jdbc.DataSourceBuilder;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;

import

org.springframework.data.jpa.repository.config.EnableJpaRepositories;

import

org.springframework.orm.jpa.JpaTransactionManager;

import

org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;

import

org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;

import

org.springframework.transaction.PlatformTransactionManager;

import

javax.persistence.EntityManagerFactory;

import

EnableJpaRepositories(basePackages

com.example.primary.repository,entityManagerFactoryRef

primaryEntityManagerFactory,transactionManagerRef

public

primaryDataSource)ConfigurationProperties(prefix

spring.datasource.primary)public

DataSource

DataSourceBuilder.create().build();}Bean(name

primaryEntityManagerFactory)public

LocalContainerEntityManagerFactoryBean

primaryEntityManagerFactory(Qualifier(primaryDataSource)

DataSource

{LocalContainerEntityManagerFactoryBean

new

LocalContainerEntityManagerFactoryBean();em.setDataSource(dataSource);em.setPackagesToScan(new

String[]

HibernateJpaVendorAdapter();em.setJpaVendorAdapter(vendorAdapter);return

em;}Bean(name

primaryTransactionManager)public

primaryTransactionManager(Qualifier(primaryEntityManagerFactory)

EntityManagerFactory

JpaTransactionManager(entityManagerFactory);}

辅助数据源配置

org.springframework.beans.factory.annotation.Qualifier;

import

org.springframework.boot.context.properties.ConfigurationProperties;

import

org.springframework.boot.jdbc.DataSourceBuilder;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;

import

org.springframework.data.jpa.repository.config.EnableJpaRepositories;

import

org.springframework.orm.jpa.JpaTransactionManager;

import

org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;

import

org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;

import

org.springframework.transaction.PlatformTransactionManager;

import

javax.persistence.EntityManagerFactory;

import

EnableJpaRepositories(basePackages

com.example.secondary.repository,entityManagerFactoryRef

secondaryEntityManagerFactory,transactionManagerRef

public

secondaryDataSource)ConfigurationProperties(prefix

spring.datasource.secondary)public

DataSource

DataSourceBuilder.create().build();}Bean(name

secondaryEntityManagerFactory)public

LocalContainerEntityManagerFactoryBean

secondaryEntityManagerFactory(Qualifier(secondaryDataSource)

DataSource

{LocalContainerEntityManagerFactoryBean

new

LocalContainerEntityManagerFactoryBean();em.setDataSource(dataSource);em.setPackagesToScan(new

String[]

HibernateJpaVendorAdapter();em.setJpaVendorAdapter(vendorAdapter);return

em;}Bean(name

secondaryTransactionManager)public

secondaryTransactionManager(Qualifier(secondaryEntityManagerFactory)

EntityManagerFactory

JpaTransactionManager(entityManagerFactory);}

定义实体管理器

为每个数据库定义实体类。

确保将它们放在配置类中指定的相应包中。

主数据库实体

javax.persistence.GeneratedValue;

import

javax.persistence.GenerationType;

import

GenerationType.IDENTITY)private

Long

javax.persistence.GeneratedValue;

import

javax.persistence.GenerationType;

import

GenerationType.IDENTITY)private

Long

com.example.primary.repository;

import

com.example.secondary.entity.SecondaryEntity;

import

org.springframework.data.jpa.repository.JpaRepository;

public

com.example.secondary.repository;

import

com.example.secondary.entity.SecondaryEntity;

import

org.springframework.data.jpa.repository.JpaRepository;

public

com.example.primary.entity.PrimaryEntity;

import

com.example.primary.repository.PrimaryRepository;

import

com.example.secondary.entity.SecondaryEntity;

import

com.example.secondary.repository.SecondaryRepository;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.web.bind.annotation.GetMapping;

import

org.springframework.web.bind.annotation.RestController;

RestController

primaryRepository;Autowiredprivate

SecondaryRepository

secondaryRepository;GetMapping(/test)public

String

PrimaryEntity();primaryEntity.setName(Primary

Entity);primaryRepository.save(primaryEntity);SecondaryEntity

secondaryEntity

SecondaryEntity();secondaryEntity.setDescription(Secondary

Entity);secondaryRepository.save(secondaryEntity);return

Entities