java - 在 MongoDB Java 驱动程序中使用数组字段的项目

标签 java arrays mongodb mongodb-java

我有以下 Collection 。我已通过用户查询此集合。

 {
      "user": "username",
      "sites": {
        "site": "abc",
        "keywords": [
          {
            "keyword": "keyword1",
            "dailyranks": [
              {
                "fild1": "value1"
              },
              {
                "fild2": "value2"
              },
              {
                "fild3": "value3"
              },
            ]
          },
          {
            "keyword": "keyword2",
            "dailyranks": [
              {
                "fild1": "value1"
              },
              {
                "fild2": "value2"
              },
              {
                "fild3": "value3"
              },  
            ]
          },
        ],
      }
    }

我想从集合中获取结果如下,我想获取集合中关键字数组的最后一个元素

[
    {
        "keyword" : "keyword1"
        "fild2" : "value2",
        "fild3" : "value3"
    },
    {
       "keyword" : "keyword2"
        "fild2" : "value2",
        "fild3" : "value3"
    },
]

我使用$project进行了聚合,但没有成功。帮我解决这个问题。

使用的代码-

BasicDBObject siteObject = new BasicDBObject();
siteObject.append("keywords", "$sites.keywords.keyword");
siteObject.append("lastrank", "$sites.keywords.dailyranks");

BasicDBList aDBList = new BasicDBList();
aaa.add(new BasicDBObject("user", modelLogin.getUSER_NAME()));

ArrayList<BasicDBObject> doc = new ArrayList<>();
doc.add(new BasicDBObject().append("$unwind", "$sites"));
doc.add(new BasicDBObject("$match", aDBList));
 doc.add(new BasicDBObject().append("$project", siteObject));
AggregationOutput output = coll.aggregate(doc);

最佳答案

您可以尝试以下聚合。

使用$map 转换Keywords 数组。

$map 中,使用 $arrayElemAt 投影 dailyranks$let 中的最后一个和倒数第二个值> 运算符来保存 $arrayAtElem 的结果并投影 fild 值。

db.coll.aggregate({
    $project: {
        keywords: {
            $map: {
                input: "$sites.keywords",
                as: "result",
                in: {
                    keyword: "$$result.keyword",
                    fild2: {$let: {vars: {obj: {$arrayElemAt: ["$$result.dailyranks", -2]}},in: "$$obj.fild2"}},
                    fild3: {$let: {vars: {obj: {$arrayElemAt: ["$$result.dailyranks", -1]}},in: "$$obj.fild3"}}
                }
            }
        }
    }
})

Java 等效项

MongoClient mongoClient = new MongoClient();
MongoDatabase db  = mongoClient.getDatabase("db")
MongoCollection<Document> collection = db.getCollection("collection");
List<Document> results =
    collection.aggregate(
        Arrays.asList(
            Aggregates.match(Filters.eq("user", modelLogin.getUSER_NAME() )),
            Aggregates.project(
                Projections.fields(
                    new Document("keywords",
                        new Document("$map",
                        new Document("input", "$sites.keywords").
                        append("as", "result").
                        append("in",
                            new Document("keyword","$$result.keyword").
                                append("fild2",
                                    new Document("$let",
                                    new Document("vars", new Document("obj",
                                            new Document("$arrayElemAt", Arrays.asList("$$result.dailyranks", -2)))).
                                    append("in", "$$obj.fild2" ))).
                                append("fild3",
                                    new Document("$let",
                                    new Document("vars", new Document("obj",
                                            new Document("$arrayElemAt", Arrays.asList("$$result.dailyranks", -1)))).
                                    append("in", "$$obj.fild3" )))
                            )
                        )
                    )))
        )).into(new ArrayList<>());

关于java - 在 MongoDB Java 驱动程序中使用数组字段的项目,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42854464/

相关文章:

java - 搜索和计算文本文件 Java 中的特定单词

java - 如何将用户输入的 6 个数字与随机生成的 6 个数字进行比较,看看它们是否相同

MongoDb 聚合 $count 以显示 0

java - 将查询结果拉入数据表

java - IntelliJ 中的共享内容根(跨模块共享源)

c - A[m][n]中的A不是指针吗(类比我们用指针定义二维矩阵)

php - 用数组php中的空值替换空字符串

c# - 不支持 MongoDB 序列化 ()

MongoDb:聚合 $lookup 过滤外部文档

java - 如何增加 Cassandra 的数据流读取并行度