Home / Questions / 249344
Accepted
cosito
Asked: 2020-03-28 10:47:57 +0800 CST 2020-03-28 10:47:57 +0800 CST

Отношения между коллекциями монго

  • 772

Я начинаю в Mongodb, и, как вы знаете, этого нет relaciones, нет joins tablasи т. Д.

Я пытаюсь передать реляционную диаграмму в NOSQL. У меня есть следующие таблицы.

пользователи

id

name

Сообщения

idUserFrom

idUserTo

messages

Как видите, у таблицы messagesесть внешний идентификатор users, как я могу его создать, хотя его нет в монго, pksи fksкак я могу выполнить этот шаг.

Пока я создал базу данных и одну collectionсо вставкой таблицы users.

> use mongodb
switched to db mongodb
> db
mongodb
> db.users.insert({id:"1",name:"Jorge"})
WriteResult({ "nInserted" : 1 })
> show collections
users
> db.users.find().pretty();
{
        "_id" : ObjectId("5c9bbc275a56aa679bb06155"),
        "id" : "1",
        "name" : "Jorge"
}

collectionsКак я могу сделать так, чтобы это выглядело так : messagesэта таблица содержит идентификатор некоторого пользователя, который может быть idFromилиidTo

db.messages.find().pretty();



  {
            "_id" : ObjectId("5c9bbc275a56aa679bb06155"),
            "idFrom" : "xxxxxxxxxx",
            "idTo"   : "xxxxxxxxxx",
            "message" : "Hola"
    }
mongodb

1 Answers

  1. Best Answer

    В MongoDB существуют отношения между коллекциями. Дело в том, что Mongo является базой данных noSQL . Это означает, что он не использует язык структурированных запросов (или SQL на английском языке). Следовательно, нет такого предложения, как SELECT * FROM table, так как оно типично для этого языка.

    С другой стороны, термин « нереляционная база данных» часто путают с отсутствием отношений. Правда в том, что Mongo позволяет вам реализовывать отношения, но через нечто, известное как ссылки . Ходят даже спокойные разговоры о кардинальности отношений с теми же характеристиками, которые мы знаем в «реляционной» базе данных. Особенность Mongo (как и многих других БД noSQL ) заключается в том, что она не соответствует модели ER (Entity-Relationship) и не придерживается ее точно, поэтому ее называют нереляционной БД .

    ПРОБЛЕМА

    Вы хотите создать связь между двумя коллекциями Mongo. Одна коллекция, называемая пользователями , будет иметь связь с другой коллекцией, называемой сообщениями . Каждый типовой документ должен messageиметь ссылку в двух полях на типовой документ user.

    РЕШЕНИЕ

    Чтобы достичь того, что мы предлагаем, мы должны создать ссылку userв каждом поле типа документа message, где мы хотим создать связь. Mongo предлагает нам два типа ссылок

    Ссылки на руководство

    Они используются для размещения значения _idдокумента в поле другого документа. Затем, если вы хотите получить связанный документ _id, вы должны сделать второй запрос к базе данных, используя информацию указанного значения.

    Предположим, мы создаем коллекцию usersследующим образом:

    > db.users.insert([{"name": "Mauricio", "email": "[email protected]"},{"name": "Patricio", "email": "[email protected]"}])

    Если мы хотим увидеть объекты коллекции users, которую мы только что создали, мы будем использовать метод find():

    > db.users.find({})
{ "_id" : ObjectId("5c9ccc140aee604c4ab6cd06"), "name" : "Mauricio", "email" : "[email protected]" }
{ "_id" : ObjectId("5c9ccc140aee604c4ab6cd07"), "name" : "Patricio", "email" : "[email protected]" }

    Мы видим, что Mongo присвоил значениям _idтип ObjectId. Он делает это автоматически, если мы _idявно не передаем ему значение для поля.

    Теперь мы создадим коллекцию messagesи введем ссылку вручную. Достигаем этого следующим образом:

    > var idMauricio = ObjectId("5c9ccc140aee604c4ab6cd06")
> var idPatricio = ObjectId("5c9ccc140aee604c4ab6cd07")
> db.messages.insert([{"idFrom": idMauricio, "idTo": idPatricio, "message": "¿Como estas?"},{"idFrom": idPatricio, "idTo": idMauricio, "message": "Muy bien, gracias"}])

    (мы использовали соответствующие значения _id)

    Если мы хотим увидеть документы в коллекции, messagesмы снова используем метод find():

    > db.messages.find()
{ "_id" : ObjectId("5c9cce340aee604c4ab6cd08"), "idFrom" : ObjectId("5c9ccc140aee604c4ab6cd06"), "idTo" : ObjectId("5c9ccc140aee604c4ab6cd07"), "message" : "¿Como estas?" }
{ "_id" : ObjectId("5c9cce340aee604c4ab6cd09"), "idFrom" : ObjectId("5c9ccc140aee604c4ab6cd07"), "idTo" : ObjectId("5c9ccc140aee604c4ab6cd06"), "message" : "Muy bien, gracias" }

    Теперь у нас есть вручную связанные документы в коллекции messagesс документами в коллекции users.

    Во многих случаях для нашего приложения будет достаточно этих типов ручных взаимосвязей. Однако, чтобы узнать имя или адрес электронной почты пользователя, отправившего сообщение, или пользователя, получившего сообщение, мы должны сделать второй запрос к базе данных:

    > var cursor = db.messages.find({"_id" : ObjectId("5c9cce340aee604c4ab6cd08")},{"_id":0, "idFrom": 1})
