Создать Jpa EntityManager, который управляет соединением MongoDb с настройкой кода Java

Question

Мне нужно определить два разных постоянных модуля, один для mysql db, а другой для mongodb. Я пытаюсь создать с помощью Spring Configuration @Configuration entityManager, который будет управлять Mongo, но приложение завершится неудачно при загрузке Spring с помощью следующего ошибка: ошибка создания бина с именем 'mongoEntityManager', определенного в ресурсе пути к классу [com / intraway / qx / utilities / config / SpringDataJpaMongoConfiguration.class]: сбой вызова метода init; Вложенное исключение - java.lang.NullPointerException

    Java config Class
@Configuration
@EnableJpaRepositories(basePackages = { "com.intraway.qx.utilities.models.repositories.mongoRepository"},
        entityManagerFactoryRef = "mongoEntityManager",
        transactionManagerRef = "mongoTransactionManager")
@EnableTransactionManagement
public class SpringDataJpaMongoConfiguration {

    @Bean(name = "mongoEntityManager")
    public LocalContainerEntityManagerFactoryBean  mongoEntityManager() {
        Map<String, Object> properties = new HashMap<>();
        properties.put("javax.persistence.transactionType", "resource_local");
        properties.put("hibernate.ogm.datastore.provider","mongodb");
        properties.put("hibernate.ogm.datastore.host","localhost");
        properties.put("hibernate.ogm.datastore.port", "27017");
        properties.put("hibernate.ogm.datastore.database", "qx_utils");

        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setPackagesToScan("com.intraway.qx.utilities.models");
        em.setPersistenceUnitName("persistence.mongo");
        em.setJpaPropertyMap(properties);
        em.setPersistenceProviderClass(HibernateOgmPersistence.class);
        return em;
    }
    @Bean(name = "mongoTransactionManager")
    public PlatformTransactionManager transactionManager() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(mongoEntityManager().getObject());
        return transactionManager;
    }
}

pom.xml http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0

    <groupId>com.intraway.qx</groupId>
    <artifactId>QX-AOS-Utilities</artifactId>
    <version>1.0.0</version>
    <packaging>jar</packaging>

    <name>QX-AOS-Utilities</name>


    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repositories -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
            <version>2.0.5.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter-api</artifactId>
            <version>5.3.1</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.hibernate.ogm</groupId>
            <artifactId>hibernate-ogm-mongodb</artifactId>
            <version>5.3.1.Final</version>
        </dependency>


    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

Мне нужно настроить соединение с БД программно (НЕ через файл application.properties), это требование.

Answer 1

На самом деле, я не знаю, использовали ли вы аннотацию @Primary в конфигурации MySQL DB. Но если вы используете два источника данных, вы должны установить один из них в качестве основного.

Вы можете следовать этому руководству, даже если оно использует свойства, но вы также можете перейти к ним в классе конфигурации.

https://medium.com/@joeclever/using-multiple-datasources-with-spring-boot-and-spring-data-6430b00c02e7

4. Создайте класс конфигурации для базы данных Oracle «foo» с именем «FooDbConfig.java»

пакет com.foobar;

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
  entityManagerFactoryRef = "entityManagerFactory",
  basePackages = { "com.foobar.foo.repo" }
)
public class FooDbConfig {

@Primary
@Bean(name = "dataSource")
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource dataSource() {
    return DataSourceBuilder.create().build();
}