查询对象列表,查找不同对象的某些属性(CosmosDB SQL API)

问题描述 投票:1回答:1

当我尝试选择一个对象数组时,我遇到了查询问题(CosmosDB SQL API)。我想知道我的搜索的所有参数是否都在不同的对象中。

应该找到下一个文件:

{
    "_id" : "97e9272d-cd7e-4a26-3245-o4e67h29beqw",
    "_type" : "Document",
    "categories" : [ 
        {
            "_name" : "PruebaCategoria", (searching by this)
            "Type" : "omega",
            "Policy number" : "1234567890",
            "date" : 1553081146391,
            "boolean" : true
        }, 
        {
            "_name" : "CategoryDemoTest",
            "Type" : "free",
            "Policy number" : "0987654321"
        }, 
        {
            "_name" : "CategoryDemoTestDates",
            "dateInitial" : 1553081146592, (and by this in range)
            "dateEnd" : 1553081146594,
            "Type" : "omega"
        }
    ],
    "partitionNumber" : 1,
    "serial" : 1
}

我想复制与mongodb API一起使用的下一个查询:

{ "categories" : { "$all" : [{ "$elemMatch" : { "dateInitial" : { "$gt" : { "$numberLong" : "1553081146591" }, "$lt" : { "$numberLong" : "1553081146593" } } } }, { "$elemMatch" : { "_name" : "PruebaCategoria" } }] } }

我尝试了以下查询,但似乎只有一个对象具有我正在寻找的所有元素时它们才匹配:

"SELECT VALUE c FROM c JOIN cat in c.categories WHERE cat._name=\"PruebaCategoria\" AND cat.dateInitial > 1553081146591 AND cat.dateInitial < 1553081146593"

退出执行此类搜索的方法(使用Cosmos DB SQL API)?

azure-cosmosdb azure-cosmosdb-sqlapi
1个回答
0
投票

根据cosmos db sql api中的所有Array Functions,在mongo db中没有这样的直接方法来实现与"$all""$elemMatch"类似的功能。

在这里提供stored procedure解决方法。

码:

function sample() {
    var collection = getContext().getCollection();

    var isAccepted = collection.queryDocuments(
        collection.getSelfLink(),
        'SELECT * FROM c',
    function (err, feed, options) {
        if (err) throw err;

        if (!feed || !feed.length) {
            var response = getContext().getResponse();
            response.setBody('no docs found');
        }
        else {
            var returnArray = [];
            for(var i =0;i<feed.length;i++){
                var nameFlag = false;       
                var dateInitialFlag = false;         
                for(var j = 0;j<feed[i].categories.length;j++){              
                    if(nameFlag == false) {
                         if(feed[i].categories[j]._name == 'PruebaCategoria'){
                            nameFlag= true;
                         }
                    }
                    if(dateInitialFlag == false){
                         if(feed[i].categories[j].dateInitial <1553081146593 || feed[i].categories[j].dateInitial > 1553081146590){
                            dateInitialFlag= true;
                        }
                    }
                    if (nameFlag == true && dateInitialFlag == true) {
                        returnArray.push(feed[i]);
                        break;
                    } 
                }
            }
            var response = getContext().getResponse();
            response.setBody(returnArray);
        }
    });

    if (!isAccepted) throw new Error('The query was not accepted by the server.');
}

你也可以pass arguments to SP,以便你可以动态过滤数据。

© www.soinside.com 2019 - 2024. All rights reserved.