> var message = cursor.hasNext() ? cursor.next() : null
> if (message) {
... var id = message.idFrom
... }
> db.users.find({"_id": id})
{ "_id" : ObjectId("5c9ccc140aee604c4ab6cd06"), "name" : "Mauricio", "email" : "[email protected]" }

    В предыдущем запросе я использовал query( {"_id" : ObjectId("5c9cce340aee604c4ab6cd08")}) в методе find(), а также передал projection( {"_id":0, "idFrom": 1}) в качестве параметра.

    Если бы мы хотели сделать аналогичный запрос на SQL, его можно было бы написать так:

    SELECT idFrom FROM messages WHERE id = "5c9cce340aee604c4ab6cd08"

    Вы можете найти больше информации о методе find()в документации

    Ссылки DBRef

    DBRefs — это соглашение, используемое для представления документа, а не определенного (вручную) типа ссылки, подобного тому, который мы только что видели. Ссылки этого типа включают имя коллекции, к которой принадлежит документ, значение поля_idдокумента и могут включать имя базы данных, к которой принадлежит коллекция.

    Документ DBRefимеет следующий формат: (важно соблюдать порядок полей)

    {"$ref": <value>, "$id": <value>, "$db": <value>}

    Чтобы использовать ссылку на тип DBRefв нашем случае, мы можем сделать это следующим образом:

    > db.messages2.insert([{"idFrom": {"$ref": "users", "$id": ObjectId("5c9ccc140aee604c4ab6cd07")}, "idTo": {"$ref": "users", "$id": ObjectId("5c9ccc140aee604c4ab6cd06")}, "message": "Gracias por responder"},{"idFrom": {"$ref": "users", "$id": ObjectId("5c9ccc140aee604c4ab6cd06")}, "idTo": {"$ref": "users", "$id": ObjectId("5c9ccc140aee604c4ab6cd07")}, "message": "Un gusto ayudarte"}])

    Если мы сделаем запрос к нашей коллекции messages2, мы получим следующее:

    > db.messages2.find()
{ "_id" : ObjectId("5c9cd7e3b6e8c62ece6b9981"), "idFrom" : DBRef("users", ObjectId("5c9ccc140aee604c4ab6cd07")), "idTo" : DBRef("users", ObjectId("5c9ccc140aee604c4ab6cd06")), "message" : "Gracias por responder" }
{ "_id" : ObjectId("5c9cd7e3b6e8c62ece6b9982"), "idFrom" : DBRef("users", ObjectId("5c9ccc140aee604c4ab6cd06")), "idTo" : DBRef("users", ObjectId("5c9ccc140aee604c4ab6cd07")), "message" : "Un gusto ayudarte" }

    Таким образом, мы создали связь между коллекцией messages2и коллекцией, usersиспользуя DBRefs.

    Опять же, чтобы узнать имя или адрес электронной почты пользователя, который отправляет или получает, необходимо сделать второй запрос в базу данных.

    ПРИСОЕДИНИТЬСЯ

    Теперь, поскольку вопрос спрашивает, можно ли выполнять JOIN в Mongo, ответ: ДА, используя метод с именем aggregate(), который, как предполагает его перевод, добавляет что-то к нашему запросу. В этом случае мы можем добавить документы, связанные с в e _idполя коллекции . Этот тип известен как . Таким образом, у нас есть способ получить данные в одном запросе.idFromidTomessagesaggregation$lookup aggregation

    Простой пример этого можно увидеть в следующем запросе:

    > db.messages.aggregate([ {$lookup: {from: "users", localField: "idFrom", foreignField: "_id", as: "sender" }}, {$lookup: {from: "users", localField: "idTo", foreignField: "_id", as: "receiver" }}])
{ "_id" : ObjectId("5c9cce340aee604c4ab6cd08"), "idFrom" : ObjectId("5c9ccc140aee604c4ab6cd06"), "idTo" : ObjectId("5c9ccc140aee604c4ab6cd07"), "message" : "¿Como estas?", "sender" : [ { "_id" : ObjectId("5c9ccc140aee604c4ab6cd06"), "name" : "Mauricio", "email" : "[email protected]" } ], "receiver" : [ { "_id" : ObjectId("5c9ccc140aee604c4ab6cd07"), "name" : "Patricio", "email" : "[email protected]" } ] }
{ "_id" : ObjectId("5c9cce340aee604c4ab6cd09"), "idFrom" : ObjectId("5c9ccc140aee604c4ab6cd07"), "idTo" : ObjectId("5c9ccc140aee604c4ab6cd06"), "message" : "Muy bien, gracias", "sender" : [ { "_id" : ObjectId("5c9ccc140aee604c4ab6cd07"), "name" : "Patricio", "email" : "[email protected]" } ], "receiver" : [ { "_id" : ObjectId("5c9ccc140aee604c4ab6cd06"), "name" : "Mauricio", "email" : "[email protected]" } ] }

    По сути, мы говорим Mongo искать документы в коллекции users, которые _idсоответствуют полю idFrome , idToи добавлять их в возвращенный документ в поле senderи поле receiver.

    В переводе на SQL это простой JOIN или, может быть, запрос типа:

    SELECT *, sender, receiver 
FROM messages 
WHERE sender IN (SELECT * FROM users WHERE id = messages.idFrom)
AND receiver IN (SELECT * FROM users WHERE id = messages.idTo)

    Как видите, почти все, что можно сделать с помощью SQL, можно сделать и в Mongo.

    Надеюсь, это тот ответ, который вы искали.

    • 10