Aggregation Abfrage in Mongo und Feder-Daten-Mongo

Question

Hallo allerseits Ich habe ein großes Problem bei der Abfrage meiner Daten. Ich habe Dokumente wie folgt aus:

{ 
    "_id" : NumberLong(999789748357864), 
    "text" : "#asd #weila #asd2 welcome in my house", 
    "date" : ISODate("2016-12-13T21:44:37.000Z"), 
    "dateString" : "2016-12-13", 
    "hashtags" : [ 
     "asd", 
     "weila", 
     "asd2" 
    ] 
} 

und ich möchte zwei Abfragen erstellen:

1) für jeden Tag die Anzahl der hashtag zählen und wie dies zum Beispiel etwas raus:

{_id:"2016-12-13", 
hashtags:[ 
{hashtag:"asd",count:20}, 
{hashtag:"weila",count:18}, 
{hashtag:"asd2",count:10}, 
.... 
] 
} 

{_id:"2016-12-14", 
hashtags:[ 
{hashtag:"asd",count:18}, 
{hashtag:"asd2",count:14}, 
{hashtag:"weila",count:10}, 
.... 
] 
} 

2) ein anderes ist das gleiche, aber ich möchte einen Zeitraum von 2016-12-13 bis 2016-12-17 festlegen.

Für den ersten schreibe ich diese Abfrage und ich bekomme, was ich suche, aber in Spring Data Mongo kann ich nicht schreiben.

db.comment.aggregate([ 
{$unwind:"$hashtags"}, 
{"$group":{ 
    "_id":{ 
     "date" : "$dateString", 
     "hashtag": "$hashtags" 
    }, 
    "count":{"$sum":1} 
    } 
}, 
{"$group":{ 
    "_id": "$_id.date", 
    "hashtags": { 
     "$push": { 
     "hashtag": "$_id.hashtag", 
     "count": "$count" 
    }}, 
    "count": { "$sum": "$count" } 
}}, 
{"$sort": { count: -1}}, 
{"$unwind": "$hashtags"}, 
{"$sort": { "count": -1, "hashtags.count": -1}}, 
{"$group": { 
     "_id": "$_id", 
     "hashtags": { "$push": "$hashtags" }, 
     "count": { "$first": "$count" } 
    }}, 
{$project:{name:1,hashtags: { $slice: ["$hashtags", 2 ]}}} 
]); 

Answer 1

Sie noch einen Bruchteil der gleichen Aggregation Betrieb abzüglich der Pipeline Schritte nach der zweiten Gruppenphase aber für die Filterung Aspekt verwenden, können Sie einen Datumsbereich Abfrage in einer ersten $match Pipeline Schritt einzuführen haben würde .

Die folgenden Mongo Mantel Beispiele zeigen, wie Sie die Aggregate für einen bestimmten Zeitraum filtern:

1) Stellen Sie einen Zeitraum von 2016.12.13 bis 2016.12.14:

var startDate = new Date("2016-12-13"); 
startDate.setHours(0,0,0,0); 

var endDate = new Date("2016-12-14"); 
endDate.setHours(23,59,59,999); 
var pipeline = [ 
    { 
     "$match": { 
      "date": { "$gte": startDate, "$lte": endDate } 
     } 
    } 
    { "$unwind": "$hashtags" }, 
    { 
     "$group": { 
      "_id": { 
       "date": "$dateString", 
       "hashtag": "$hashtags" 
      }, 
      "count": { "$sum": 1 } 
     } 
    }, 
    { 
     "$group": { 
      "_id": "$_id.date", 
      "hashtags": { 
       "$push": { 
        "hashtag": "$_id.hashtag", 
        "count": "$count" 
       } 
      } 
     } 
    } 
] 
db.comment.aggregate(pipeline) 

Set

2) 2016.12.17 einen Zeitraum von 2016.12.13 bis:

var startDate = new Date("2016-12-13"); 
startDate.setHours(0,0,0,0); 

var endDate = new Date("2016-12-17"); 
endDate.setHours(23,59,59,999); 
// run the same pipeline as above but with the date range query set as required 

Spring Data Equivalent (ungetestet):