MongoDB聚合-如何使用spring-data-mongodb将查询表达式应用到匹配阶段？

zbdgwd5y 于 2022-12-12 发布在 Go

关注(0)|答案(3)|浏览(178)

我的文档中包含动态字段，我需要根据给定的复杂查询条件查找匹配记录的计数

示例实体

@Document(collection = "UserAttributes")
public class UserAttributesEntity {
    @Id
    @Getter
    private String id;
    @NotNull
    @Size(min = 1)
    @Getter @Setter
    private String userId;
    @NotNull
    @Getter @Setter
    private Map<String, Object> attributes = new HashMap<>();
}

示例数据

{
    "_id" : ObjectId("6164542362affb14f3f2fef6"),
    "userId" : "89ee6942-289a-48c9-b0bb-210ea7c06a88",
    "attributes" : {
        "age" : 61,
        "name" : "Name1"
    }
},
{
    "_id" : ObjectId("6164548045cc4456792d5325"),
    "userId" : "538abb29-c09d-422e-97c1-df702dfb5930",
    "attributes" : {
        "age" : 40,
        "name" : "Name2",
        "location" : "IN"
    }
}

需要查询表达式

"((attributes.name == 'Name1' && attributes.age > 40) OR (attributes.location  == 'IN'))

$match的MongoDB聚合查询如下所示，但无法通过spring mongo db API获得相同的查询：

{ 
    $expr: 
    { 
        "$and": [{
            "$gt": ["$attributes.age", 40]
        }, {
            "$eq": ["$attributes.name", "Name2"]
        }] 
    }
}

我错过什么了吗？
库使用：数据org.springframework.data库：3.1.1

mongodb

来源：https://stackoverflow.com/questions/69641321/mongodb-aggregation-how-can-i-apply-query-expression-into-match-stage-using-sp

3条答案

按热度按时间

ao218c7q1#

您可以实现自己的AggregationOperation来处理各种情况。我还没有尝试过自己的代码，但应该是这样的：

AggregationOperation myMatch (List<Document> conditions) {
    return new AggregationOperation() {
        @Override
        public String getOperator() {
            return "$match";
        }
        @Override
        public Document toDocument(AggregationOperationContext context) {
            return new Document("$match",
                    new Document("$expr",
                            new Document("$and", conditions)
                    )
            );
        }
    };
}

并以这种方式调用它（以匹配您问题查询）：

void callMyMatch() {
    myMatch(List.of(
        new Document("$gt", List.of("$attributes.age", 40)),
        new Document("$eq", List.of("$attributes.name", "Name2"))
    ));
}

展开查看全部

赞(0）回复(0）举报 2022-12-12

ve7v8dk22#

这个项目阶段允许我们使用查询表达式，我把我的方法转换到下面来达到结果：

private Mono<Long> aggregate() {
    final Aggregation aggregation = Aggregation
            .newAggregation(
                    Aggregation.project("userAttributes.playerLevel", "userAttributes.name")
                        .andExpression("((userAttributes.name == 'Name1' && userAttributes.age > 40) OR (userAttributes.location  == 'IN'))")
                        .as("result"),
                    Aggregation.match(Criteria.where("result").is(true)),
                    Aggregation.group().count().as("count"));
    return mongoTemplate.aggregate(aggregation, mongoTemplate.getCollectionName(UserAttributesEntity.class), Map.class)
       .map(result -> Long.valueOf(result.get("count").toString()))
       .next()
}

赞(0）回复(0）举报 2022-12-12

83qze16e3#

在spring-data-mongodb库中仍然不支持$expr操作符。但是有一个使用MongoTemplate的解决方案来解决这个问题-
Aggregation.match（）提供了一个重载方法，它接受AggregationExpression作为参数。

$match运算子的AggregationExpression使用范例-

Aggregation aggregationQuery = Aggregation.newAggregation(Aggregation.match(AggregationExpression.from(MongoExpression.create("'$expr': { '$gte': [ '$foo', '$bar'] }"))));
mongoTemplate.aggregate(aggregationQuery, Entity.class);

以上代码相当于query -

db.collection.aggregate([{"$match": {"$expr": {"$gte: ["$foo", "$bar"]}}}])

问题的代码应该是这样的-

Aggregation aggregationQuery = Aggregation.newAggregation(Aggregation.match(AggregationExpression.from(MongoExpression.create("'$expr': { '$and': [{ '$gt': ['$attributes.age', 40] }, { '$eq': ['$attributes.name', "Name2"] }] }"))));
mongoTemplate.aggregate(aggregationQuery, Entity.class);

赞(0）回复(0）举报 2022-12-12

我来回答

MongoDB聚合-如何使用spring-data-mongodb将查询表达式应用到匹配阶段？

3条答案

相关问题

热门标签

最新问答