MongoDB
 sql >> Teknologi Basis Data >  >> NoSQL >> MongoDB

Jumlah agregasi di Spring Data MongoDB

Saya telah menemukan ini akhirnya. Kuncinya adalah menggunakan fungsi agregasi count() di Data Musim Semi untuk MongoDB, yang diterjemahkan menjadi jumlah kenaikan sebesar 1 di shell Mongo asli. Ini adalah Tes JUnit terakhir saya:

    /**
     * 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;
    }

Jadi akhirnya ini diterjemahkan menjadi operasi agregasi asli berikut:

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



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Bagaimana cara menanyakan hanya dokumen dengan stempel waktu terbaru dari grup?

  2. $proyek di $lookup mongodb

  3. Masukkan nilai default tidak berfungsi mongodb

  4. Agregasi Mongodb berdasarkan Hari lalu Jam

  5. Multer - cara menangani file menggunakan upload.fields() setelah file dikirimkan