登录
当前位置： 首页 > 知识库问答 >
问题：

MongoDB投影在@聚集Spring数据上

邵锐
2023-03-14

我已经为此挣扎了好几天了。我们刚刚开始与mongoDB合作，因此我对它的了解非常有限。

总之，我想做的是：我们有一个叫做Loan的课程，就像这样：

@Document(collection = "Loans")
public class Loan{

    @Id
    private String id;
    private String type;

    private LoanApplication loanApplication;
    private LoanDecision loanDecision;

    private String loanAppId;
    private String loanDecisionId;

    private LocalDateTime receivedDate;
    private LocalDate leadExpiry;

    private Integer previousStatus;
    private Integer status;

    private Boolean isEligibleForRemove;

    private String timeStamp;

    private List<String> loanDecisions;

    private String activeLoanDecision;
    private String lenderReferenceNumber;
    private String pdfName;

由于查询此集合时必须执行各种操作，因此我们在LoanRepository中创建了一个聚合（该聚合适用于我们在Mongo Compass中创建的，然后将其导出到我们的代码中）：

@Repository
@EnableMongoRepositories
public interface LoanRepository extends MongoRepository<Loan, String> {

@Aggregation(pipeline = {"{$match: {\r\n" + 
        "  'status':{$in: ?0},\r\n" + 
        "  'loanApplication.mortgage.requested.lenderSubmission.lenderProfile.lenderCode': ?1\r\n" + 
        "  }},{\r\n" + 
        "    $project: {\r\n" + 
        "        'applicationId': '$loanApplication.deal.applicationId',\r\n" + 
        "        'cominedLtv': '$loanApplication.deal.combinedLtv',\r\n" + 
        "        'receivedDate': '$receivedDate',\r\n" + 
                 //other fields to project
        "        }\r\n" + 
        "    }\r\n" + 
        "}, {\r\n" + 
        "    $unwind: {\r\n" + 
        "        path: '$applicants'\r\n" + 
        "    }\r\n" + 
        "}, {\r\n" + 
        "    $match: {\r\n" + 
        "        'applicants.primaryApplicantFlag': 'Y'\r\n" + 
        "    }\r\n" + 
        "}
         //other aggregate methods
"})
    public List<LoanProjection> findLeads(final List<Integer> leadsStatus, final String lenderCode);
}

这个想法是，在所有上述操作之后，我们只需要从整个Loans表中返回一些字段（可以在$project步骤中看到）。我知道这个存储库中所有方法的返回类型必须是Loan，一个解决方案是利用Spring投影。因此，我创建了必要的投影接口（在下面，您将只找到$project步骤中字段的接口）：

public interface LoanProjection {   
    DealType getDealType();
    LocalDate getReceivedDate();
}

public interface DealTypeProjection {
    String getApplicationId();
    String getcombinedLtv();
}

问题是：调用findLeads（）存储库方法时，会发生以下错误：

java.lang.NullPointerException: null
    at org.springframework.data.mongodb.core.mapping.MongoSimpleTypes$1.isSimpleType(MongoSimpleTypes.java:110) ~[spring-data-mongodb-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.data.mongodb.repository.query.StringBasedAggregation.isSimpleReturnType(StringBasedAggregation.java:119) ~[spring-data-mongodb-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.data.mongodb.repository.query.StringBasedAggregation.doExecute(StringBasedAggregation.java:81) ~[spring-data-mongodb-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.data.mongodb.repository.query.AbstractMongoQuery.execute(AbstractMongoQuery.java:101) ~[spring-data-mongodb-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:618) ~[spring-data-commons-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:605) ~[spring-data-commons-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.data.projection.DefaultMethodInvokingMethodInterceptor.invoke(DefaultMethodInvokingMethodInterceptor.java:80) ~[spring-data-commons-2.2.5.RELEASE.jar:2.2.5.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:95) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:212) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at com.sun.proxy.$Proxy130.findLeadsTest(Unknown Source) ~[na:na]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_231]
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[na:1.8.0_231]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[na:1.8.0_231]
    at java.lang.reflect.Method.invoke(Unknown Source) ~[na:1.8.0_231]
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:344) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:198) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:212) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at com.sun.proxy.$Proxy130.findLeadsTest(Unknown Source) ~[na:na]
    at com.filogix.lg.service.impl.LoanServiceImpl.retrieveLeads(LoanServiceImpl.java:261) ~[classes/:na]
    at com.filogix.lg.api.LoanController.getLeads(LoanController.java:49) ~[classes/:na]
    at com.filogix.lg.api.LoanController$$FastClassBySpringCGLIB$$54fe4fe8.invoke(<generated>) ~[classes/:na]
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:769) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:747) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.validation.beanvalidation.MethodValidationInterceptor.invoke(MethodValidationInterceptor.java:120) ~[spring-context-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:747) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at com.filogix.lg.api.LoanController$$EnhancerBySpringCGLIB$$f692749f.getLeads(<generated>) ~[classes/:na]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_231]
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[na:1.8.0_231]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[na:1.8.0_231]
    at java.lang.reflect.Method.invoke(Unknown Source) ~[na:1.8.0_231]
    at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:106) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:879) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:793) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:634) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:741) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at com.filogix.lg.config.DecodingFilter.doFilter(DecodingFilter.java:35) ~[classes/:na]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.4.RELEASE.jar:5.2.4.RELEASE]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) ~[tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:541) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:367) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1639) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [na:1.8.0_231]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [na:1.8.0_231]
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.31.jar:9.0.31]
    at java.lang.Thread.run(Unknown Source) [na:1.8.0_231]

