java - 如何正确配置 SimpleMongoRepository?
问题描述
我最近正在使用 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
,它实际上是从您的配置中抛出异常。因此,如果您真的需要手动配置您的存储库,您可以尝试注入MongoRepositoryFactory
.
请注意,仅当您需要在存储库实现上实现特定事物时才需要这样做。如果您只使用 Spring Data 提供的默认接口,那么就没有必要这样做了。
编辑:您可以查看 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。
推荐阅读
- c# - C# foreach 列表元素在列表中添加一个 AddField
- java - 带分隔坐标的交互式图像
- android - 从不同的类向应用程序发送值但需要单击(点击)两次按钮 - Flutter / Dart
- python - 重新排列 2 个不同长度的数组以创建第三个数组 Numpy Python
- c - 数组初始值设定项必须是初始值设定项列表或字符串字面量错误
- reactjs - 如何使用反应钩子添加级联下拉菜单?
- testing - 如何计算以下问题的服务器停机时间和可用性?
- c# - 如何从两个表达式创建有效的 lambda 谓词?
- c# - C#在另一种方法中使用变量
- python - python子进程“OSError:[WinError 6]句柄无效”错误