sql >> Database teknologi >  >> NoSQL >> MongoDB

Aggregationssum i Spring Data MongoDB

Det har jeg endelig fundet ud af. Nøglen er at bruge count() aggregeringsfunktionen i Spring Data for MongoDB, som oversættes til at summere trin med 1 i den oprindelige Mongo-skal. Dette er min sidste JUnit-test:

    /**
     * Test page posts count
     */
    @Test
    public void testPagePostsCount() throws Exception{
        MongoTemplate template = repository.getMongoTemplate();
        Page page = new Page();
        page.setPageId("2210");
        page.setUserId("azec");
        List<String> postList = new ArrayList<String>();
        postList.add("53eb1a560efbe048c7ea698d");
        postList.add("53eb1a6b0efbe048c7ea698e");
        page.setPostIds(postList);
        template.save(page);

        Aggregation agg = newAggregation(
            match(Criteria.where("_id").is("2210")),
            unwind("postIds"),
            group("_id").count().as("nPosts"),
            project("nPosts").and("_id").as("pageId")
        );

        AggregationResults<PostCount> results = template.aggregate(agg, "page", PostCount.class);
        List<PostCount> postCount = results.getMappedResults();
        Assert.assertTrue(!postCount.isEmpty());
        Assert.assertTrue(postCount.get(0).nPosts == 2);
        Assert.assertTrue(postCount.get(0).pageId.equals("2210"));
    }

    private class PostCount {
        String pageId;
        int nPosts;
    }

Så endelig oversættes dette til følgende native aggregeringsoperation:

{
   "aggregate":"page",
   "pipeline":[
      {
         "$match":{
            "_id":"2210"
         }
      },
      {
         "$unwind":"$postIds"
      },
      {
         "$group":{
            "_id":"$_id",
            "nPosts":{
               "$sum":1
            }
         }
      },
      {
         "$project":{
            "nPosts":1,
            "pageId":"$_id"
         }
      }
   ]
}



  1. MongoDb:hvordan man opretter det rigtige (sammensatte) indeks for data med mange søgbare felter

  2. mongodb tekstsøgning med flere felter

  3. MongoDB:er det sikkert at bruge dokumentets ID offentligt?

  4. hvordan gemmer man dataframe i mongodb ved hjælp af pyspark?