MongoDB выбора вложенного документа на основе результата поиска родительского документа

Question

У меня есть chats коллекция ведьма образец документа с

{ 
    "_id" : ObjectId("57f95e8e385bb61c5cf2cd18"), 
    //some other fields 
    "messages" : [ 
      { 
        "sender" : "57ec1aaa0ffe16123439d52b", 
        "message" : "Hello!", 
        "sentTime" : "Oct 13, 2016 1:51:31 AM" 
      }, 
      { 
        "sender" : "57ec1aaa0ffe16123439d52b", 
        "message" : "Hello!", 
        "sentTime" : "Oct 13, 2016 1:51:33 AM" 
      } 
    ] 
} 

Я хочу найти свою коллекцию на основе _id поля и только получить данные из messages sub-document в качестве результата запроса с использованием java-драйвера для MongoDB, поскольку я хочу, чтобы Map to POJO-массив использовал Gson.

Желаемая Выход:

[ 
     { 
       "sender" : "57ec1aaa0ffe16123439d52b", 
       "message" : "Hello!", 
       "sentTime" : "Oct 13, 2016 1:51:31 AM" 
     }, 
     { 
       "sender" : "57ec1aaa0ffe16123439d52b", 
       "message" : "Hello!", 
       "sentTime" : "Oct 13, 2016 1:51:33 AM" 
     } 
] 

Как я могу идти с этим с помощью драйвера Java для MongoDB

Answer 1

Нам нужно указать запрос и список полей, вот пример того, как сделать это:

DB db = //get db 

DBObject object = new BasicDBObject(); 
object.put("_id", new ObjectId("<some id>")); 
DBObject fields = new BasicDBObject(); 
fields.put("messages", 1); 
DBObject result = db.getCollection("test").findOne(object, fields); 
System.out.println(result.get("messages")); 

Answer 2

Возможно, это немного уродливо, но это сработает.

chats.aggregate(Arrays.asList(
    match(eq("_id", <your id here>)), 
    unwind("$messages"), 
    project(fields(excludeId(), 
        computed("sender", "$messages.sender"), 
        computed("message", "$messages.message"), 
        computed("sentTime", "$messages.sentTime"))) 
    )).forEach(printBlock); 

printBlock только распечатывает каждый документ (их можно собрать, чтобы массировать там).

Block<Document> printBlock = new Block<Document>() { 
     @Override 
     public void apply(final Document document) { 
      System.out.println(document.toJson()); 
     } 
    };