0

次のMongoDBコレクション " Games" があります:

{ 
"_id" : ObjectId("515461d3c6c18efd4a811fd3"), 
"gameid" : NumberLong("86982207656"), 
"tableName" : "Hydra Zoom 40-100 bb", 
"nplayers" : 6, 
"playersList" : [   
                                    {           "exist" : true,         
                                                        "suspended" : false,
                                                        "grade" : 0,
                                                        "clusterId" : -1,
                                                        "playerid" : "DoomY9999",
                                                        "playsWithFriends" : 0,
                                                        "squeezePlay" : 0,
                                                        "weakShowdown" : 0,
                                                        "numberOfPlays" : 1
                                     },
                                  {
                                                        "exist": true,
                                                        "suspended" : false,

次のMySQLクエリを MongoDBにマップしたいと思います

String query = "SELECT idplayer, COUNT(idplayer) AS countplayer "
                    + "FROM (SELECT b.idgame, b.idplayer "
                    + "FROM associations a, associations b "
                    + "WHERE a.idplayer=? "
                    + "AND b.idgame=a.idgame "
                    + "AND b.idplayer <> ? "
                    + "ORDER BY b.idgame DESC LIMIT 1000) as c"
                    + " GROUP BY idplayer "
                    + "ORDER BY countplayer DESC LIMIT 5;";

クエリの説明: この SQL クエリは、プレイヤー 'X' の同じゲームを最も頻繁にプレイしていると思われるプレイヤーをカウントします。結果は、プレイヤーの名前と一緒にプレイした回数になります

LIMIT についての簡単な注意: 最初の " LIMIT 1000" は、実際には調査したいゲームの制限になります。データベースが非常に大きくなる可能性があるため、最後の 1000 ゲームのみを DESC 順に分析します (最新のものは " gameid" が高くなります)。

2 番目の制限 5: は、「上位 5」人のフレンド用です。それらの数を合計します。

これまでのところ、Aggregation Framework のほとんどすべてが"ORDER BY b.idgame DESC LIMIT 1000) as c". 通過するゲームの数が非常に多い可能性があるため、これは私にとって重要です。

これがMongoDB（Javaドライバー） での私のクエリです：

 //build the query
    DBObject match1 = new BasicDBObject("$match", new BasicDBObject("playersList.playerid",_playerid));
    DBObject unwind = new BasicDBObject("$unwind", "$playersList");
    DBObject match2 = new BasicDBObject("$match", new BasicDBObject("playersList.playerid",new BasicDBObject("$ne",_playerid)));

    DBObject groupFields = new BasicDBObject("_id","$playersList.playerid");
    groupFields.put("times", new BasicDBObject("$sum",1));
    DBObject group = new BasicDBObject("$group", groupFields);
    DBObject sort = new BasicDBObject("$sort", new BasicDBObject("times",-1) );
    DBObject limit = new BasicDBObject("$limit", 5 );

    DBObject group2 = new BasicDBObject("$group", "gameid");
    DBObject sort2 = new BasicDBObject("$sort", new BasicDBObject("gameid",-1) );
    DBObject limit2 = new BasicDBObject("$limit", 1000 );

    DB db = mongoDb;
    DBCollection coll = db.getCollection("games");

    //aggregation query
    //THIS WORKS
    AggregationOutput output = coll.aggregate( match1, unwind, match2, group, sort, limit);

    //THIS DOESN'T WORK!
     AggregationOutput output = coll.aggregate( match1, unwind, match2, group, sort, limit, group2, sort2, limit2);

このクエリを修正するのを手伝ってください。ありがとう！

4

1 に答える 1

2

フィールドgameは最初のgroup操作の結果に含まれていなかったためgroup、フィールドに基づく 2 番目の操作は機能しgameませんでした。

より効率的なクエリを行うには、集計操作の順序を変更して、できるだけ早くデータを削減する必要があります。私は、playersList をアンワインドする前にゲームのマッチングを移動しました。2 番目のグループは必要ありません。

集計操作は、mongo シェルでは次のようになります。

// playerId to search for coplayers
var playerId = "DoomY9999"

db.game.aggregate([
    // First $match can take advantage of suitable index if available

    // Find all games that playerid X has played
    { $match : { "playersList.playerid" : playerId } },

    // Sort by most recent games (gameid descending)
    { $sort : { "_id.gameid" : -1 } },

    // Limit number of games to examine
    { $limit : 1000 },

    // Create a stream of documents from the playersList array
    { $unwind : "$playersList" },

    // Match players except for playerid X
    { $match : { "playersList.playerid" : {$ne : playerId }} },

    // Count number of games each player has played
    { $group : {
        _id : "$playersList.playerid",
        count : { $sum : 1 }
    }},

    // Sort by most frequent players (count descending)
    { $sort : { "count" : -1 } },

    // Limit results to 5 players
    { $limit : 5 },

    // Rename the result fields
    { $project : {
        _id : 0,
        coplayer : "$_id",
        count : 1
    }}
])
于 2013-04-12T04:55:36.560 に答える