java - Spring Boot 多数据源 - 只工作一个

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: 42000o.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，它就可以工作。

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

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

第一个数据库配置:

@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 必须在代表数据库中表的实体中使用。在您的情况下，将位于 Bvp 和 DbUser 类。