如何在 MySQL 和 MariaDB 的 Spring Boot 应用程序中配置多个(两个以上)数据源,

Posted

技术标签:

【中文标题】如何在 MySQL 和 MariaDB 的 Spring Boot 应用程序中配置多个(两个以上)数据源,【英文标题】:How can I configure multiple(more than two) data sources in my spring boot application in MySQL and MariaDB, 【发布时间】:2021-11-22 02:28:03 【问题描述】:

我必须在 Spring Boot 应用程序中运行时连接到多个数据源,其中亚马逊 RDS 分别部署了 mysql 和 MariaDB 实例。目前,两者都是独立存在的 MariaDB 实例。我已经使用了通常的弹簧启动配置,例如这里 Multiple data source and schema creation in Spring Boot

我在这里遇到一个问题,即我无法连接到辅助数据源,而我能够连接到主数据源。 这里有一些代码sn-ps。

另外,我想知道在运行时回退到相同模式的其他数据库实例的任何机制,如果原始数据库实例关闭而不影响应用程序或重新启动它。我对此一无所知。

import com.zaxxer.hikari.HikariDataSource;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
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 org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.util.HashMap;

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "a.b.c.d.e",
        entityManagerFactoryRef = "aEntityManagerFactory",
        transactionManagerRef = "aTransactionManager"
)
public class aConfiguration 
    @Bean
    @Primary
    @ConfigurationProperties("app.datasource.a")
    public DataSourceProperties aDataSourceProperties() 
        return new DataSourceProperties();
    

    @Bean
    @Primary
    @ConfigurationProperties("app.datasource.a.configuration")
    public DataSource aDataSource() 
        return aDataSourceProperties().initializeDataSourceBuilder()
                .type(HikariDataSource.class).build();
    

    @Bean
    public EntityManagerFactoryBuilder entityManagerFactoryBuilder() 
        return new EntityManagerFactoryBuilder(new HibernateJpaVendorAdapter(), new HashMap<>(), null);
    

    @Primary
    @Bean(name = "aEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean aEntityManagerFactory(EntityManagerFactoryBuilder builder) 
        return builder
                .dataSource(aDataSource())
                .packages(SomeQualifiedEntity.class)
                .build();
    

    @Primary
    @Bean
    public PlatformTransactionManager aTransactionManager(
            final @Qualifier("aEntityManagerFactory") LocalContainerEntityManagerFactoryBean aEntityManagerFactory) 
        return new JpaTransactionManager(aEntityManagerFactory.getObject());
    

import com.zaxxer.hikari.HikariDataSource;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
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 org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.util.HashMap;

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "u.v.w.x.y",
        entityManagerFactoryRef = "bEntityManagerFactory",
        transactionManagerRef = "bTransactionManager"
)
public class aConfiguration 
    @Bean
    @Primary
    @ConfigurationProperties("app.datasource.b")
    public DataSourceProperties bDataSourceProperties() 
        return new DataSourceProperties();
    

    @Bean
    @Primary
    @ConfigurationProperties("app.datasource.b.configuration")
    public DataSource bDataSource() 
        return bDataSourceProperties().initializeDataSourceBuilder()
                .type(HikariDataSource.class).build();
    

    @Bean
    public EntityManagerFactoryBuilder entityManagerFactoryBuilder() 
        return new EntityManagerFactoryBuilder(new HibernateJpaVendorAdapter(), new HashMap<>(), null);
    

    @Primary
    @Bean(name = "bEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean bEntityManagerFactory(EntityManagerFactoryBuilder builder) 
        return builder
                .dataSource(bDataSource())
                .packages(SomeQualifiedEntity.class)
                .build();
    

    @Primary
    @Bean
    public PlatformTransactionManager bTransactionManager(
            final @Qualifier("bEntityManagerFactory") LocalContainerEntityManagerFactoryBean bEntityManagerFactory) 
        return new JpaTransactionManager(aEntityManagerFactory.getObject());
    

app.datasource.a.url=
app.datasource.a.username=
app.datasource.a.password=
app.datasource.a.driverClassName=org.mariadb.jdbc.Driver

app.datasource.b.url=
app.datasource.b.username=
app.datasource.b.password=
app.datasource.b.driverClassName=org.mariadb.jdbc.Driver

我希望我可以提供实体和存储库,但我不能。很抱歉。

【问题讨论】:

【参考方案1】:

我在 application.properties 文件中配置了我的数据库/数据源。尽管我只有一个数据库,但出于好奇,我尝试了多个数据库,并且成功了。所以也许在那里试试?格式如下:

spring.h2.console.enabled=true
spring.datasource.url=jdbc:h2:mem:testdb
spring.data.jpa.repositories.bootstrap-mode=default

【讨论】:

你已经发送了内存数据库设置,不过我可以试试最后一行。 它只是我在 5 秒谷歌搜索后发现的一个例子,它不是来自我的项目。但应该也适用于不在内存数据库中,不是吗? 不 ? 它不是。

以上是关于如何在 MySQL 和 MariaDB 的 Spring Boot 应用程序中配置多个(两个以上)数据源,的主要内容,如果未能解决你的问题,请参考以下文章

如何MySQL和MariaDB数据库修改root密码

如何在 MySQL 和 MariaDB 的 Spring Boot 应用程序中配置多个(两个以上)数据源,

如何将LabVIEW连接到MySQL MariaDB

linux如何安装数据和简单使用mysql-mariadb

如何在 MacOS 上重置 MySQL 或 MariaDB(使用 brew 安装)?

如何在centos7中安装mysql