Agrgregation mit mongoDBtemplate für verschachteltes Dokument

Question

Ich versuche, Agregation mit Feder mongodb Vorlage zu verwenden. Die Gruppierung muss auf der dritten Dokumentenebene erfolgen. Eingabedokument ist

{ 
    "_id": "59036b0fa036cc28c8e07db6", 
    "sections": [{ 
     "srcName": "test1", 
     "data": [{ 
       "srcKey": "", 
       "rowIdx": 0, 
       "values": [{ 
         "srcDesc": "Assets" 
        }, 
        { 
         "srcDesc": "NonAssets" 
        }, 
        { 
         "srcDesc": "liabilities" 
        } 
       ] 
      }, 
      { 
       "srcKey": "01", 
       "rowIdx": 1, 
       "values": [{ 
        "srcDesc": "NonAssets" 
       }] 
      } 
     ] 
    }] 
} 

Wesentlichen Abfrage wie

select distinct(srcdesc) from document where srcName="test1"; 

laufen Ich möchte Bitte beachten Sie, dass srcDesc dritte Ebene der Verschachtelung ist. Ich versuche unter Java-Code

private MatchOperation getMatchOPeration(String sectionName){ 
     Criteria criteira=Criteria.where("sectionName").in(sectionName); 
     return match(criteira); 
    } 

    private GroupOperation getGroupOperaion(){ 
     return group("srcDesc").last("srcDesc").as("srcDesc"); 
    } 

private ProjectionOperation getProjectionOPeration(){ 
     return project("srcDesc").and("srcDesc").previousOperation(); 
    } 

public List<SourceName> findAllSourceNamesBySection(String sectionName){ 
     List<SectionsDocument> sourceNameList=new ArrayList<>(); 
     MatchOperation matchOPeration=getMatchOPeration(sectionName); 
     GroupOperation groupOperation=getGroupOperaion(); 
     ProjectionOperation projectionOperation=getProjectionOPeration(); 
     AggregationResults<SectionsDocument> aggregationResults= 
     mongoTemplate.aggregate(Aggregation.newAggregation(
      matchOPeration, 
      unwind("sections.data.values"), 
      groupOperation, 
      projectionOperation),StatDocument.class,SectionsDocument.class); 
      sourceNameList=aggregationResults.getMappedResults(); 
     return new ArrayList<>(); 
    } 

Answer 1

Sie können Ihren Code unten aktualisieren.

Added $unwindsections & sections.data vor sections.data.values Abwickeln zu entspannen.

Aktualisiert $group get distinct srcDesc mit $addToSet Betreiber.

Die $project Stufe entfernt.

private MatchOperation getMatchOperation(String sectionName){ 
    Criteria criteira=Criteria.where("sections.srcName").in(sectionName); 
    return match(criteira); 
} 

private GroupOperation getGroupOperaion(){ 
    return group().addToSet("sections.data.values.srcDesc").as("srcDescs"); 
} 

public List<String> findAllSrcDescBySection(String sectionName){ 
    MatchOperation matchOperation=getMatchOperation(sectionName); 
    GroupOperation groupOperation=getGroupOperaion(); 
    BasicDBObject aggregationResults= 
       mongoTemplate.aggregate(Aggregation.newAggregation(
         matchOperation, 
         unwind("sections"), 
         unwind("sections.data"), 
         unwind("sections.data.values"), 
         matchOperation, 
         groupOperation), collectionname, BasicDBObject.class).getUniqueMappedResult(); 
    return (ArrayList)aggregationResults.get("srcDescs"); 
} 

-Update 3.4 Version:

Dies ist ähnlich wie oben, aber statt $unwind'ing sind wir $reduce'ing-$projectsrcDescs aus jedem Dokument.

$map + $filter, um die sections Elemente mit dem Eingang srcName zu filtern, gefolgt von map, um die Ausgabe zu transformieren. $reduce verwendet die Ausgabe der Filterstufe innerhalb der Kartenstufe, um ($concatArrays Teil) srcDesc über alle values in jedem data zu extrahieren und zusammenzuführen.

$unwind + $group, um eindeutig srcDesc mit $addToSet Operator zu erhalten.

aggregate([{ 
     $project: { 
      srcDescs: { 
       $arrayElemAt: [{ 
        $map: { 
         input: { 
          $filter: { 
           input: "$sections", 
           as: "sectionsf", 
           cond: { 
            $eq: ["$$sectionsf.srcName", "test1"] 
           } 
          } 
         }, 
         as: "sectionsm", 
         in: { 
          $reduce: { 
           input: "$$sectionsm.data", 
           initialValue: [], 
           in: { 
            $concatArrays: ["$$value", "$$this.values.srcDesc"] 
           } 
          } 
         } 
        } 
       }, 0] 
      } 
     } 
    }, 
    { 
     $unwind: "$srcDescs" 
    }, 
    { 
     $group: { 
      _id: null, 
      srcDescs: { 
       $addToSet: "$srcDescs" 
      } 
     } 
    } 
])