一 简介

开发过程中，我们都需要和数据库打交道，小项目一个数据库就可以，代码也比较简单，只要连接一个数据库，本文中，由于业务需求，我们需要连接另一个库去查询数据，因此要对旧版本(只实现连接一个库的jpa)进行改造，使之可以同时连接两个库。

环境：springboot jdk1.8

数据库：mysql5.7

二改造过程

1、修改yml配置，将图1修改成图2.增加另一个数据库配置atp，同时jpa配置增加命名规则配置naming。

图1

图2

2、增加两个数据库配置对应的config

对两个数据库配置需要分别指定对应的manager和bean生效的路径basePackages.

两个数据库配置定义一个作为primary，默认指定它作为主数据库。

主数据库配置：

@Configuration@EnableTransactionManagement@EnableJpaRepositories(entityManagerFactoryRef = "autodataEntityManagerFactory", transactionManagerRef = "autodataTransactionManager", basePackages = {"test.autodata.dao.repository","test.autodata.common"})public class AutoDataConfig {@Primary@Bean(name = "autodataDataSource")@ConfigurationProperties(prefix = "spring.datasource.autodata")public DataSource autodataDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "autodataEntityManagerFactory")public LocalContainerEntityManagerFactoryBean entityManagerFactory(EntityManagerFactoryBuilder builder, @Qualifier("autodataDataSource") DataSource dataSource) {return builder.dataSource(dataSource).packages("test.autodata.dao.domain").persistenceUnit("autodata").build(); }@Bean(name = "autodataTransactionManager")public PlatformTransactionManager customerTransactionManager(@Qualifier("autodataEntityManagerFactory") EntityManagerFactory autodataEntityManagerFactory) {return new JpaTransactionManager(autodataEntityManagerFactory);}}从数据库配置类似主数据库配置，不用配置primary.

3修改启动类

原本只有一个数据库时，没有配置config的java配置文件，一些配置都直接配置在主启动类里。启动类配置了数据库jpa的两个属性，红色下划线部分，修改成两个数据库后将这部分配置在config里了，见上述配置.

图4

三测试

启动日志初始化两个数据库的配置信息。

图5

两个数据库的配置对应的basepackages目录不同，我们要在对应的目录下写代码。

第一个数据库要将实体类写在dao的domain下，将repository写在dao的repository目录下。第二个数据库则要写在atp对应的目录下。

图6

查询数据库命令如下：

@Repository

public interface CaseOrderTaskInfoRepository extends JpaRepository ,JpaSpecificationExecutor{

@Query(value = "select `order_id` from case_order_task_info s WHERE s.case_id=:caseId",nativeQuery = true)

List findList(@Param("caseId") String caseId);

}

public interface ReExecPlanInfoRepository extends JpaRepository, JpaSpecificationExecutor {

@Query(value = "select p from ReExecPlanInfo p ")

List queryList();

结果如下：

图7

图8

四总结

第一次配置jpa多个数据源，也参考网上各种资料，但是各种报错，最后终于配置成功。