java - 如何正确配置 SimpleMongoRepository？

标签 java spring mongodb spring-data-mongodb

最近在用MongoDB，遇到这样的问题。我需要配置 SimpleMongoRepository，我找到了这个主题作为示例(以上一篇文章为例)Spring Data Mongo Repository:: Common shared method across all Repo issue

配置:

@Configuration
@RequiredArgsConstructor
@EnableConfigurationProperties(MultipleMongoProperties.class)
@EnableMongoRepositories(basePackages = "productcatalog.repository")
public class MultipleMongoConfig {

    private final MultipleMongoProperties mongoProperties;

    @Bean(name = "mongoTemplate")
    public MongoTemplate mongoTemplate() {
        return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
    }

    @Primary
    @Bean(name = "primaryMongoTemplate")
    public MongoTemplate primaryMongoTemplate() {
        return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
    }

    @Bean(name = "secondaryMongoTemplate")
    public MongoTemplate secondaryMongoTemplate() {
        return new MongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
    }

    @Bean("primary")
    public SimpleMongoRepository<ProductModel, String> getPrimaryProductRepository() {
        TypeInformation<ProductModel> typeInformation = ClassTypeInformation.from(ProductModel.class);
        MongoPersistentEntity<ProductModel> mongoPersistentEntity = new BasicMongoPersistentEntity<>(typeInformation);
        return new SimpleMongoRepository<>(entityInformationFor(mongoPersistentEntity, String.class), primaryMongoTemplate());
    }

    @Bean("secondary")
    public SimpleMongoRepository<ProductModel, String> getSecondaryProductRepository() {
        TypeInformation<ProductModel> typeInformation = ClassTypeInformation.from(ProductModel.class);
        MongoPersistentEntity<ProductModel> mongoPersistentEntity = new BasicMongoPersistentEntity<>(typeInformation);
        return new SimpleMongoRepository<>(entityInformationFor(mongoPersistentEntity, String.class), secondaryMongoTemplate());
    }

    @Bean("productRepository")
    public MongoRepository<ProductModel, String> getRepository() {
        return new MongoRepositoryImpl<>(getPrimaryProductRepository(), getSecondaryProductRepository());
    }

    @Bean
    @Primary
    public MongoDbFactory primaryFactory(final MongoProperties mongo) {
        return getMongoDbFactory(mongo);
    }

    @Bean
    public MongoDbFactory secondaryFactory(final MongoProperties mongo) {
        return getMongoDbFactory(mongo);
    }

    public <T, ID extends Serializable> MongoEntityInformation<T, ID> entityInformationFor(MongoPersistentEntity<T> entity,
                                                                                           Class<ID> idType) {
        return new MappingMongoEntityInformation<>(entity, idType);
    }

    private SimpleMongoDbFactory getMongoDbFactory(MongoProperties mongo) {
        MongoCredential mongoCredential = MongoCredential.createCredential(mongo.getUsername(), mongo.getAuthenticationDatabase(), mongo.getPassword());
        List<MongoCredential> mongoCredentialList = Collections.singletonList(mongoCredential);
        ServerAddress serverAddress = new ServerAddress(mongo.getHost(), mongo.getPort());
        MongoClient mongoClient = new MongoClient(serverAddress, mongoCredentialList);
        return new SimpleMongoDbFactory(mongoClient,
                mongo.getDatabase());
    }
}

我的模型:

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(collection = "products")
public class ProductModel {

    @Id
    private String id;

    @Field(value = "name")
    private String name;
}

但是我的 SimpleMongoRepository 配置中有一个问题，在这一行中

MongoPersistentEntity<ProductModel> mongoPersistentEntity = new BasicMongoPersistentEntity<>(typeInformation);

idProperty 配置为 null，然后在使用它的后续方法中我得到 NPE。如何解决这个问题？

java.lang.NullPointerException: null
at org.springframework.data.mongodb.repository.support.MappingMongoEntityInformation.getIdAttribute(MappingMongoEntityInformation.java:101) ~[spring-data-mongodb-1.10.9.RELEASE.jar:na]
at org.springframework.data.mongodb.repository.support.SimpleMongoRepository.findAll(SimpleMongoRepository.java:211) ~[spring-data-mongodb-1.10.9.RELEASE.jar:na]
at productcatalog.repository.MongoRepositoryImpl.findAll(MongoRepositoryImpl.java:97) ~[classes/:na]
at productcatalog.service.impl.ProductServiceImpl.getProductsByIds(ProductServiceImpl.java:36) ~[classes/:na]
at productcatalog.controller.ProductCatalogController.getProductsByIds(ProductCatalogController.java:90) ~[classes/:na]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_181]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_181]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:901) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:861) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:635) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846) ~[spring-webmvc-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:742) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52) ~[tomcat-embed-websocket-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContentFilter.java:108) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:81) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) ~[spring-web-4.3.13.RELEASE.jar:4.3.13.RELEASE]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199) ~[tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:478) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:803) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1459) [tomcat-embed-core-8.5.23.jar:8.5.23]
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-8.5.23.jar:8.5.23]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_181]
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-8.5.23.jar:8.5.23]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]

