SpringData mongoDB API for aggregation $ map

Question

다음은 내 원주민 MongoDB 쿼리이며 아래는 SpringData Mongo API에 해당합니다. SpringData Mongo API의 $ 프로젝트에서 $ map을 사용하는 것에 대해 고심하고 있습니다. 당신은 $map 집계 아래 시도 할 수 있습니다 API

db.users.aggregate([  
    { $match: {$and : [{userType:"200"} },  
    { $unwind: "$userOrgMap" }, 
    { 
     $lookup: 
     { 
      from: "users", 
      localField: "userOrgMap.createdbyuser", 
      foreignField: "_id", 
      as: "created_by" 
     } 
    }, 
    {$project:{ 
     _id:"$_id", 
     login:"$login", 
     firstName:"$firstName", 
     lastName:"$lastName", 
     email:"$email", 
     deactivateFlag:"$deactivateFlag", 
     createdOn:"$createdOn", 
     createdBy:{ 
     "$map": { 
        "input": "$created_by", 
        "as": "u", 
         "in": { 
          "name": { "$concat" : [ "$$u.firstName", " ", "$$u.lastName" ] }, 
         } 
       } 
    } 
     } 
    }, 
    { $sort : { createdBy : 1} } 

]) 

봄 쿼리

Aggregation aggregation = newAggregation(
      Aggregation.match(Criteria.where("userType").is(userType)), 
      Aggregation.unwind("userOrgMap"), 
      Aggregation.lookup("users", "userOrgMap.createdbyuser", "_id", "created_by"), 
      Aggregation.project("userId","login","firstName","lastName","email","deactivateFlag","createdOn") 
     ); 

Answer 1

내 전환을 완료에 도움을 주셔서 감사합니다.

project().and(mapItemsOf("created_by"). 
          as("u"). 
          andApply(new AggregationExpression() { 
           @Override 
           public DBObject toDbObject(AggregationOperationContext aggregationOperationContext) { 
            return new BasicDBObject("name", StringOperators.valueOf("u.firstName").concat(" ").concatValueOf("u.lastName").toDbObject(aggregationOperationContext)); 
           } 
          })) 
      .as("createdBy"); 

$let 표현

project().and(VariableOperators.Let.define(VariableOperators.Let.ExpressionVariable.newVariable("u").forExpression(ArrayOperators.arrayOf("created_by").elementAt(0))). 
          andApply(new AggregationExpression() { 
           @Override 
           public DBObject toDbObject(AggregationOperationContext aggregationOperationContext) { 
            return new BasicDBObject("name", StringOperators.valueOf("u.firstName").concat(" ").concatValueOf("u.lastName").toDbObject(aggregationOperationContext)); 
           } 
          })) 
      .as("createdBy"); 

사용 람다 및 고정 수입을 사용.

import static org.springframework.data.mongodb.core.aggregation.ArrayOperators.arrayOf; 
import static org.springframework.data.mongodb.core.aggregation.StringOperators.valueOf; 
import static org.springframework.data.mongodb.core.aggregation.VariableOperators.Let.ExpressionVariable.*; 
import static org.springframework.data.mongodb.core.aggregation.VariableOperators.Let.define; 
import static org.springframework.data.mongodb.core.aggregation.VariableOperators.mapItemsOf; 

project().and(mapItemsOf("created_by"). 
       as("u"). 
       andApply(aggregationOperationContext -> new BasicDBObject("name", valueOf("u.firstName").concat(" ").concatValueOf("u.lastName").toDbObject(aggregationOperationContext)))) 
       .as("createdBy"); 

    project().and(define(newVariable("u").forExpression(arrayOf("created_by").elementAt(0))). 
      andApply(aggregationOperationContext -> new BasicDBObject("name", valueOf("u.firstName").concat(" ").concatValueOf("u.lastName").toDbObject(aggregationOperationContext)))) 
      .as("createdBy"); 

[스프링 프레임 워크의 하위 문서 배열 필드 필터 어레이 (