如何使用Spring JPA和Hikari CP连接SQL数据库_spring data jpa 连接池

作者：Cpp五条 | 2024-02-28 17:45:13

踩

spring data jpa 连接池

Spring Data JPA是 Spring Data Family中最常见和最成熟的框架。

微信搜索关注《Java学研大本营》，加入读者群，分享更多精彩

首先，让我们在深入讨论之前设定议程。在这篇文章中，我们将只讨论如何使用 Spring Data JPA 框架使用 Hikari CP 作为连接池层进行多数据库连接。所以读者应该对 Spring Boot 、 Spring Data JPA 和连接池有基本的了解。

众所周知，Spring Data JPA 是 Spring Data Family 中最常见和最成熟的框架，它将在我们的应用程序 DAO 层中发挥作用。

我们需要做的就是在我们的 pom 中添加依赖项，并在应用程序属性文件中配置我们的数据库连接详细信息。所有其他事情都将由 Spring Boot 的自动配置魔法来处理，这意味着无需编写任何单个 Java 代码来配置数据源。

在高层次上，Spring 自动配置将使用我们在属性文件中提供的连接详细信息为数据源、实体管理器和事务创建 bean。

数据源：形成连接对象，包含数据库连接详细信息

EntityManager ：它与数据源具有一对一的关系，管理 JPA 实体及其持久化操作。

事务管理器：它与实体管理器具有一对一的关系。它处理事务。

之所以讨论这个 JPA 内部，是为了让您知道 JPA 需要这三个 bean 来连接数据库并执行操作。

因此，对于每个数据库连接，您都需要创建这些 bean。考虑一下，如果您的应用程序想要连接 2 个不同的数据库，那么您需要为每个数据库创建这些 bean。这意味着我们在配置阶段创建了多个相同类型的 bean。因此，我们需要用“@Primary”注释其中一个 bean。

所以在这里，我将展示一个 Spring JPA 多数据库配置的示例，在我的示例中，将使用 2 个数据库。只是为了解释起见，假设一个数据库是 Oracle（主），另一个是 My SQL。

主要数据源配置：

这里要注意的一件事是，您必须将 JPA 存储库和实体包链接到 entityManager。

“@EnableJpaRepositories”有一个属性“basePackages”。您必须提及此数据库的存储库文件包名称作为此属性的值。如果您有多个要扫描的包，请用逗号分隔。

“LocalContainerEntityManagerFactoryBean”有一个属性“packageToScan”。您必须在此属性中提及相应的 JPA 实体文件包名称。如果要扫描多个包，则将其传递到字符串数组中。


@Configuration
@EnableConfigurationProperties({PrimaryDataSourceProperties.class})
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef="entityManagerFactory",
        basePackages={"com.primary.repo"}
)
public class PrimaryDataSource {
 
    @Autowired
    PrimaryDataSourceProperties dataSourceProp;
 
    @Primary
    @Bean(name="dataSource")
    public DataSource primaryDataSource(){
        HikariConfig hikariConfig = new HikariConfig();
        hikariConfig.setUserName(dataSourceProp.getUsername());
        hikariConfig.setPassword(dataSourceProp.getPassword());
        hikariConfig.setJdbcUrl(dataSourceProp.getUrl());
        hikariConfig.setDriverClassName(dataSourceProp.getDriverClassName());
        hikariConfig.setMaximumPoolSize(dataSourceProp.getMaxPoolSize());
        hikariConfig.setMinimumIdle(dataSourceProp.getMinimumIdle());
        hikariConfig.setConnectionTimeout(dataSourceProp.getConnectionTimeOut());
        hikariConfig.setIdleTimeout(dataSourceProp.getIdleTimeOut());
        hikariConfig.setPoolName(dataSourceProp.getPoolName());
        return new HikariDataSource(hikariConfig);
    }
 
    @Primary
    @Bean(name="entityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactory(EntityManagerFactoryBuilder builder,
                                                                       @Qualifier("dataSource") DataSource datasource){
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(datasource);
        em.setPackageToScan(new String[]{"com.primary.entity"});
        HibernateJpaVendorAdaptor vendorAdaptor = new HibernateJpaVendorAdaptor();
        em.setJpaVendorAdaptor(vendorAdaptor);
        HashMap<String, Object> properties = new HashMap<>();
        properties.put("hibernate.dialect", "org.hibernate.dialect.OracleDialect");
        em.setJpaPropertyMap(properties);
        return em;
    }
 
