从 basicdblist Mongodb 中检索值

Question

{
DB db = Helper.connectingMonggo();
BasicDBObject query = new BasicDBObject();
query.put("_id", "123");
DBCollection table = new db.getCollection("prodDetail");
DBCursor cursor = table.find(query); --// cursor has only one record (size =1)

while(cursor.hasNext()){
  DBObject obj = cursor.next();
  List<String> upcs = new ArrayList<>();
  BasicDBList list = (BasicDBList) obj.get("prodList"); --//here prodList size also 1 always
  DBObject obj1 = (DBObject) list.get(0);
  BasicDBList detailsList = (BasicDBList) obj1.get("pDetailsList");

 for(Object obj2 : detailsList){
   JSONObject obj3 = new JSONObject(JSON.serialize(obj2));
   ups.add(obj3.get("upcStatus").toString());
 } } }

我正在获取带有 upcStatus 的列表数组，但是，它是正确的书写方式吗？

Answer 1

这是一个使用 MongoDB Java 驱动程序 v3.12 和 MongoDB v4.2 的聚合查询。请注意，结果是使用单个查询返回的，没有其他代码。这很有用，因为查询完全在服务器上运行并将结果返回到您的 Java 应用程序。

try(MongoClient mongoClient = MongoClients.create()) {
    MongoDatabase database = mongoClient.getDatabase("test");
    MongoCollection<Document> coll = database.getCollection("testCollection");
    List<Bson> pipeline = Arrays.asList(
        Aggregates.match(Filters.eq("_id", 123)),
        Aggregates.project(Projections.fields(
            Projections.excludeId(), 
                Projections.computed("upcStatus", Filters.eq("$arrayElemAt", 
                    Arrays.asList("$prodList.pDetailsList.upcStatus", 0L))
                )
        ))
    );
    
    Document doc = coll.aggregate(pipeline).first();
    System.out.println(doc.toJson());    // prints the array of upcStatus field values
}

代码中使用的类定义为以下类或包中：org.bson.Document、org.bson.conversions.Bson、com.mongodb.client.model.*和com.mongodb.client.*。

另外，请注意try 语句块打开与服务器的连接，并在尝试块结束时自动关闭。