我得到了存储库:

public class MongoRepositoryImpl<T, K extends Serializable> implements MongoRepository<T, K> {

    private SimpleMongoRepository<T, K> primaryRepository;

    private SimpleMongoRepository<T, K> secondaryRepository;

    private SimpleMongoRepository<T, K> actualSource;

    private ReadWriteLock lock = new ReentrantReadWriteLock();

    private Lock writeLock = lock.writeLock();
    private Lock readLock = lock.readLock();

    private static final Integer DEFAULT_SIZE = 10;

    public MongoRepositoryImpl(SimpleMongoRepository<T, K> primaryRepository, SimpleMongoRepository<T, K> secondaryRepository) {
        this.primaryRepository = primaryRepository;
        this.secondaryRepository = secondaryRepository;
        actualSource = primaryRepository;
    }

 @Override
    public T findOne(K id) {
        T findResult;
        try {
            readLock.lock();
            findResult = actualSource.findOne(id);
        } finally {
            readLock.unlock();
        }
        return findResult;
    }


    @Override
    public List<T> findAll() {
        List<T> result;
        try {
            readLock.lock();
            result = actualSource.findAll();
        } finally {
            readLock.unlock();
        }
        return result;
    }

    @Override
    public Iterable<T> findAll(Iterable<K> ids) {
        Iterable<T> result;
        try {
            readLock.lock();
            result = actualSource.findAll(ids);
        } finally {
            readLock.unlock();
        }
        return result;
    }

除了 findAll (Iterable ids) 之外的所有方法都有效，当我使用这个方法时，我得到了 NPE 因为 idProperty = null;我该如何解决这个问题？

最佳答案

我认为您需要 org.springframework.data.mongodb.repository.support.MongoRepositoryFactory 的专用实例。

在您的配置类中设置工厂:

@Configuration
@RequiredArgsConstructor
@EnableConfigurationProperties(MultipleMongoProperties.class)
@EnableMongoRepositories(basePackages = "productcatalog.repository", repositoryFactoryBeanClass = MultipleMongoRepositoryFactoryBean.class)
public class MultipleMongoConfig {
    /* ...code... */
}

然后，在您的 MultipleMongoRepositoryFactoryBean 中:

public class MultipleMongoRepositoryFactoryBean<R extends MongoRepository<T, I>, T, I extends Serializable> extends MongoRepositoryFactoryBean<R, T, I> {

    protected RepositoryFactorySupport getFactoryInstance(MongoOperations operations) {
         return new MultipleMongoRepositoryFactory<T, I>(operations);
    }
}

然后根据元数据在 MongoRepositoryFactory 中创建自己的一组存储库。

public class MultipleMongoRepositoryFactory<T, ID extends Serializable> extends MongoRepositoryFactory {

    private final MongoOperations mongoOperations;

    public MultipleMongoRepositoryFactory(MongoOperations mongoOperations) {
        super(mongoOperations);
    }

    @Override
    protected Object getTargetRepository(RepositoryMetadata metadata) {
        /* Add personalyzed stuff here */
        return super.getTargetRepository(metadata);
    }

}

请注意 MongoRepositoryFactory::getEntityInformation(EntityMetadata) 有一个返回 MongoEntityInformation 的方法，这实际上是从您的配置中抛出异常。因此，如果您真的需要手动配置存储库，您可以尝试注入(inject) MongoRepositoryFactory。

请注意，仅当您需要在存储库实现上实现特定内容时才需要这样做。如果您只使用 Spring Data 提供的默认接口(interface)，则不需要像这样。

编辑:您可以查看 Spring Data 的文档以获取更多信息。 https://docs.spring.io/spring-data/mongodb/docs/1.6.4.RELEASE/reference/html/#repositories.custom-implementations .这是从版本 1.6.4 中检索到的，这是我遇到与您相同问题的版本。对于当前版本，请参阅 https://docs.spring.io/spring-data/mongodb/docs/current/reference/html/#repositories.custom-implementations .

关于java - 如何正确配置 SimpleMongoRepository？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54004106/

上一篇：mongodb - 如何从 api 获得响应，而不是 504 网关超时问题

下一篇：node.js - mongodb 实现中的嵌套文档，就像 Reddit 评论一样

相关文章：

java - Java JScrollPane动态添加组件的方法

java - 如何提高从 hazelcast 读取数据的 Get 方法性能？

java - JMS异常监听器

java - Java foreach 循环遍历不可变的 volatile 数组线程安全吗？

database - Spring Security 没有基于角色的使用数据库

c - 蒙戈 : Error converting JSON to BSON

java - 尽管使用 @Primary，但两个同名的 bean 会导致 ConflictingBeanDefinitionException

java - NPE on spring autowires form TestExecutionListener

python - 是否可以将 render_to_response 模板从 django 保存到服务器？

python - Mongo引擎和服务器状态

©2024 IT工具网  联系我们