Блог

Я следил за многими учебными пособиями и рассмотрел множество ответов (на SO и других сайтах), и я вполне уверен, что ничего не пропустил, но я не могу заставить два источника данных / EntityManagers работать в моей среде.

Это то, что у меня есть

DbADataSourceConfig.java

 package com.myorg.rest.config.dba;

import ...

@Configuration
// @EnableJpaRepositories(
//     basePackages = "com.myorg.rest.dao.dbA",
//     entityManagerFactoryRef = "dbAEntityManager",
//     transactionManagerRef = "dbATransactionManager"
//     )
@EnableTransactionManagement
public class DbADataSourceConfig {

    @Autowired
    private EnvProperties settings;

    @Bean
    @Primary
    public DataSource prjDataSource() {
        DataSourceProperties ds = settings.getdbADatasource();
        return ds.initializeDataSourceBuilder().type(BasicDataSource.class).build();
    }

    @Bean(name = "dbAEntityManager")
    @Primary
    public LocalContainerEntityManagerFactoryBean dbAEntityManager() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(prjDataSource());
        em.setPackagesToScan(new String[] { "com.myorg.model.entities.dba" });
        em.setPersistenceUnitName("dbAUnit");

        JpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        em.setJpaProperties(additionalProperties());
        // em.afterPropertiesSet();

        return em;
    }

    @Bean(name = "dbATransactionManager")
    @Primary
    public PlatformTransactionManager dbATransactionManager() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(dbAEntityManager().getObject());

        return transactionManager;
    }

    Properties additionalProperties() {
        Properties properties = new Properties();
        properties.setProperty("hibernate.dialect", "org.hibernate.dialect.MySQL5Dialect");
        return properties;
    }
}
  

DbBDataSourceConfig.java

 package com.myorg.rest.config.dbb;

import ...

@Configuration
// @EnableJpaRepositories(
//     basePackages = "com.myorg.rest.dao.dbB",
//     entityManagerFactoryRef = "dbBEntityManager",
//     transactionManagerRef = "dbBTransactionManager"
//     )
@EnableTransactionManagement
public class DbBDataSourceConfig {

    @Autowired
    private EnvProperties settings;

    @Bean
    @Primary
    public DataSource prjDataSource() {
        DataSourceProperties ds = settings.getdbBDatasource();
        return ds.initializeDataSourceBuilder().type(BasicDataSource.class).build();
    }

    @Bean(name = "dbBEntityManager")
    @Primary
    public LocalContainerEntityManagerFactoryBean dbBEntityManager() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(prjDataSource());
        em.setPackagesToScan(new String[] { "com.myorg.model.entities.dbb" });
        em.setPersistenceUnitName("dbBUnit");

        JpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        em.setJpaProperties(additionalProperties());
        // em.afterPropertiesSet();

        return em;
    }

    @Bean(name = "dbBTransactionManager")
    @Primary
    public PlatformTransactionManager dbBTransactionManager() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(dbBEntityManager().getObject());

        return transactionManager;
    }

    Properties additionalProperties() {
        Properties properties = new Properties();
        properties.setProperty("hibernate.dialect", "org.hibernate.dialect.MySQL5Dialect");
        return properties;
    }
}
  

AbstractDBADAO.java

 package com.myorg.rest.dao.dba.base;

public abstract class AbstractDBADAO<T extends Serializable> implements IAbstractJpaDAO<T> {

    private Class<T> clazz;

    @PersistenceContext(unitName = "dbAUnit")
    private EntityManager entityManager;

    public AbstractDBADAO(Class<T> clazzToSet) {
        this.clazz = clazzToSet;
    }

    public T findOne(String id) {
        return entityManager.find(clazz, id);
    }

    public List<T> findAll() {
        CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder();
        CriteriaQuery<T> entityQuery = criteriaBuilder.createQuery(clazz);
        entityQuery.from(clazz);
        return entityManager.createQuery(entityQuery).getResultList();
    }

    public void create(T entity) {
        entityManager.persist(entity);
    }

    public T update(T entity) {
        return entityManager.merge(entity);
    }

    public void delete(T entity) {
        entityManager.remove(entity);
    }

    public void deleteById(String entityId) {
        T entity = findOne(entityId);
        delete(entity);
    }
}
  

and last IAbstractJpaDAO.java

 package com.myorg.rest.dao.dba.base;

import ...

public interface IAbstractJpaDAO<T extends Serializable> {

    T findOne(String id);

    List<T> findAll();

    void create(T entity);

    T update(T entity);

    void delete(T entity);

    void deleteById(String entityId);

}
  

Of course, there’s also a bunch of @Repository s extending IAbstractDAO interface and a corresponding bunch of @Service s extending AbstractDAO<T> , but those are just skeletons like

EntityARepo.java

 package com.myorg.rest.dao.dba.repositories;

import ...

@Repository
public interface EntityARepo extends IAbstractJpaDAO<EntityA> {

}
  

EntityAService.java

 package com.myorg.rest.dao.dba.services;

import ...

@Service
public class EntityAService extends AbstractDBADAO<EntityA> implements EntityARepo {

    public EntityAService() {
        super(EntityA.class);
    }
}
  

Аналогично, для второй базы данных (dbB) настроена целая куча классов.

Проблема

Что бы я ни делал, я получаю следующую проблему (или что-то очень похожее):

 org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type 'javax.persistence.EntityManager' available: expected single matching bean but found 2: org.springframework.orm.jpa.SharedEntityManagerCreator#0,org.springframework.orm.jpa.SharedEntityManagerCreator#1
            at org.springframework.beans.factory.config.DependencyDescriptor.resolveNotUnique(DependencyDescriptor.java:220)
            at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1285)
            at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1227)
  

Из того, что я понимаю, @PersistenceContext не удается разрешить правильно LocalContainerEntityManagerFactoryBean . У них обоих есть setPersistenceUnitName('dbXUnit') , поэтому они должны быть в состоянии правильно разрешаться, верно?.

У меня нет никакого persistence.xml файла, я все делаю программно.

Что я пробовал до сих пор

1. Очевидно, приведенный выше код.
2. Кроме того, вы заметите, что есть раздел с комментариями для @EnableJpaRepositories ; это тоже не работает.
3. Я также безуспешно пытался создать PersistenceUnitManager для каждого из классов конфигурации источника данных.
4. Я пробовал @Autowired , с и без @PersistenceContext , тоже не повезло.
5. Я пробовал @PersistenceContext использовать сеттер и использовать @Qualifier на входе EntityManager , тоже не повезло.
6. Я пробовал с @Primary декораторами и без них.

Пожалуйста, имейте в виду, что любые несоответствия между размещенными выше файлами, безусловно, являются ошибкой копирования / вставки, мне пришлось редактировать имена, чтобы сохранить конфиденциальность. Также обратите внимание, что код, который у меня есть, компилируется, запускается и не выводит никаких других ошибок, кроме перечисленных выше. Кроме того, если настроен только один из этих классов конфигурации базы данных, проект выполняется должным образом, и я могу выполнить тесты для этого соединения.

Вопрос

• Кто-нибудь может определить, почему @PersistenceContext не подключается правильная зависимость и жалуется на дубликат? или
• Должен ли я делать что-то совершенно по-другому?

Пока вы идете правильным путем.

Вам нужно 2 из каждого:

1. EntityManager / factory
2. DataSource
3. TransactionManager
4. JpaRepository-Configs

Ключом к успеху является правильное и уникальное присвоение имен им всем (2×4 = 8 разных имен). @Primary и @Secondary здесь не помогает.