Spring 启动多个数据源 - 只工作一个

Question

我有问题，当我尝试使用 2 个数据库时出现错误

我的错误日志：

NoUniqueBeanDefinitionException: No qualifying bean of type [javax.sql.DataSource] is defined: expected single matching bean but found 2: reportDataSource,secondDataSource

然后如果我在第一个数据源上设置@Primary，我会在第二个数据库查询时出错：

o.h.engine.jdbc.spi.SqlExceptionHelper : SQL Error: 942, SQLState: 42000 o.h.engine.jdbc.spi.SqlExceptionHelper : ORA-00942: table or view does not exist

org.springframework.dao.InvalidDataAccessResourceUsageException: could not extract ResultSet; SQL [n/a]; nested exception is org.hibernate.exception.SQLGrammarException: could not extract ResultSet

SQL 如果我运行它在 DB 上手动工作。

Hibernete 没有看到我的 table 因为不是 @Primary 数据源。当我从应用程序中删除第一个数据库时，第二个工作正常。在我看来，两个实体管理器都使用@Primary 数据源，这就是为什么 Hibernate 看不到第二个 table 的原因。

我不知道我现在应该做什么。欢迎任何帮助。

第一个 DbConfig：

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "reportEntityMangerFactory", 
        basePackages = {"com.company.db.report.repository"}
)
public class ReportDbConfig {
    
    @Bean(name = "reportDataSource")
    public DataSource dataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
        dataSource.setUrl("jdbc:oracle:thin:@127.0.0.1:1521:FIRST");
        dataSource.setUsername("test");
        dataSource.setPassword("test");

        return dataSource;
    }
    
    @Bean(name = "reportEntityManager")
    public EntityManager entityManager() {
        return entityManagerFactory().createEntityManager();
    }
    
    @Bean(name = "reportEntityMangerFactory")
    public EntityManagerFactory entityManagerFactory() {
        HashMap<String, Object> properties = new HashMap<String, Object>();
        properties.put("hibernate.hbm2ddl.auto", "validate");
        properties.put("hibernate.dialect", "org.hibernate.dialect.Oracle10gDialect");
        HibernateJpaVendorAdapter jpaVendorAdapter = new HibernateJpaVendorAdapter();
        
        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setDataSource(dataSource());
        factory.setJpaVendorAdapter(jpaVendorAdapter);
        factory.setPackagesToScan("com.company.db.report.entity");
        factory.setJpaPropertyMap(properties);
        factory.afterPropertiesSet();
        return factory.getObject();
    }
}

第二个数据库配置：

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "secondEntityMangerFactory",
        basePackages = {"com.company.db.second.repository"}
)
public class SecondDbConfig {

    @Bean(name = "secondDataSource")
    public DataSource dataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
        dataSource.setUrl("jdbc:oracle:thin:@127.0.0.1:1521:SECOND");
        dataSource.setUsername("test");
        dataSource.setPassword("test");

        return dataSource;
    }
    
    @Bean(name = "secondEntityManager")
    public EntityManager entityManager() {
        return entityManagerFactory().createEntityManager();
    }

    @Bean(name = "secondEntityMangerFactory")
    public EntityManagerFactory entityManagerFactory() {
        HashMap<String, Object> properties = new HashMap<String, Object>();
        properties.put("hibernate.hbm2ddl.auto", "validate");
        properties.put("hibernate.dialect", "org.hibernate.dialect.Oracle10gDialect");
        HibernateJpaVendorAdapter jpaVendorAdapter = new HibernateJpaVendorAdapter();
        
        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setDataSource(dataSource());
        factory.setJpaVendorAdapter(jpaVendorAdapter);
        factory.setPackagesToScan("com.company.db.second.entity");
        factory.setJpaPropertyMap(properties);
        factory.afterPropertiesSet();
        return factory.getObject();
    }
}

来自第一个数据库的存储库 (com.company.db.report.repository.DbUserRepository):

@Repository
@Table(name = "DB_USER")
public interface DbUserRepository extends JpaRepository<DbUser, Long> {
    
    List<DbUser> findAll();
    
    DbUser save(DbUser entity);
}

来自第二个数据库的存储库 (com.company.db.second.repository.BvpRepository):

@Repository
@Table(name = "BVP")
public interface BvpRepository extends JpaRepository<Bvp, Long> {
    
    List<Bvp> findAll();
    
    Bvp save(Bvp entity);
}

第一个数据库的实体在 com.company.db.report.entity，对于 com.company.db.second.entity.

中的第二个数据库

类似的问题是 there，但这个答案没有帮助。

Answer 1

如果您需要检查配置，请查看此 link 以便重构并使您的代码更具可读性。

我可以看到您正在使用存储库中的 @Table。 @Table 必须用在代表数据库中 table 的实体中。在您的情况下，将位于 Bvp 和 DbUser 类.

Spring 启动多个数据源 - 只工作一个

Spring Boot Multiple Datasource - work only one

java

hibernate

spring-boot

spring-java-config