我首先开始调整我的聚合逻辑，认为它可能有问题（在Mongo Compass和Atlass中聚合可以正常工作），最后我只使用了$match操作符（非常基本的东西），错误仍然存在。

@Aggregation(pipeline = {"{$match: {\r\n" + 
            "  'status':{$in: ?0},\r\n" + 
            "  'loanApplication.mortgage.requested.lenderSubmission.lenderProfile.lenderCode': ?1\r\n" + 
            "  }}"})
    public List<LoanProjection> findLeadsTest(final List<Integer> leadsStatus, final String lenderCode);

然后我想看看使用@Query注释是否会收到相同的错误。有趣的是，这种方法的投影效果很好！！！

@Query(value = "{$and: [{'status': {$in: ?0}}, {'loanApplication.mortgage.requested.lenderSubmission.lenderProfile.lenderCode': ?1}]}")
    public List<LoanProjection> findLeads(final List<Integer> leadsStatus, final String lenderCode);

因此，我的问题是：spring projection是否与@Agregation不兼容，或者我是否用错了（很可能）？

共有1个答案

仲孙俊贤
2023-03-14

我认为您需要使用类而不是接口，并且需要添加@Id注释，以便匹配聚合的结果

在您的情况下，很难准确地了解id，因为您没有通过CLI在mongo中手动运行聚合添加任何结果。

但是如果我试着猜测，这样的事情可能会帮助你：

import org.springframework.data.annotation.Id;
// other imports

public class LoanProjection {

    @Id
    private DealType dealType;
    private LocalDate receivedDate;

    DealType getDealType() {
        return dealType;
    }

    LocalDate getReceivedDate() {
        return receivedDate;
    }
}

public class DealTypeProjection {
    @Id
    private String applicationId;
    private String combinedLtv;

    public String getApplicationId() {
        return applicationId;
    }

    public String getCombinedLtv() {
        return combinedLtv;
    }
}

通常，聚合的结果与使用的文档非常不同，因此需要有一些唯一的标识符才能将其映射到新的投影。您可以像查看新的文档一样查看聚合结果，因为这是spring将结果与实际DTO匹配的方式。

更多详情请点击此处：https://docs.spring.io/spring-data/mongodb/docs/current/reference/html/#mongodb.repositories.queries.aggregation

 类似资料：
  • MongoDB聚合和投影

    本文向大家介绍MongoDB聚合和投影，包括了MongoDB聚合和投影的使用技巧和注意事项，需要的朋友参考一下 为此，请使用$project和aggregate()。聚合中的$project将带有请求字段的文档传递到管道的下一个阶段。 让我们创建一个包含文档的集合- 在find()方法的帮助下显示集合中的所有文档- 这将产生以下输出- 以下是对MongoDB聚合和投影的查询- 这将产生以下输出-

  • MongoDB投影

    MongoDB 中的投影即查询指定的字段，而不是直接查询文档的全部字段。比如说某个文档中有 5 个字段，而我们只需要其中的 3 个字段，那么就可以使用 MongoDB 中的投影来指定需要查询的 3 个字段。 在《 MongoDB查询文档》一节中我们介绍的 find() 方法，在使用 find() 方法时，如果不设置其中的第二个参数，那么在查询时将返回文档中的所有字段，想要限制要查询的字段，您就需要

  • Spring数据MongoDB-聚合方法

    有人知道如何使用Spring-Data将下面的聚合函数转换成java代码吗？

  • 在Spring数据JPA场误差中使用投影

  • Spring数据MongoDB聚合SORT顺序

    我的应用程序使用Spring数据MongoDB，我试图在嵌入式文档中按降序排序数据，这是不工作的。 请参考以下JSON文档 JSON-库存文件： Spring数据Mongodb聚合查询： 电流输出： 苹果：150.0 李子：200.0 橙子：500.0 预期产量（按需求描述订单）： 橙子：500.0 李子：200.0 苹果：150.0 你能帮我按降序得到预期的输出吗？ 此外，我计划通过使用上述带限

  • Spring数据-投影和@Query嵌套属性

    假设我有那些DTO： 在我的存储库中，我使用这些DTO作为投影进行查询： 我可以使用这个repo很好地访问ForumDTO中的id、name，但对于lasthread，它只返回null。我试过作为最后一个线程。Id、lastThread\u Id、lastThreadId均无效。

相关问答

Spring数据投影加载附加字段Spring JPA投影可以有集合吗？从MongoDb聚合查询创建Spring数据聚合Spring数据MongoDb聚合查找级联QueryDSL投影中的集合

相关文章

在mongodb的聚合内调用函数？如何在MongoDB聚合中将数组元素的子集相加？Mongodb中MapReduce实现数据聚合方法详解带有投影以排除_id的Node.js MongoDB Find仍返回它mongoDB使用投影剔除‘额外’字段的操作过程

相关阅读

MongoDB数据模型MongoDB数据类型欢聚集团MongoDB删除数据库MongoDB创建数据库

相关工具

Spring Data MongoDB易得网络数据采集系统投胎模拟器MongoDBmongodb-net

相关文档

设计数据密集型应用数据采集从入门到放弃蓝天数据采集发布系统数据科学网聚宝开发指南
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.