Como deletar dbref em mgo?

9
var (
    type User struct{
        Id bson.ObjectId 'bson:"_id"'
        Name string
    }

type Post struct{
    Id bson.ObjectId 'bson:"_id"'
    Uid string
    User User
    ref mgo.DBRef
    Title string
    }
)
  

// tente 10000 vezes inserções

id := bson.NewObjectId()
user := &User{ id, "test"}
db.C("users").insert(user)

post := db.C("Post").insert(&Post{Uid: id.hex(), ref: mgo.DBRef{"ref":"users", "id": id}, Title:"test dbref"})
  
    

// primeiro caminho tão sujo -_-!

  

// mysql: left join users no user.id = post.uid, como fazer no mgo?

posts := new([]User)
db.C("posts").Find(nil).All(posts)

ids := []bson.ObjectId
for _, p := range posts{
  ids = append(ids, p.Uid)
}

users := make([]User, len(ids))
db.C("users").Find(bson.M{"_id": {"$in": ids}}).All(users)

//and then set the User attribute?
for _,u := range users {
   for _, m := range m{
       if m.Uid == u.Id {
          m.User = m
       }
   }
}
  

caminho secundário, com o atributo ref, mas o mgo.session tentará encontrar

for _,m := range posts{
   db.FindRef(m.ref).One(&m.User)
}
  

// 3a via, com mapReduce ??

é meu primeiro golang + mongodb, então qual é a melhor maneira de arquivar dbref ou junções?

Thx

    
por benyu 22.08.2015 в 10:13
fonte

1 resposta

2

Em vez de usar DBRef , você pode usar apenas método de referência manual para conectar dois ou mais documentos relacionados. Por exemplo, sua estrutura pode ser vista da seguinte maneira:

type User struct{
    Id bson.ObjectId 'bson:"_id"'
    Name string 'json:"name"'
}

type Post struct{
    UserId bson.ObjectId 'json:"userid"' // manual ref to User
    Title string
}

Você pode usar o estágio de agregação $ lookup para realizar uma junção externa esquerda. Por exemplo, para descobrir todas as postagens com base nos usuários:

pipeline := []bson.M{ 
        bson.M{"$lookup": bson.M{
                            "from": "posts", 
                            "foreignField":"userid",
                            "localField":"_id",
                            "as":"posts",
                            },
              },
        }

result := []bson.M{}    
err := coll_users.Pipe(pipeline).All(&result)

Exemplo de resultado:

{
  "_id": ObjectId("590ab726f4bab950360c2dbe"),
  "name": "test",
  "posts": [
    {
      "_id": ObjectId("590ab72619663bad7743ff9e"),
      "userid": ObjectId("590ab726f4bab950360c2dbe"),
      "title": "test manual reference"
    }
  ]
}

Alternativa para armazenar usuários e postagens em coleções separadas, você também pode incorporar / sub-documentar. Veja também Modelagem de dados

    
por Wan Bachtiar 04.05.2017 / 07:25
fonte