Как я могу разработать приложение, которое будет работать в нескольких баз данных одновременно с помощью Spring + Hibernate?

Question

Я разрабатываю приложение Java, используя Spring + Hibernate. Я хочу, чтобы это приложение работало в более чем одной базе данных одновременно.

Для примера, если пользователь пытается найти некоторые данные, приложение должно одновременно искать эти данные во всех настроенных источниках данных.

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

Edit 1 Позвольте мне объяснить мою проблему ниже подробно мой DAO класс

@Repository("engineDAO") 
public class EngineDAOImpl implements EngineDAO { 

    @Autowired 
    private SessionFactory sessionFactory; 

    @Override 
    public void persistEngine(Engine engine, String[] DataSourceNames) { 
     sessionFactory.getCurrentSession().persist(engine); 
    } 
} 

Теперь из класса обслуживания я буду называть persistEngine метод EngineDAO класса с аргументом, как String[] DataSourceNames так эта операция должна выполняться для всех источников данных, предоставленных в качестве аргумента. Какие все изменения я должен сделать для этого? Заранее спасибо

Answer 1

У вас может быть несколько объектов SessionFactory или EntityManagerFactory, каждый из которых связан с различными DataSource. Если вы хотите управлять транзакцией в разных источниках данных, я бы рекомендовал использовать JTA Transaction Manager. Если ваше приложение не работает в среде Java EE, вы можете использовать какой-либо сторонний менеджер транзакций JTA, например Atomikos Transaction Manager

В Stackoverflow есть несколько потоков, которые обсуждают эту проблему. Try this

Edit 1: Если вы NEET для выбора источников данных по имени, чем ваш DAO может реализовать BeanFactoryAware и вы получите BeanFactory объект, который можно использовать для доступа к SessionFactory фасоли по имени. Ваш код должен выглядеть примерно так

@Repository("engineDAO") 
public class EngineDAOImpl implements EngineDAO, BeanFactoryAware { 

    private org.springframework.beans.factory.BeanFactory beanFactory; 

    @Override 
    public void persistEngine(final Engine engine, final String[] sessionFactoryNames) { 
     for (final String sessionFactoryName : sessionFactoryNames) { 
      final SessionFactory sessionFactory = beanFactory.getBean(sessionFactoryName, SessionFactory.class); 
      sessionFactory.getCurrentSession().persist(engine); 
     } 
    } 

    @Override 
    public void setBeanFactory(final BeanFactory beanFactory) throws BeansException { 
     this.beanFactory = beanFactory; 
    } 
}