MongoDB를 $ 집계 $가 나는 몽고 집계 그룹 쿼리가

Question

자바 봄 데이터에 여러 필드를 밀어 : 나는 자바 봄 - 데이터 - MongoDB의에서이 질의를 필요로한다

db.wizard.aggregate(
{ 
$group: { 
    _id: "$title", 
    versions: { $push: {version:"$version", author:"$author", dateAdded:"$dateAdded"}} 
    } 
}) 

을 내 현재 솔루션은 다음과 같습니다

Aggregation agg = Aggregation.newAggregation(
      Aggregation.group("title"). 
        push("version").as("versions") 
    ); 

문제는 푸시 메서드 (버전, 작성자, 날짜 추가)에 필드를 추가하는 방법을 모르겠다는 것입니다. Spring-Data-MongoDB로 가능합니까?

Answer 1

참고 : MongoDB를 버전 2.6-3.0 (호환 자바 드라이버)

내가 구현하는 org.springframework.data.mongodb.core.aggregation.AggregationOperation 클래스를 확장 한 사용자 정의 toDBObject은 방법 :

귀하의 경우

public class GenericAggregationOperation implements AggregationOperation { 

    private String operator; 
    private DBObject query; 

    /** 
    * Default constructor. 
    * 
    * @param operator MongoDB operator ($group, $sort, $project, etc..) 
    * @param query MongoDB aggregation query step string 
    */ 
    public GenericAggregationOperation(String operator, String query) { 
     this(operator, (DBObject) JSON.parse(query)); 
    } 

    /** 
    * Default constructor. 
    * 
    * @param operator MongoDB operator ($group, $sort, $project, etc..) 
    * @param query MongoDB aggregation query step DBObject 
    */ 
    public GenericAggregationOperation(String operator, DBObject query) { 
     this.operator = operator; 
     this.query = query; 
    } 

    @Override 
    public DBObject toDBObject(AggregationOperationContext context) { 

     return new BasicDBObject(operator, query); 
    } 

} 

, 그것은 다음과 같습니다

List<AggregationOperation> list = new ArrayList<AggregationOperation>(); 
lista.add(new GenericAggregationOperation("$group", "{ \"_id\": \"$title\", \"versions\": { \"$push\": { \"version\":\"$version\", \"author\":\"$author\", \"dateAdded\":\"$dateAdded\"}} }")); 

TypedAggregation<EpisodeIndexDto> agg = Aggregation.newAggregation(
    YourClassTitleVersion.class, list); 
mongoOperations.aggregate(agg, YourClassTitleVersion.class, 
    YourClassTitleVersion.class).getMappedResults(); 

희망이 도움이 될 것입니다.

Answer 2

Aggregation 파이프 라인 단계 중 하나에 BasicDbObject를 직접 전달할 수 있습니다.

Aggregation agg = newAggregation(
      group("title"). 
      push(new BasicDBObject 
        ("version", "$version").append 
        ("author", "$author").append 
        ("dateAdded", "$dateAdded")).as("versions"));