Mongodb агрегат изменить элемент перед нажатием - PullRequest
Новая
       32

Mongodb агрегат изменить элемент перед нажатием

0 голосов
/ 14 сентября 2018

Я пытаюсь сделать агрегированный запрос на mongodb, используя doctrine mongodb.

вот упрощенная версия документов, к которым я обращаюсь: 

{
    "_id" : ObjectId("574edf0ece8300c95ae0a1a4"),
    "user" : {
        "$ref" : "User",
        "$id" : ObjectId("574eac76ce8300a251e0a1a4"),
        "$db" : "master"
    },
    "content" : "some text",
    "hash" : "f46fe1003204704ce11edb15ff4b0ca3f93232da",
    "servicesToPublish" : [ 
        {
            "serviceTokenId" : "53931163ce830032106dfa6f",
            "status" : "published",
            "statusUpdatedAt" : ISODate("2016-06-01T13:12:17.000Z"),
            "type" : "text"
        }
    ]
}

вот запрося использую: 

$aggregationBuilder
    ->match()
        ->field('servicesToPublish.status')->equals(ServiceToPublish::STATUS_PUBLISHED)
        ->field('user.$id')->in($userIds)
    ->group()
        ->field('_id')->expression('$hash')
        ->field('posts')->push($aggregationBuilder->expr()->ifNull('$servicesToPublish', '[]'))
        ->field('users')->push('$users')
;

, что переводится в этот запрос монго: 

db.message.aggregate([{
    "$match": {
        "servicesToPublish.status": "published",
        "user.$id": {
            "$in": [ObjectId("5a733013ce8300b566d15a9b"),...]
        }
    }
}, {
    "$group": {
        "_id": "$hash",
        "posts": {"$push": "$servicesToPublish"},
        "users": {"$push": "$user"}
    }
}]);

вот пример результата 

{
    "_id" : "19a5a9315ba8ac5ffb3779e68b887c805c61d54c",
    "posts" : [ 
        [ 
            {
                "serviceTokenId" : "5a7abe9cce8300c502f38d6c",
                "type" : "text",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T08:20:02.000Z")
            }, 
            {
                "serviceTokenId" : "59c14d0ece83008449843d15",
                "type" : "other",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T08:20:04.000Z")
            }
        ], 
        [ 
            {
                "serviceTokenId" : "59c13700ce83005a66843d15",
                "type" : "text",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T06:21:57.000Z")
            }, 
            {
                "serviceTokenId" : "59c13725ce83005668843d15",
                "type" : "other",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T06:21:59.000Z")
            }
        ]
    ],
    "user" : [ 
        {
            "$ref" : "User",
            "$id" : ObjectId("5a733013ce8300b566d15aa4"),
            "$db" : "master"
        }, 
        {
            "$ref" : "User",
            "$id" : ObjectId("5a7abc2ece83003b6af38d6c"),
            "$db" : "master"
        }
    ]
}

Мне нужно сохранить связьМежду user и posts есть ли способ использовать идентификатор пользователя в качестве ключа в массиве записей (что-то вроде этого: "posts": {"id1":[...], "id2": [...]}) или добавить идентификатор пользователя в каждый элемент массива сообщений, как этот {"userId":"...", "serviceTokenId" : "...","type":"...", "status":"...", "statusUpdatedAt":ISODate("...")}

Если нет способа сделать это, могу ли я быть уверен, что порядок массива posts будет таким же, как у пользовательского?(т.е. первый элемент posts соответствует первому элементу user)

1 Ответ

0 голосов
/ 14 сентября 2018

Вы можете использовать новый этап $ addFields для добавления пользователя к сообщениям.

В обычном запросе monngodb это будет выглядеть так: 

db.message.aggregate([
{
    "$match": {
        "servicesToPublish.status": "published",
        "user.$id": {
            "$in": [ObjectId("5a733013ce8300b566d15a9b"),...]
        }
    }
}, 
{
    "$addFields" : { servicesToPublish: { $map: { 
        input: "$servicesToPublish", 
        as: "service", 
        in: { $mergeObjects: [ "$$service", { user: "$user" } ] }
    } } }
},
{
    "$group": {
        "_id": "$hash",
        "posts": {"$push": "$servicesToPublish"},
        "user": {"$push": "$user"}
    }
}
]);

Какойдолжен дать вам что-то вроде этого: 

{
    "_id" : "19a5a9315ba8ac5ffb3779e68b887c805c61d54c",
    "posts" : [ 
        [ 
            {
                "serviceTokenId" : "5a7abe9cce8300c502f38d6c",
                "type" : "text",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T08:20:02.000Z"),
                "user" : {
                    "$ref" : "User",
                    "$id" : ObjectId("5a733013ce8300b566d15aa4"),
                    "$db" : "master"
                }
            }, 
            {
                "serviceTokenId" : "59c14d0ece83008449843d15",
                "type" : "other",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T08:20:04.000Z")
                "user" : {
                    "$ref" : "User",
                    "$id" : ObjectId("5a733013ce8300b566d15aa4"),
                    "$db" : "master"
                }
            }
        ], 
        [ 
            {
                "serviceTokenId" : "59c13700ce83005a66843d15",
                "type" : "text",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T06:21:57.000Z")
                "user" : {
                    "$ref" : "User",
                    "$id" : ObjectId("5a7abc2ece83003b6af38d6c"),
                    "$db" : "master"
                }
            }, 
            {
                "serviceTokenId" : "59c13725ce83005668843d15",
                "type" : "other",
                "status" : "published",
                "statusUpdatedAt" : ISODate("2018-04-17T06:21:59.000Z")
                "user" : {
                    "$ref" : "User",
                    "$id" : ObjectId("5a7abc2ece83003b6af38d6c"),
                    "$db" : "master"
                }
            }
        ]
    ],
    "user" : [ 
        {
            "$ref" : "User",
            "$id" : ObjectId("5a733013ce8300b566d15aa4"),
            "$db" : "master"
        }, 
        {
            "$ref" : "User",
            "$id" : ObjectId("5a7abc2ece83003b6af38d6c"),
            "$db" : "master"
        }
    ]
}

Вы не можете получить userId в одиночку, так как вы используете DBRef с $ в имени поля.Попытка использовать его как { $mergeObjects: [ "$$services", { userId: "$user.$id" } ] } приводит к ошибке 16410 «Имена полей FieldPath могут не начинаться с« $ »."

...