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

Мне нужно определить два разных постоянных модуля, один для базы данных mysql, а другой для mongodb. Я пытаюсь создать с помощью Spring @Configuration entityManager, который будет управлять Mongo, но приложение не работает при начальной загрузке Spring со следующей ошибкой: Ошибка создание bean-компонента с именем «mongoEntityManager», определенным в ресурсе пути к классу [com/intraway/qx/utilities/config/SpringDataJpaMongoConfiguration.class]: не удалось вызвать метод инициализации; вложенным исключением является 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), это требование.


spring-boot java hibernate hibernate-ogm
person David Salas Boscan    schedule 08.01.2019    source источник

Ответы (1)


arrow_upward
0
arrow_downward

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

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

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();
}
person hayrettinm    schedule 08.01.2019