    @Primary
    @Bean(name="transactionManager")
    public PlatformTransactionManager transactionManager(@Qualifier("entityManagerFactory") EntityManagerFactory entityManagerFactory){
        return new JpaTransactionManager(entityManagerFactory);
    }
 
}


@ConfigurationProperties(prefix="primary.datasource")
public class PrimaryDataSourceProperties{
    private String url;
    private String username;
    private String password;
    private String driverClassName;
    private int connectionTimeOut;
    private int idleTimeOut;
    private int maxPoolSize;
    private int minimumIdle;
    private String poolName;
 
    //Getters & Setters
}

辅助数据源配置：


@Configuration
@EnableConfigurationProperties({SecondaryDataSourceProperties.class})
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef="secondaryEntityManagerFactory",
        basePackages={"com.secondary.repo"}
)
public class PrimaryDataSource {
 
    @Autowired
    PrimaryDataSourceProperties dataSourceProp;
 
    @Primary
    @Bean(name="secondaryDataSource")
    public DataSource primaryDataSource(){
        HikariConfig hikariConfig = new HikariConfig();
        hikariConfig.setUserName(dataSourceProp.getUsername());
        hikariConfig.setPassword(dataSourceProp.getPassword());
        hikariConfig.setJdbcUrl(dataSourceProp.getUrl());
        hikariConfig.setDriverClassName(dataSourceProp.getDriverClassName());
        hikariConfig.setMaximumPoolSize(dataSourceProp.getMaxPoolSize());
        hikariConfig.setMinimumIdle(dataSourceProp.getMinimumIdle());
        hikariConfig.setConnectionTimeout(dataSourceProp.getConnectionTimeOut());
        hikariConfig.setIdleTimeout(dataSourceProp.getIdleTimeOut());
        hikariConfig.setPoolName(dataSourceProp.getPoolName());
        return new HikariDataSource(hikariConfig);
    }
 
    @Primary
    @Bean(name="secondaryEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactory(EntityManagerFactoryBuilder builder,
                                                                       @Qualifier("secondaryDataSource") DataSource datasource){
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(datasource);
        em.setPackageToScan(new String[]{"com.secondary.entity"});
        HibernateJpaVendorAdaptor vendorAdaptor = new HibernateJpaVendorAdaptor();
        em.setJpaVendorAdaptor(vendorAdaptor);
        HashMap<String, Object> properties = new HashMap<>();
        properties.put("hibernate.dialect", "org.hibernate.dialect.MySQLDialect");
        em.setJpaPropertyMap(properties);
        return em;
    }
 
    @Primary
    @Bean(name="secondaryTransactionManager")
    public PlatformTransactionManager transactionManager(@Qualifier("secondaryEntityManagerFactory") EntityManagerFactory entityManagerFactory){
        return new JpaTransactionManager(entityManagerFactory);
    }
 
}


@ConfigurationProperties(prefix="secondary.datasource")
public class SecondaryDataSourceProperties{
    private String url;
    private String username;
    private String password;
    private String driverClassName;
    private int connectionTimeOut;
    private int idleTimeOut;
    private int maxPoolSize;
    private int minimumIdle;
    private String poolName;
 
    //Getters & Setters
}


primary.datasource.username=test
primary.datasource.password=test
primary.datasource.url=jdbc:oracle:thin:@test:8899/test
primary.datasource.connectionTimeOut=60000
primary.datasource.idleTimeOut=900000
primary.datasource.maxPoolSize=10
primary.datasource.minimumIdle=10
 
secondary.datasource.username=test
secondary.datasource.password=test
secondary.datasource.url=jdbc:mysql:thin:@test:8899/test
secondary.datasource.connectionTimeOut=60000
secondary.datasource.idleTimeOut=900000
secondary.datasource.maxPoolSize=10
secondary.datasource.minimumIdle=10

如何使用Spring JPA和Hikari CP连接SQL数据库_spring data jpa 连接池

主要数据源配置：

辅助数据源配置：

推荐书单

《项目驱动零起点学Java》

精彩回顾