#spring-boot #jpa #spring-data-jpa #entitymanager
#весенняя загрузка #jpa #spring-data-jpa #entitymanager
Вопрос:
Я следил за многими учебными пособиями и рассмотрел множество ответов (на 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
файла, я все делаю программно.
Что я пробовал до сих пор
- Очевидно, приведенный выше код.
- Кроме того, вы заметите, что есть раздел с комментариями для
@EnableJpaRepositories
; это тоже не работает. - Я также безуспешно пытался создать
PersistenceUnitManager
для каждого из классов конфигурации источника данных. - Я пробовал
@Autowired
, с и без@PersistenceContext
, тоже не повезло. - Я пробовал
@PersistenceContext
использовать сеттер и использовать@Qualifier
на входеEntityManager
, тоже не повезло. - Я пробовал с
@Primary
декораторами и без них.
Пожалуйста, имейте в виду, что любые несоответствия между размещенными выше файлами, безусловно, являются ошибкой копирования / вставки, мне пришлось редактировать имена, чтобы сохранить конфиденциальность. Также обратите внимание, что код, который у меня есть, компилируется, запускается и не выводит никаких других ошибок, кроме перечисленных выше. Кроме того, если настроен только один из этих классов конфигурации базы данных, проект выполняется должным образом, и я могу выполнить тесты для этого соединения.
Вопрос
- Кто-нибудь может определить, почему
@PersistenceContext
не подключается правильная зависимость и жалуется на дубликат? или - Должен ли я делать что-то совершенно по-другому?
Ответ №1:
Пока вы идете правильным путем.
Вам нужно 2 из каждого:
- EntityManager / factory
DataSource
TransactionManager
- JpaRepository-Configs
Ключом к успеху является правильное и уникальное присвоение имен им всем (2×4 = 8 разных имен). @Primary
и @Secondary
здесь не помогает.
Комментарии:
1. У меня есть два из них. Вы видите, что чего-то не хватает?
2. Оказывается, вы были правы, произошла несогласованность имен. Исправлено, и все настроено, спасибо!