2

MongoDBでの高度なカウントクエリに問題があります。

ドキュメントフィールド内のオブジェクトをカウントしようとしていますが、クエリに一致する前の要素が存在し、配列内で 古い場合に限ります。

説明させてください…。

私はコンテナドキュメントを持っています、次のように見えます：

{
 "_id" : ...,
 [...]
 "objects" : [ ]
}

オブジェクトフィールド内：次のようなオブジェクトドキュメント
があります。

[
  {
    "_id" : ...,
    "name" : "foo",
    "properties" = [ ],
    "time" = 000000042
  }

  {
    "_id" : ...,
    "name" : "bar",
    "properties" = [ ],
    "time" = 000000424
  }

  {
    "_id" : ...,
    "name" : "baz",
    "properties" = [ ],
    "time" = 000004242
  }

今のところ、含まれているコンテナドキュメントの数を
数えます：オブジェクト1（foo）のコンテナの
数、オブジェクト1と2（fooとbar）のコンテナの
数、オブジェクト1、2、3（foo、bar、baz ）のコンテナの数）。

しかし、今は、 barがfooよりも古い場合にのみfooとbarをカウントしたい（時間フィールドを使用）...オブジェクト1のコンテナーのカウント（foo）、オブジェクト1と2のコンテナーのカウント（fooとbar）、およびfoo.time <bar.timeオブジェクト1、2、および3（foo、bar、baz）を含むコンテナーのカウントAND foo.time <bar.time <baz.time


問題は、コンテナごとに時間フィールドを変更する必要があることです。言い換えれば、ドキュメントごとに動的クエリを使用するにはどうすればよいですか？

ここにコードのサンプルがあります：

foreach ($COUNTER[ARRAY_FIELDS_NAME_TO_COUNT] as $key => $value)
{
// Build the query (Name & properties)
$match[$key] = array('$elemMatch' => array('name' => $value['name']));
foreach ($value['properties'] as $propertyName => $propertyValue)
  $match[$key]['$elemMatch']["properties.$propertyName"] = $propertyValue;

// Time checking
if ($key > 0)
{
  //FIXME with a... dynamics query searching inside current doc??
  //           or   a special var set to the previous object matched...  or MapReduce..
}


// Make the query
$query = array('objects' => array('$all' => $match));

$result[$key]['count'] = $db->person->count($query);
}

私はMongoDBを初めて使用しますが、それを効率的に行うためのベストプラクティスが何であるかは本当にわかりません。

よろしく！

4

1 に答える 1

1

シェル (javascript) で Aggregation Framework を使用してこれを行う方法を次に示します。

読みやすくするためにこれを複数の行に分割したことに注意してください。実際のクエリは最後の行です。私は foo bar と baz を使用しましたが、もちろん、より適切なものに調整したいと考えています。

match = { "$match" : { "objects.name" : "foo" } };
unwind = { "$unwind" : "$objects" };
projectDates = {"$project" : {
        "_id" : 1,
        "objects" : 1,
        "fooDate" : {
            "$cond" : [
                {
                    "$eq" : [
                        "$objects.name",
                        "foo"
                    ]
                },
                "$objects.time",
                0
            ]
        },
        "barDate" : {
            "$cond" : [
                {
                    "$eq" : [
                        "$objects.name",
                        "bar"
                    ]
                },
                "$objects.time",
                0
            ]
        },
        "bazDate" : {
            "$cond" : [
                {
                    "$eq" : [
                        "$objects.name",
                        "baz"
                    ]
                },
                "$objects.time",
                0
            ]
        }
    }
};
group = {"$group" : {
        "_id" : "$_id",
        "objects" : {
            "$push" : "$objects"
        },
        "maxFooDate" : {
            "$max" : "$fooDate"
        },
        "maxBarDate" : {
            "$max" : "$barDate"
        },
        "maxBazDate" : {
            "$max" : "$bazDate"
        }
    }
};
projectCount = {"$project" : {
        "_id" : 1,
        "foos" : {
            "$add" : [
                1,
                0
            ]
        },
        "foosAndBars" : {
            "$cond" : [
                {
                    "$lt" : [
                        "$maxFooDate",
                        "$maxBarDate"
                    ]
                },
                1,
                0
            ]
        },
        "foosBarsAndBazs" : {
            "$cond" : [
                {
                    "$and" : [
                        {
                            "$lt" : [
                                "$maxBarDate",
                                "$maxBazDate"
                            ]
                        },
                        {
                            "$lt" : [
                                "$maxFooDate",
                                "$maxBarDate"
                            ]
                        }
                    ]
                },
                1,
                0
            ]
        }
    }
};
countFoos = {"$group" : {
        "_id" : "FoosBarsBazs",
        "Foos" : {
            "$sum" : "$foos"
        },
        "FBs" : {
            "$sum" : "$foosAndBars"
        },
        "FBBs" : {
            "$sum" : "$foosBarsAndBazs"
        }
    }
};


db.collection.aggregate([match, unwind, projectDates, projectCount, countFoos]).result
于 2012-10-09T19:33:23.547 に答える