javascript - 如何将解析云代码的query.count结果保存在变量中？

Question

我是解析云代码的新手。我编写了一个函数，我试图在其中根据适配器名称(用户输入)获取特定过程的计数。我的代码如下:

Parse.Cloud.define("getProcedureList",function (req, res)
{
    var resultCount;
    var query = new Parse.Query("mst_logReports");
    query.limit(10);

    query.equalTo("adapterName",req.params.adapterName);
    query.find({
        success: function (result) {
            var resultArr = [];
            var resultlen = result.length;

            var tempArr = {};
            if (resultlen > 0) {
                for (var i = 0; i < resultlen; i++) {
                    tempArr = {

                        "procedure":result[i].get("procedure") : 

                        // (here I want the count of this procedure). 
                        // How to use query.count inside this for loop 
                        // so that I can get the counts? 

                    }
                    resultArr.push(tempArr);
                }
            }
            res.success(resultArr);
        },
        error: function (error) {
            res.success(error);
        }
    })
 });

注意:代码运行良好。但是我无法在上面的代码中获得该特定过程的计数。

如有任何帮助，我们将不胜感激。谢谢

Answer 1

我无法准确捕捉到你想要的内容。

我假设您想通过每个 mst_logReports 对象获取计数。

success: function (result) {
    var resultArr = [];
    var resultlen = result.length;

    var tempArr = {};
    if (resultlen > 0) {
        var promises = [];
        for (var i = 0; i < resultlen; i++) {
            var report = result[i];
            var query = new Parse.Query('???');
            query.equalTo('xxx', report.get('qqq'));
            promises.push(query.count());
        }
        Parse.Promise.when(promises)
        //arguments.length will equalTo promises.length, or declare arg1, arg2 ... to fit resultLen
        .then(function(){
            //get all count success

            var counts = arguments;
            for(var i=0; i<counts.length; i++){
                //why this object end with : ????
                tempArr = {
                    "procedure":result[i].get("procedure") : 
                }

                resultArr.push(tempArr);
            }
            res.success(resultArr);
        }, res.error);
    } else {
        res.success(resultArr);
    }
}

云代码请求太多不合适，只有15秒。更好的方法是保持对 mst_logReports 对象的计数。你可以在afterSave中使用increment(确保它已经被保存)。

===================已编辑=================

mst_logReports 包含 2 个字段，分别是 adapterName(String) 和 procedure(String)。

mst_logReports

adapter, procedure
A, x
A, x
A, y
B, x
B, y

你的用户输入A

你想要得到 [{x:2},{y,1}]

var procedureCnts = {};
for(var i=0; i<counts.length; i++){
    var procedure = result[i].get("procedure");
    if(procedureCnts[procedure]){
        procedureCnts[procedure]++;
    }else{
        procedureCnts[procedure] = 0;
    }
}
for(var key in procedureCnts){
    tempArr = {
        "procedure" : key,
        "count": procedureCnts
    }
    resultArr.push(tempArr);
}

res.success(resultArr);

遗憾的是，由于 query.limit 不能 >1000，此函数无法缩放。

如果所有过程类型是固定的。您可以尝试以下(作为我的第一个回答方式)

Parse.Cloud.define("getProcedureList",function (req, res)
{
    var possibleProcedures = ['x', 'y', 'z'];
    var promises = [];
    var results = [];
    for(var i=0; i<possibleProcedures.length; i++){
        var query = new Parse.Query("mst_logReports");
        query.equalTo("adapterName", req.params.adapterName);
        query.equalTo("procedure", possibleProcedures[i]);
        promises.push(query.count());
    }

    //Parse.Promise.when() is closed to es6 Promise.all()
    Parse.Promise.when(promises)
    //arguments.length will equalTo promises.length, or declare arg1, arg2 ... to fit resultLen
    .then(function(){
        //promises.length == arguments.length

        for(var i=0; i< arguments.length; i++){
            results.push({
                "procedure": possibleProcedures[i],
                "count": arguments[i]
            });
        }
        res.success(results);
    }, res.error);

});

如果可能的程序不固定，我找不到适合您问题的正确解决方案。

================其他解决方案==============

下一种方式更灵活，避免过多的 api-request。并且 query.count() 很慢并且对于 db 来说加载太高。

您应该维护 2 个类，适配器和过程。

Adapter: name(string), procedureCnt(jsonObject)
Procedure: adapter(pointer of adapter), name(string)

保存过程

function(adapterName){
    var query = new Parse.Query("Adapter");
    query.equalTo("name", adapterName);
    query.first().then(
        function(adapter){
            if(adapter){
                var Procedure = Parse.Object.extend("Procedure");
                var procedure = new Procedure();
                procedure.set('adapter', adapter);
                procedure.save().then(response.success, response.error);
            }else{
                response.error("the adapter is not exist");
            }
        }, response.error
    );
}

程序保存后:

Parse.Cloud.afterSave("Procedure", function(req) {
    var procedure = req.object;
    var adapter = procedure.get('adapter');
    var key = 'procedureCnt.' + procedure.get('name');
    adapter.increment(key, 1);
    adapter.save();
});

程序删除后:

Parse.Cloud.afterDelete("Procedure", function(req) {
    var procedure = req.object;
    var adapter = procedure.get('adapter');
    var key = 'procedureCnt.' + procedure.get('name');
    adapter.increment(key, -1);
    adapter.save();
});

查询适配器的数量

function(name){
    var query = new Parse.Query("Adapter");
    query.equalTo('name', name);
    query.first().then(
        function(adapter){
            if(adapter){
                response.success(adapter.get('procedureCnt'));
            }else{
                response.error('adapter not found');
            }
        }, reponse.error
    );
}

唯一的问题是 AfterSave 并不总是成功。并不是说，你仍然可以通过 Parse.Promise.when() 做很多 query.count()。用法在上述代码之一中。