Java에서 Mongodb를 정렬하고 구별하십시오. 3.2

내 mongodb에 80,000 개의 문서가 있습니다. Java 드라이버를 사용하여 이러한 문서를 쿼리하고 있습니다. 특정 필드를 기반으로 내 문서를 정렬 한 다음이 결과에 고유 한 필터를 적용하려고했습니다. 정렬 옵션은 잘 작동하지만 별개의 문서는 얻을 수 없습니다. 나는 나의 작업 예제를 첨부했다.Java에서 Mongodb를 정렬하고 구별하십시오. 3.2

Document query = new Document("RetweetCount",-1); 
    MongoCursor<Document> cursor = collection.find().sort(query).iterator(); 
    try{ 
    while(cursor.hasNext()) { 
     Document dr = (Document) cursor.next(); 
     String stat = dr.getString("status"); 
     int retweetcount = dr.getInteger("RetweetCount"); 
     //Sort works fine. I have to apply distinct here!!! distinct is based on status field 
     System.out.println(retweetcount+"--->"+stat); 
    } 
    }finally{ 
     cursor.close(); 
    } 
}

출처

2016-06-13 prabhu

http://api.mongodb.com/java/3.2/com/mongodb/operation/DistinctOperation.html 샘플 데이터베이스를 제공한다면 조금 알아낼 수 있습니다. – Newton

@Netwon 내 db 구조는 다음과 같습니다. {status : x, retweetcount : 2}, {status : y, retweetcount : 5}, {status : x, retweetcount : 3} 새로운 상태와 그 retweetcount와 함께 저장할 때마다. 상태에 대한 최고 retweetcount를 가져야하지만 내 db에 중복 상태가 있습니다. 상태를 얻고 싶습니다 : x와 retweetcount : 3, 그 상태에 대한 가장 높은 retweetcount 있습니다. – prabhu

컬렉션을 백업 할 수 있습니까? – Newton

이 방법을 시도했지만 관련이없는 필드를 가져옵니다. I referred this link

ArrayList<Document> dd = new ArrayList<Document>(); 
    //MongoCursor<Document> cursor1 = collection.find().sort(query).iterator(); 

    Document grouping = new Document("_id","$status"); 
    grouping.append("text", new Document("$first","$_id")); 
    grouping.append("RetweetCount", new Document("$first","$RetweetCount")); 
    grouping.append("screen_name", new Document("$first","screen_name")); 
    Document group = new Document("$group",grouping); 
    System.out.println(group); 

    Document sortfields = new Document("RetweetCount",-1); 
    Document sort = new Document("$sort",sortfields); 

    Document projectfields = new Document("_id",0); 
    projectfields.append("_id", "$text"); 
    projectfields.append("RetweetCount", "$RetweetCount"); 
    projectfields.append("sn", "$screen_name"); 
    Document projects = new Document("$project",projectfields); 



    AggregateIterable<Document> iterable = collection.aggregate(asList(new Document(group),new Document(sort),new Document(projects))); 
    iterable.forEach(new Block<Document>() { 
     @Override 
     public void apply(final Document document) { 
      System.out.println(document.toJson()); 
     } 
    });

출력 :

{ "_id" : { "$oid" : "576124fafbfb870794452ac6" }, "RetweetCount" : 643, "sn" : "screen_name" }

그것은 내 텍스트 필드 대신이 id 필드에 반환 생략합니다. 또한 내 retweet 순서가 올바르지 않습니다. 이 방법은 정상적으로 작동하지만 결과가 다릅니다. 아무도 나를 교정하지 않을 수 있었습니까 !!!

출처

2016-06-17 13:23:22 prabhu

나는 해결책을 얻었다. – prabhu

Java에서 Mongodb를 정렬하고 구별하십시오. 3.2

답변

관련 문제